It is written in JavaScript,crud for mysql.You can also use transactions very easily.node
mysqls 一款專爲node.js生成sql語句的插件,鏈式調用,使用靈活。支持生成sql語法,也支持生成語法以後直接調用,支持事物等特性。
API參考很流行的ThinkPHP模型API。mysql
npm install mysqls --save-dev
- init: sql初始化API
- exec: 執行sql語句
- sql: 鏈式調用生成sql語句,支持生成後直接執行sql語句
- transaction: 執行事務API
//import方式 import { init, exec, sql, transaction } from 'mysqls' //require方式 let { init, exec, sql, transaction } = require('mysqls')
// 可在項目的啓動時初始化配置 init({ host: 'localhost', user: 'root', password:'123456', database: 'test', port: 3306, })
- ispool: 是否以鏈接池的方式初始化 (default:true)
- host: host地址 (default:'127.0.0.1')
- user: 用戶名 (default:'root')
- password: 數據庫密碼 (default:'root')
- database: 使用的數據庫 (default:'test')
- port: 端口 (default:'3306')
- waitConnection: 是否等待連接(鏈接池時使用) (default:true)
- connectionLimit: 鏈接池大小 (default:10)
- queueLimit: 排隊限制 (default:0)
sql .table('node_table') .field('id,name') .where({id:1}) .select() // result SELECT id,name FROM node_table WHERE id=1
const sqlstr = sql .table('node_table') .field('id,name') .where({id:1}) .select(); const result = await exec(sqlstr);
const result = sql .table('node_table') .field('id,name') .where({id:1}) .select(true) .exec();
//使用 exec 函數 exec(sql.table('web_pages').where({id:147}).select()) .then(res=>{ console.log(res) }).catch(err=>{ console.log(err) }) // 使用 exec 方法 sql.table('web_pages').where({id:147}).select(true).exec() .then(res=>{ console.log(res) }).catch(err=>{ console.log(err) })
//使用 exec 函數 const result = await exec(sql.table('web_pages').where({id:147}).select()) // 使用 exec 方法 const result = await sql.table('web_pages').where({id:147}).select(true).exec()
const tranSqlArr = [ sql.table('table1').data({number:'number-5'}).update(), sql.table('table2').data({number:'number+5'}).update() ] const result = await transaction(tranSqlArr)
查詢web
sql .table('node_table') .field('id,name') .where({id:1}) .select() SELECT id,name FROM node_table WHERE id=1
插入sql
sql .table('node_table') .data({name:'zane',email:'752636052@qq.com'}) .insert() INSERT INTO node_table (name,email) VALUES (`zane`,`752636052@qq.com`)
更新數據庫
sql .table('node_table') .data({name:'zane',email:'752636052@qq.com'}) .update() UPDATE node_table SET name=`zane`,email=`752636052@qq.com`
刪除npm
sql .table('node_table') .where({name:'zane'}) .delet(); DELETE FROM node_table WHERE name=`zane`
//參數json多字段 sql .table('node_table') .where({id:1,name:'zane'}) .select() SELECT * FROM node_table WHERE id=1 AND name=`zane` //參數數組 let data=[ {id:1,name:'zhangsan',_type:'or'}, {sex:1,number:3} ] sql.table('node_table').where(data).select() SELECT * FROM node_table WHERE (id=1 OR name=`zhangsan` ) AND (sex=1 AND number=3 ) //多字段鏈接方式 let data=[ {id:1,name:'zhangsan',_type:'or',_nexttype:'or'}, {sex:1,number:3,_type:'and'} ] sql.table('node_table').where(data).select() SELECT * FROM node_table WHERE (id=1 OR name=`zhangsan`) OR (sex=1 AND number=3) //表達式查詢 let data={ id:{eq:100,egt:10,_type:'or'}, name:'zhangshan' } sql.table('node_table').where(data).select() SELECT * FROM node_table WHERE ((id=100) OR (id>=10)) AND name=`zhangshan` //混合查詢 let data=[{ id:{eq:100,egt:10,_type:'or'}, name:'zhangshan', _nexttype:'or' },{ status:1, name:{like:'%zane%'} }] sql.table('node_table').where(data).select() SELECT * FROM node_table WHERE (((id=100) OR (id>=10)) AND name=`zhangshan`) OR (status=1 AND ((name LIKE `%zane%`))) //UNION , UNION ALL 組合使用 sql .union('SELECT * FROM think_user_1',true) .union('SELECT * FROM think_user_2',true) .union(['SELECT * FROM think_user_3','SELECT name FROM think_user_4']) .union('SELECT * FROM think_user_5',true) .select() 獲得 (SELECT * FROM think_user_1) UNION ALL (SELECT * FROM think_user_2) UNION ALL (SELECT * FROM think_user_3) UNION (SELECT name FROM think_user_4) UNION (SELECT * FROM think_user_5)
更多用法請查看詳細文檔json