Support of MongoDB for TypeScript

import { MongoClient, Db, Collection, Document, BulkWriteResult } from "mongodb";

const uri = "mongodb://localhost:27017";
const client = new MongoClient(uri);

async function my_add_object(): Promise<void> {
  const db: Db = client.db("testdb");
  const foo: Collection<Document> = db.collection("FooCollection");

  // Insert a single object
  const result = await foo.insertOne({ name: "Alice", age: 25, active: true });
  console.log("Inserted object:", result.insertedId);
}

async function my_bulkwrite(): Promise<void> {
  const db: Db = client.db("testdb");
  const foo: Collection<Document> = db.collection("FooCollection");

  // Perform multiple operations in bulk
  const result: BulkWriteResult = await foo.bulkWrite([
    { insertOne: { document: { name: "Bob", age: 30, active: false } } },
    { updateOne: { filter: { name: "Alice" }, update: { $set: { active: false } } } },
    { deleteOne: { filter: { name: "Charlie" } } }
  ]);

  console.log("BulkWrite result:", result);
}

async function my_aggregate(): Promise<void> {
  const db: Db = client.db("testdb");
  const foo: Collection<Document> = db.collection("FooCollection");

  // Simple aggregation: group by 'active' and count, then merge results into another collection
  const pipeline = [
    { $group: { _id: "$active", count: { $sum: 1 } } },
    { $merge: { into: "TargetCollection", whenMatched: "merge", whenNotMatched: "insert" } }
  ];

  const result = await foo.aggregate(pipeline).toArray();
  console.log("Aggregation result (before merge):", result);

  // Check TargetCollection contents
  const target: Collection<Document> = db.collection("TargetCollection");
  const merged = await target.find().toArray();
  console.log("TargetCollection after merge:", merged);
}

async function main(): Promise<void> {
  try {
    await client.connect();
    await my_add_object();
    await my_bulkwrite();
    await my_aggregate();
  } catch (err) {
    console.error("Error:", err);
  } finally {
    await client.close();
  }
}

main().catch(console.error);

// foo-mongoose-example.ts
import { Schema, model, connect, disconnect }  from 'mongoose;

const uri = "mongodb://localhost:27017/testdb";

// Define schema & model
const fooSchema = new Schema({
  name: String,
  age: Number,
  active: Boolean,
});
const FooCollection = model("FooCollection", fooSchema);

async function my_add_object() {
  // Insert a single object using the model
  const doc = new FooCollection({ name: "Alice", age: 25, active: true });
  await doc.save();
  console.log("Inserted object:", doc._id);
}

async function my_bulkwrite() {
  // Use the model's bulkWrite API
  const result = await FooCollection.bulkWrite([
    { insertOne: { document: { name: "Bob", age: 30, active: false } } },
    { updateOne: { filter: { name: "Alice" }, update: { $set: { active: false } } } },
    { deleteOne: { filter: { name: "Charlie" } } },
  ]);

  console.log("BulkWrite result:", result);
}

async function my_aggregate() {
  // Simple aggregation: group by 'active' and count
  const pipeline = [
    { $group: { _id: "$active", count: { $sum: 1 } } },
    {
      $merge: {
        into: "TargetCollection",
        whenMatched: "merge",
        whenNotMatched: "insert",
      },
    },
  ];

  const result = await FooCollection.aggregate(pipeline);
  console.log("Aggregation result (before merge):", result);
}

async function main() {
  try {
    await connect(uri);

    await my_add_object();
    await my_bulkwrite();
    await my_aggregate();
  } finally {
    await disconnect();
  }
}

main().catch(console.error);