Script 'Create New Document' for mongodb

Create New Document

Verified

Created by armancemaripota 899 days ago Viewed 10101 times

Submitted by adam186 Deno

Verified 701 days ago

import { MongoClient } from "https://deno.land/x/atlas_sdk@v1.0.3/mod.ts";

/**
 * @param data_source For example: `Cluster0`
 */
type MongodbRest = {
  endpoint: string;
  api_key: string;
};
export async function main(
  auth: MongodbRest,
  data_source: string,
  database: string,
  collection: string,
  document: Record<string, any>,
) {
  const client = new MongoClient({
    endpoint: auth.endpoint,
    dataSource: data_source,
    auth: { apiKey: auth.api_key },
  });
  const documents = client.database(database).collection(collection);
  return await documents.insertOne(document);
}


Other submissions

Submitted by rossmccrann Deno

Created 857 days ago

All edits

Permalink

import * as wmill from "https://deno.land/x/windmill@v1.19.2/mod.ts";
import { Bson, MongoClient } from "https://deno.land/x/mongo@v0.30.1/mod.ts";

/*
@param: {wmill.Resource} mongodb - Resource containing mongodb connection object
example:
await client.connect({
  db: "<db_name>",
  tls: true,
  servers: [
    {
      host: "<db_cluster_url>",
      port: 27017,
    },
  ],
  credential: {
    username: "<username>",
    password: "<password>",
    db: "<db_name>",
    mechanism: "SCRAM-SHA-1",
  },
});
*/

export async function main(
    mongodb_con: wmill.Resource<"mongodb">,
    new_document: object,
    db_name: string,
    collection_name: string,
) {
    const client = new MongoClient();

    // Connecting to a Mongo Atlas Database
    const resp = await client.connect(mongodb_con);

    const db = client.database(db_name);
    const coll = db.collection(collection_name);

    const insertId = await coll.insertOne(new_document);

    return `Document inserted in MongoDB`;
}


`1`	`import { MongoClient } from "https://deno.land/x/atlas_sdk@v1.0.3/mod.ts";`
`2`
`3`	`/**`
`4`	* @param data_source For example: `Cluster0`
`5`	`*/`
`6`	`type MongodbRest = {`
`7`	`endpoint: string;`
`8`	`api_key: string;`
`9`	`};`
`10`	`export async function main(`
`11`	`auth: MongodbRest,`
`12`	`data_source: string,`
`13`	`database: string,`
`14`	`collection: string,`
`15`	`document: Record<string, any>,`
`16`	`) {`
`17`	`const client = new MongoClient({`
`18`	`endpoint: auth.endpoint,`
`19`	`dataSource: data_source,`
`20`	`auth: { apiKey: auth.api_key },`
`21`	`});`
`22`	`const documents = client.database(database).collection(collection);`
`23`	`return await documents.insertOne(document);`
`24`	`}`
`25`

`1`	`import * as wmill from "https://deno.land/x/windmill@v1.19.2/mod.ts";`
`2`	`import { Bson, MongoClient } from "https://deno.land/x/mongo@v0.30.1/mod.ts";`
`3`
`4`	`/*`
`5`	`@param: {wmill.Resource} mongodb - Resource containing mongodb connection object`
`6`	`example:`
`7`	`await client.connect({`
`8`	`db: "<db_name>",`
`9`	`tls: true,`
`10`	`servers: [`
`11`	`{`
`12`	`host: "<db_cluster_url>",`
`13`	`port: 27017,`
`14`	`},`
`15`	`],`
`16`	`credential: {`
`17`	`username: "<username>",`
`18`	`password: "<password>",`
`19`	`db: "<db_name>",`
`20`	`mechanism: "SCRAM-SHA-1",`
`21`	`},`
`22`	`});`
`23`	`*/`
`24`
`25`	`export async function main(`
`26`	`mongodb_con: wmill.Resource<"mongodb">,`
`27`	`new_document: object,`
`28`	`db_name: string,`
`29`	`collection_name: string,`
`30`	`) {`
`31`	`const client = new MongoClient();`
`32`
`33`	`// Connecting to a Mongo Atlas Database`
`34`	`const resp = await client.connect(mongodb_con);`
`35`
`36`	`const db = client.database(db_name);`
`37`	`const coll = db.collection(collection_name);`
`38`
`39`	`const insertId = await coll.insertOne(new_document);`
`40`
`41`	return `Document inserted in MongoDB`;
`42`	`}`
`43`