TypeScript rethinkdb.db函数代码示例

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

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

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

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

示例1: doc

r.connect({ host: "localhost", port: 28015 }).then(function(conn: r.Connection) {
    console.log("HI", conn);

    const testDb = r.db("test");

    r.table("players").hasFields("games_won").run(conn).then(cursorCallback);
    r.table("players").hasFields({ "games_won": { "championships": true } }).run(conn).then(cursorCallback);
    r.table("players").filter(r.row.hasFields("games_won").not()).run(conn).then(cursorCallback);
    r.table("players").filter(r.row.hasFields({ "games_won": { "championships": true } }).not()).run(conn).then(cursorCallback);

    testDb.tableCreate("users").run(conn).then(function() {
        const users = testDb.table("users");

        users.insert({ name: "bob" }).run(conn, function() {
        });

        users.filter(function(doc?) {
            return doc("henry").eq("bob");
        })
        .between("james", "beth")
        .limit(4)
        .run(conn)
        .then((cursor: r.Cursor) => {
          cursor.toArray().then((rows: any[]) => {
            console.log(rows);
          });
        });
    });
});

开发者ID:ArtemZag，项目名称:DefinitelyTyped，代码行数:29，代码来源:rethinkdb-tests.ts

示例2: function

 r.dbCreate('howmidoin').run(conn, function(err, res) {
   if(err) {}
   console.log('second')
   r.db('howmidoin').tableCreate('data').run(conn, function(err, res) {
   	if(err) {}
   	console.log('third')
 	});
 });

开发者ID:argonauthills，项目名称:howmidoin，代码行数:8，代码来源:server.ts

示例3: function

r.connect({ host: "localhost", port: 28015 }, function(err: Error, conn: r.Connection) {
    console.log("HI", err, conn);

    conn.server((err, server) => {});

    const testDb = r.db("test");

    r.table("players").hasFields("games_won").run(conn, errorAndCursorCallback);
    r.table("players").hasFields({ "games_won": { "championships": true } }).run(conn, errorAndCursorCallback);
    r.table("players").filter(r.row.hasFields("games_won").not()).run(conn, errorAndCursorCallback);
    r.table("players").filter(r.row.hasFields({ "games_won": { "championships": true } }).not()).run(conn, errorAndCursorCallback);

    r.table("players").filter(
      r.row.hasFields("games_won").not()
      .or(r.row("games_won").not().eq(true))
      .and(true)
    )
    .run(conn, errorAndCursorCallback);

    const center = r.point(123, 456);
    r.table("geo")
      .getIntersecting(r.circle(center, 1000, { unit: "m" }), { index: "location" })
      .orderBy(r.row("location").distance(center, { unit: "m" }))
      .eqJoin("external", testDb.table("other"), { index: "external" })
      .getField("right")
      .run(conn, errorAndCursorCallback);

    testDb.tableCreate("users").run(conn, function(err, stuff) {
        const users = testDb.table("users");
        users.wait({waitFor: 'ready_for_reads'});
        users.insert({ name: "bob" }).run(conn, function() {
        });

        users.hasFields("foo_bar").run(conn, () => {});

        users.filter(function(doc?) {
            return doc("henry").eq("bob");
        })
        .filter(r.row("updatedAt").default(0).lt(r.now().sub(1000)))
        .between("james", "beth")
        .limit(4)
        .run(conn, function(err, cursor) {
          cursor.toArray<string>((err, strings) => {
            console.log(strings);
          });
        });
    });

    testDb.table("users").indexCreate("name_index", [r.row("name")]);

    r.js("'str1' + 'str2'").run(conn, function (err, value) {});
    r.uuid().run(conn, function (err, uuid) {});
    r.uuid("input value").run(conn, function (err, uuid) {});

    r.table("games").changes().run(conn, function(err, cursor) {
      cursor.each(console.log);
    });
});

开发者ID:VincentDamour，项目名称:DefinitelyTyped，代码行数:58，代码来源:rethinkdb-tests.ts

示例4: PrepareTablesEvent

        r.connect({host: 'localhost', port: 28015}, (err, conn) => {
            if (err) throw err;
            dbConnection = conn;

            r.dbCreate('lingua').run(conn, (er, rtr) => {
                //console.log(er);
            });


            db = r.db('lingua');

            new PrepareTablesEvent().dispatch();
        });

开发者ID:joergwasmeier，项目名称:lingua，代码行数:13，代码来源:A_Server.ts

示例5: obtenerPosts

async function obtenerPosts(ctx) {
  try {
    let con = await r.connect(config);
    let query = await r.db('blog').table('posts').orderBy(r.desc('fecha')).run(con);
    let posts = await query.toArray();    

    ctx.body = posts;
  } catch (e) {
    ctx.status = 500;
    ctx.body = {
      status: ctx.status,
      error: e.message
    }
  }
}

开发者ID:melendezgg，项目名称:koa2-rethinkdb-typescript，代码行数:15，代码来源:server.ts

示例6: function

r.connect({ host: "localhost", port: 28015 }, function(err: Error, conn: r.Connection) {
    console.log("HI", err, conn);

    const testDb = r.db("test");

    r.table("players").hasFields("games_won").run(conn, errorAndCursorCallback);
    r.table("players").hasFields({ "games_won": { "championships": true } }).run(conn, errorAndCursorCallback);
    r.table("players").filter(r.row.hasFields("games_won").not()).run(conn, errorAndCursorCallback);
    r.table("players").filter(r.row.hasFields({ "games_won": { "championships": true } }).not()).run(conn, errorAndCursorCallback);

    r.table("players").filter(
      r.row.hasFields("games_won").not()
      .or(r.row("games_won").not().eq(true))
      .and(true)
    )
    .run(conn, errorAndCursorCallback);

    testDb.tableCreate("users").run(conn, function(err, stuff) {
        const users = testDb.table("users");

        users.insert({ name: "bob" }).run(conn, function() {
        });

        users.hasFields("foo_bar").run(conn, () => {});

        users.filter(function(doc?) {
            return doc("henry").eq("bob");
        })
        .filter(r.row("updatedAt").default(0).lt(r.now().sub(1000)))
        .between("james", "beth")
        .limit(4)
        .run(conn, function(err, cursor) {
          cursor.toArray<string>((err, strings) => {
            console.log(strings);
          });
        });
    });

    r.js("'str1' + 'str2'").run(conn, function (err, value) {});
    r.uuid().run(conn, function (err, uuid) {});
    r.uuid("input value").run(conn, function (err, uuid) {});

    r.table("games").changes().run(conn, function(err, cursor) {
      cursor.each(console.log);
    });
});

开发者ID:ArtemZag，项目名称:DefinitelyTyped，代码行数:46，代码来源:rethinkdb-tests.ts

示例7: moment

router.post('/', (req: any, res) => {
    if (req.body && req.body.email && req.body.password) {

        r.db(config.DB_NAME).table('users').filter({ email: req.body.email }).run(req.conn)
            .then((cursor) => {
                cursor.next((err, row) => {
                    if (err && err.message.indexOf('No more rows ') > -1) {
                        const salt = bcrypt.genSaltSync(saltRounds);
                        if (!salt) res.status(500).end('User registration failed try again later.');
                        const hash = bcrypt.hashSync(req.body.password, salt);
                        if (!hash) res.status(500).end('User registration failed try again later.');
                        const refresh_token = crypto.randomBytes(20).toString('hex');
                        if (!refresh_token) res.status(500).end('User registration failed try again later.');
                        r.table("users").insert({ isAdmin: false, email: req.body.email, password: hash, refresh_token: refresh_token }).run(req.conn)
                            .then((result) => {
                                const exp = moment().add(3, "months").valueOf();
                                const user = { userId: result.generated_keys[0], email: req.body.email, expires: exp, refresh_token: refresh_token, access_token: jwtoken.sign({ isAdmin: false }, config.SECRET, { issuer: result.generated_keys[0], expiresIn: exp }) };
                                res.set('Content-Type', 'application/json');
                                res.json(user);
                            }, (err) => {
                                console.log(err)
                                res.status(500).end('Internal server error');
                            })
                    } else if (row) {
                        res.end('An account already exists for this email address.');
                    }

                })
            },
            (err) => {
                console.log(err)
                res.status(500).end('Internal server error');
            })
    } else if (req.body && !req.body.email) {
        res.status(500).end('Email cannot be empty');
    } else if (req.body && !req.body.password) {
        res.status(500).end('Password cannot be empty');
    }
});

开发者ID:triniwiz，项目名称:mojichat-api，代码行数:39，代码来源:users.ts

示例8: crearPost

async function crearPost(ctx) {  
  try {    
    let { titulo, texto } = ctx.request.body;    
    let con = await r.connect(config);
        
    let post = await r.db('blog').table('posts').insert({
      titulo: titulo,
      fecha: r.now(),
      texto: texto
    }).run(con);
    
    ctx.body = {
      post_id: post.generated_keys[0] 
    }
  } catch (e) {
    ctx.status = 500;
    ctx.body = {
      status: ctx.status,
      error: e.message
    }
  }
}

开发者ID:melendezgg，项目名称:koa2-rethinkdb-typescript，代码行数:22，代码来源:server.ts

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