Nodejs数据库查询构建器knex的使用

Nodejs数据库查询构建器knex的使用
Knex.js 是一个 SQL 查询构建器，它为 Node.js 环境提供了强大的 SQL 构建功能。你可以用它来生成和执行各种复杂的 SQL 查询。下面我将向你介绍如何安装和使用 Knex。

安装

首先你需要安装 Knex 和你的数据库驱动。例如，如果你正在使用 PostgreSQL，你可以运行以下命令：

npm install knex --save
npm install pg --save

对于 MySQL，你可以这样做：

npm install knex --save
npm install mysql2 --save

配置 Knex

在项目中创建一个文件，比如 knexfile.js 来配置 Knex：

const path = require('path');

module.exports = {

  development: {
    client: 'sqlite3',
    connection: {
      filename: path.join(__dirname, '../db/development.sqlite3'),
    },
    useNullAsDefault: true,
  },

  production: {
    client: 'postgresql',
    connection: process.env.DATABASE_URL,
    pool: { min: 2, max: 10 },
    migrations: {
      tableName: 'knex_migrations'
    }
  }

};

初始化 Knex

在你的应用入口文件（例如 index.js 或 app.js）中初始化 Knex：

const knex = require('knex')({
  client: 'sqlite3', // 或者 'pg' for PostgreSQL
  connection: {
    filename: './db/development.sqlite3'
  },
  useNullAsDefault: true
});

// 或者基于环境变量选择不同的配置
const environment = process.env.NODE_ENV || 'development';
const config = require('./knexfile')[environment];
const knex = require('knex')(config);

执行基本查询

插入数据

knex('users').insert({ name: 'John Doe', email: 'john@example.com' })
  .then(id => console.log(id))
  .catch(err => console.error(err));

查询数据

knex('users')
  .select('*')
  .where('email', 'like', '%example.com%')
  .then(rows => console.log(rows))
  .catch(err => console.error(err));

更新数据

knex('users')
  .update({ email: 'newemail@example.com' })
  .where('id', 1)
  .then(() => console.log("Updated"))
  .catch(err => console.error(err));

删除数据

knex('users')
  .del()
  .where('id', 1)
  .then(() => console.log("Deleted"))
  .catch(err => console.error(err));

使用事务

knex.transaction(function (trx) {
  return knex('users')
    .transacting(trx)
    .insert({ name: 'Jane Doe', email: 'jane@example.com' })
    .then(function () {
      return knex('profiles')
        .transacting(trx)
        .insert({ user_id: 2, bio: 'A new user.' });
    })
    .then(trx.commit)
    .catch(trx.rollback);
}).catch(function (err) {
  console.log(err);
});

以上就是 Knex.js 的一些基础用法。通过这些示例，你可以开始构建更复杂的 SQL 查询。