Script 'Search Documents' for mongodb

Search Documents

Verified

Created by rossumblament 1078 days ago Viewed 24329 times

Submitted by adam186 Deno

Verified 881 days ago

import { removeObjectEmptyFields } from "https://deno.land/x/windmill_helpers@v1.0.1/mod.ts";
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" }`
 * Find out more at:
 * https://www.mongodb.com/docs/manual/reference/method/db.collection.find/
 */
type MongodbRest = {
  endpoint: string;
  api_key: string;
};
export async function main(
  auth: MongodbRest,
  data_source: string,
  database: string,
  collection: string,
  filter?: Record<string, any>,
  projection?: Record<string, number>,
  sort?: Record<string, number>,
  limit?: number,
  skip?: number,
) {
  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.find(
    filter,
    removeObjectEmptyFields({ projection, sort, limit, skip }),
  );
}


Other submissions

Submitted by rossmccrann Deno

Created 1036 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",
  },
});

@param: {object} filter - Object to filter mongodb documents
example:
{ username: { $ne: null } }

*/

export async function main(
    mongodb_con: wmill.Resource<"mongodb">,
    db_name: string,
    collection_name: string,
    filter: object
) {
    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 all_collection = await collection.find(filter).toArray();

    return (all_collection ? 'Documents Found in MongoDB' : 'Documents Not Found');
}

`1`	`import { removeObjectEmptyFields } from "https://deno.land/x/windmill_helpers@v1.0.1/mod.ts";`
`2`	`import { MongoClient } from "https://deno.land/x/atlas_sdk@v1.0.3/mod.ts";`
`3`
`4`	`/**`
`5`	* @param data_source For example: `Cluster0`
`6`	`*`
`7`	* @param filter For example: `{ "_id": "01234" }`
`8`	`* Find out more at:`
`9`	`* https://www.mongodb.com/docs/manual/reference/method/db.collection.find/`
`10`	`*/`
`11`	`type MongodbRest = {`
`12`	`endpoint: string;`
`13`	`api_key: string;`
`14`	`};`
`15`	`export async function main(`
`16`	`auth: MongodbRest,`
`17`	`data_source: string,`
`18`	`database: string,`
`19`	`collection: string,`
`20`	`filter?: Record<string, any>,`
`21`	`projection?: Record<string, number>,`
`22`	`sort?: Record<string, number>,`
`23`	`limit?: number,`
`24`	`skip?: number,`
`25`	`) {`
`26`	`const client = new MongoClient({`
`27`	`endpoint: auth.endpoint,`
`28`	`dataSource: data_source,`
`29`	`auth: { apiKey: auth.api_key },`
`30`	`});`
`31`	`const documents = client.database(database).collection(collection);`
`32`	`return await documents.find(`
`33`	`filter,`
`34`	`removeObjectEmptyFields({ projection, sort, limit, skip }),`
`35`	`);`
`36`	`}`
`37`

`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`	`@param: {object} filter - Object to filter mongodb documents`
`25`	`example:`
`26`	`{ username: { $ne: null } }`
`27`
`28`	`*/`
`29`
`30`	`export async function main(`
`31`	`mongodb_con: wmill.Resource<"mongodb">,`
`32`	`db_name: string,`
`33`	`collection_name: string,`
`34`	`filter: object`
`35`	`) {`
`36`	`const client = new MongoClient();`
`37`
`38`	`// Connecting to a Mongo Atlas Database`
`39`	`const resp = await client.connect(mongodb_con);`
`40`
`41`	`const db = client.database(db_name);`
`42`	`const collection = db.collection(collection_name);`
`43`
`44`	`const all_collection = await collection.find(filter).toArray();`
`45`
`46`	`return (all_collection ? 'Documents Found in MongoDB' : 'Documents Not Found');`
`47`	`}`