恕我直言，虽然MongoDB可以做到这一点，但我不建议为每个域维护一个单独的数据库，特别是如果您希望拥有大量的数据库。您是否考虑过使用多租户模型？
下面的示例代码将用户'Alex'添加到两个不同的数据库“domainOne”和“domainTwo”中。

var mongoose = require('mongoose');
var personSchema = { name: String, domain : String };
var baseUri = 'mongodb://localhost/';

domains.forEach((domain) => {
    var conn = mongoose.createConnection(baseUri + domain, (error) => {
    if(error){
        console.log('Ups! Database connection failed!');
        return;
    }
    //Use the connection object to create your models,
    //instead the mongoose object
    //so that our data is saved into the database
    //associated with this connection
    var Person = conn.model('Person', personSchema);

    //Lets add user 'Alex' into the database
    (new Person({name : 'Alex', domain : domain })).save((error) => {
        if(error){
            console.log('Ups! Could not save person');
        } else {
            conn.close();
        }
    });
    });
});

这是我如何实现我的项目：

// config/db.ts
import {createConnection} from 'mongoose'

const MONGO_URI = process.env.MONGO_URI

if (!MONGO_URI)
  throw new Error(
    'Please define the MONGO_URI environment variable inside .env'
  )

const connections: any = {}

async function db(dbName: string) {
  if (connections[dbName]) {
    return connections[dbName]
  } else {
    connections[dbName] = createConnection(`${MONGO_URI}/${dbName}`)
    return connections[dbName]
  }
}

export default db



// models/Test.ts
import { Schema } from 'mongoose'

export interface ITest {
  _id: Schema.Types.ObjectId
  name: string
  createdAt?: Date
}

const testSchema = new Schema<ITest>(
  {
    name: { type: String, required: true },
  },
  { timestamps: true }
)

export default testSchema



// pages/api/test.ts
import nc from 'next-connect'
import db from '../../config/db'
import testSchema from '../../models/Test'

const handler = nc()

handler.get(
  async (req: NextApiRequestExtended, res: NextApiResponseExtended) => {
    try {
      const conn = await db(req.headers['x-db-key'])
      const model = await conn.model('Test', testSchema)

      const data = await model.find({})

      res.send(data)
    } catch (error: any) {
      res.status(500).json({ error: error.message })
    }
  }
)

export default handler