Script 'Update a Document' for mongodb

Update a Document

Verified

Created by stephanesbei 919 days ago Viewed 9678 times

Submitted by adam186 Deno

Verified 722 days ago

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

/**
 * @param data_source For example: `Cluster0`
 *
 * @param filter For example: `{ "_id": "01234" }`
 *
 * @param upsert If `true` and no documents match the `filter`,
 * then a new document will be created with the values of `document`.
 * Default is `false`.
 */
type MongodbRest = {
  endpoint: string;
  api_key: string;
};
export async function main(
  auth: MongodbRest,
  data_source: string,
  database: string,
  collection: string,
  filter: Record<string, any>,
  document: Record<string, any>,
  upsert?: boolean,
) {
  const client = new MongoClient({
    endpoint: auth.endpoint,
    dataSource: data_source,
    auth: { apiKey: auth.api_key },
  });
  const docs = client.database(database).collection(collection);
  upsert = typeof upsert === "boolean" ? upsert : undefined;
  return await docs.updateOne(filter, document, { upsert });
}


Other submissions

Submitted by rossmccrann Deno

Created 878 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">,
    db_name: string,
    collection_name: string,
    data: object,
    _id: 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 collection = db.collection(collection_name);

    const { matchedCount, modifiedCount, upsertedId } = await collection.updateOne(
        { _id: ObjectID(_id), },
        { $set: data },
    );

    return ({ matchedCount: matchedCount, modifiedCount: modifiedCount, upsertedId: upsertedId });
}

`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`	* @param filter For example: `{ "_id": "01234" }`
`7`	`*`
`8`	* @param upsert If `true` and no documents match the `filter`,
`9`	* then a new document will be created with the values of `document`.
`10`	* Default is `false`.
`11`	`*/`
`12`	`type MongodbRest = {`
`13`	`endpoint: string;`
`14`	`api_key: string;`
`15`	`};`
`16`	`export async function main(`
`17`	`auth: MongodbRest,`
`18`	`data_source: string,`
`19`	`database: string,`
`20`	`collection: string,`
`21`	`filter: Record<string, any>,`
`22`	`document: Record<string, any>,`
`23`	`upsert?: boolean,`
`24`	`) {`
`25`	`const client = new MongoClient({`
`26`	`endpoint: auth.endpoint,`
`27`	`dataSource: data_source,`
`28`	`auth: { apiKey: auth.api_key },`
`29`	`});`
`30`	`const docs = client.database(database).collection(collection);`
`31`	`upsert = typeof upsert === "boolean" ? upsert : undefined;`
`32`	`return await docs.updateOne(filter, document, { upsert });`
`33`	`}`
`34`

`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`
`26`	`export async function main(`
`27`	`mongodb_con: wmill.Resource<"mongodb">,`
`28`	`db_name: string,`
`29`	`collection_name: string,`
`30`	`data: object,`
`31`	`_id: string`
`32`
`33`	`) {`
`34`	`const client = new MongoClient();`
`35`
`36`	`// Connecting to a Mongo Atlas Database`
`37`	`const resp = await client.connect(mongodb_con);`
`38`
`39`	`const db = client.database(db_name);`
`40`	`const collection = db.collection(collection_name);`
`41`
`42`	`const { matchedCount, modifiedCount, upsertedId } = await collection.updateOne(`
`43`	`{ _id: ObjectID(_id), },`
`44`	`{ $set: data },`
`45`	`);`
`46`
`47`	`return ({ matchedCount: matchedCount, modifiedCount: modifiedCount, upsertedId: upsertedId });`
`48`	`}`