TypeScript mongodb.connect函数代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› TypeScript›TypeScript教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了TypeScript中mongodb.connect函数的典型用法代码示例。如果您正苦于以下问题：TypeScript connect函数的具体用法？TypeScript connect怎么用？TypeScript connect使用的例子？那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。

在下文中一共展示了connect函数的5个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的TypeScript代码示例。

示例1: init

async function init() {

    log(`Connecting to system database...`);

    while (!systemDB)
        try {
            systemDB = await mongodb.connect(make_mongo_url(config.systemDatabase));
        } catch (err) {
            console.log(err);
            log.warn('Could not connect to system database. Retrying in 1s...');
            await new Promise(r => setTimeout(r, 1e3));
        }

    var clientConfig = await systemDB.collection('clients').find({ id: clientID }).toArray();

    if (!clientConfig.length)
        await systemDB.collection('clients').insert({ id: clientID });
    else
        clientConfig = clientConfig[0];

    if (!clientConfig.role) {
        log.warn(`No client configuration in database. Client idle.`);
        return;
    }

    log(`Role: ${colors.magenta(clientConfig.role.toUpperCase())}`);
    log(`Instances: ${colors.magenta(clientConfig.instances)}`);

    require(roleHandlerMap[clientConfig.role]).default(clientConfig, flags, config, numOfCores);

    log.green('Master process initialized.');

}

开发者ID:raelgor，项目名称:zen-arena，代码行数:33，代码来源:main.ts

示例2: init

export async function init() {
    if(collection) {
        return collection;
    }
    
    assert(dbName, 'Mongo DB name should be specified');
    assert(collectionName, 'Mongo collection name should be specified');
    assert(connectionString, 'Mongo connection string should be specified');

    try {
        const client = await connect(connectionString as string, {
            useNewUrlParser: true,
        });
        return collection =  client.db(dbName).collection<ChatShape>(collectionName as string)
    } catch (error) {
        throw error;
    }
}

开发者ID:ddddm，项目名称:remind-to-pay-netflix-bot，代码行数:18，代码来源:index.ts

示例3: function

        async function(req, res){
            try{

                    MongoClient.connect(process.env.MONGO_URL, async (err, db)=>{
                        const uploadsDir = `${__dirname}/uploads`;
                        let filesOnDisk = fs.readdirSync(`${uploadsDir}`);

                        let filesFromDb = [
                            ...await getBrandPhotos(db),
                            ...await getContactPhotos(db),
                            ...await getFavoursPhotos(db),
                            ...await getMastersPhotos(db),
                            ...await getProductsPhotos(db),
                            ...await getModelsPhotos(db),
                            ...await getCoursesPhotos(db),
                            ...await getSalonsPhotos(db),
                            ...await getTransformsPhotos(db),
                        ].map(url=>url.split('/')[3]);

                        let unusedFiles = arrayDiff(filesOnDisk, filesFromDb);
                        let wrongRecords = arrayDiff(filesFromDb, filesOnDisk);

                        console.log('filesOnDisk length ', filesOnDisk.length);
                        console.log('filesFromDb length ', filesFromDb.length);
                        console.log('unusedFiles length', unusedFiles.length);
                        console.log('wrongRecords', wrongRecords);

                        unusedFiles.forEach((file:string)=>fs.unlink(`${uploadsDir}/${file}`));
                        console.log(`${unusedFiles.length} files deleted`);
                        process.exit();
                    });

                res.status(200).end();
            }catch (err){
                res.status(404).end();
            }
        }

开发者ID:galyna，项目名称:PalamarGroup，代码行数:37，代码来源:photo.endpoint.ts

示例4: init

    /**
     * 初期化
     */
    static async init() : Promise<void>
    {
        const log = slog.stepIn('MongoDB', 'init');
        try
        {
            if (Config.hasMongoDB())
            {
                const url = Config.MONGO_URL;
                Database.db = await mongodb.connect(url);
            }

            log.stepOut();
        }
        catch (err)
        {
            console.error('MongoDBの初期化に失敗しました。');
            console.error(err.message);
            log.e(err.message);
            log.stepOut();

            // すぐに終了するとログが出力されないので数秒待ってから終了する
            setTimeout(() => process.exit(-1), 3000);
        }
    }

开发者ID:nandai，项目名称:web-service-template，代码行数:27，代码来源:mongodb.ts

示例5: testFunc

async function testFunc(): Promise<mongodb.MongoClient> {
    const testClient: mongodb.MongoClient = await mongodb.connect(connectionString);
    return testClient;
}

开发者ID:CNBoland，项目名称:DefinitelyTyped，代码行数:4，代码来源:mongodb-tests.ts

注：本文中的mongodb.connect函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。