knex
Knex是一个基于JavaScript的查询生成器，它允许你使用JavaScript代码来生成和执行SQL查询语句。它提供了一种简单和直观的方式来与关系型数据库进行交互，而无需直接编写SQL语句。你可以使用Knex定义表结构、执行查询、插入、更新和删除数据等操作。
https://knexjs.org/guide/query-builder.html#withrecursive
Knex的安装和设置
knex支持多种数据库 pg sqlite3 mysql2 oracledb tedious
用什么数据库安装对应的数据库就行了
#安装knex
$ npm install knex --save#安装你用的数据库
$ npm install pg
$ npm install pg-native
$ npm install sqlite3
$ npm install better-sqlite3
$ npm install mysql
$ npm install mysql2
$ npm install oracledb
$ npm install tedious
连接数据库
import knex from 'knex'
const db = knex({client: "mysql2",connection: config.db
})
db:user: rootpassword: '123456'host: localhostport: 3306database: xiaoman
定义表结构
db.schema.createTable('list', (table) => {table.increments('id') //id自增table.integer('age') //age 整数table.string('name') //name 字符串table.string('hobby') //hobby 字符串table.timestamps(true,true) //创建时间和更新时间
}).then(() => {console.log('创建成功')
})
实现增删改差
import mysql2 from 'mysql2/promise'
import fs from 'node:fs'
import jsyaml from 'js-yaml'
import express from 'express'
import knex from 'knex'
const yaml = fs.readFileSync('./db.config.yaml', 'utf8')
const config = jsyaml.load(yaml)
// const sql = await mysql2.createConnection({
// ...config.db
// })
const db = knex({client: "mysql2",connection: config.db
})const app = express()
app.use(express.json())
//查询接口 全部
app.get('/', async (req, res) => {const data = await db('list').select().orderBy('id', 'desc')const total = await db('list').count('* as total')res.json({code: 200,data,total: total[0].total,})
})
//单个查询 params
app.get('/user/:id', async (req, res) => {const row = await db('list').select().where({ id: req.params.id })res.json({code: 200,data: row})
})//新增接口
app.post('/create', async (req, res) => {const { name, age, hobby } = req.bodyconst detail = await db('list').insert({ name, age, hobby })res.send({code: 200,data: detail})
})//编辑
app.post('/update', async (req, res) => {const { name, age, hobby, id } = req.bodyconst info = await db('list').update({ name, age, hobby }).where({ id })res.json({code: 200,data: info})
})
//删除
app.post('/delete', async (req, res) => {const info = await db('list').delete().where({ id: req.body.id })res.json({code: 200,data: info})
})
const port = 3000app.listen(port, () => {console.log(`Example app listening on port ${port}`)
})
事务
你可以使用事务来确保一组数据库操作的原子性，即要么全部成功提交，要么全部回滚
例如A给B转钱，需要两条语句，如果A语句成功了，B语句因为一些场景失败了，那这钱就丢了，所以事务就是为了解决这个问题，要么都成功，要么都回滚，保证金钱不会丢失。
//伪代码
db.transaction(async (trx) => {try {await trx('list').update({money: -100}).where({ id: 1 }) //Aawait trx('list').update({money: +100}).where({ id: 2 }) //Bawait trx.commit() //提交事务}catch (err) {await trx.rollback() //回滚事务}})
