mysqls
It is written in JavaScript,crud for mysql.You can also use transactions very easily.
mysqls 一款專為node.js生成sql語句的插件,鏈式調用,使用靈活。支持生成sql語法,也支持生成語法之后直接調用,支持事物等特性。
API參考很流行的ThinkPHP模型API。
node mysql、npm地址:www.npmjs.com/package/mys…
github: github.com/wangweiange…
mysqls是筆者在開發過程中為了更簡單、更高效的開發效率而封裝的一個庫,年初做的,最近從新小修改和加強了一下。分享給有需要的人,感興趣的也可以看看筆者的思路。因為個人使用過ThinkPHP,認為其對mysql的封裝調用方式是非常友好和易用的,因此絕大部分api參考其中。如果你有其他的意見和建議也希望可以跟我分享。
安裝:
npm install mysqls --save-dev復制代碼
mysql防止sql注入、
mysqls參數說明
- init: sql初始化API
exec: 執行sql語句
mysql2?sql: 鏈式調用生成sql語句,支持生成后直接執行sql語句
transaction: 執行事務API
項目使用:
//import方式
import { init, exec, sql, transaction } from 'mysqls'//require方式
let { init, exec, sql, transaction } = require('mysqls')復制代碼
mysql配置初始化:
// 可在項目的啟動時初始化配置
init({host: 'localhost',user: 'root',password:'123456',database: 'test',port: 3306,
})復制代碼
init 參數說明
- 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)
nodered與mysql?
只生成sql語句
sql.table('node_table').field('id,name').where({id:1}).select()// result
SELECT id,name FROM node_table WHERE id=1復制代碼
使用exec函數執行sql語句
const sqlstr = sql.table('node_table').field('id,name').where({id:1}).select();const result = await exec(sqlstr);復制代碼
使用sql.prototype.exec鏈式調用
const result = sql.table('node_table').field('id,name').where({id:1}).select(true).exec();復制代碼
- 鏈式調用執行sql時select方法需要傳參數:true
- 同樣適合update(true),insert(true),delet(true),query(true)方法
使用Promise方式
//使用 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)})復制代碼
sql server和mysql、
使用async/await
//使用 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)復制代碼
生成sql語句簡單用法
- 備注:sql調用方法的順序內部已經做了排序,因此可以不按嚴格的sql語句順序來寫
查詢
sql.table('node_table').field('id,name').where({id:1}).select()SELECT id,name FROM node_table WHERE id=1復制代碼
sqlserver數據庫。插入
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`復制代碼
刪除
sql .table('node_table').where({name:'zane'}).delet();DELETE FROM node_table WHERE name=`zane`復制代碼
生成sql語句高級用法
//參數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)復制代碼
mysql。
更多用法請查看詳細文檔:
github.com/wangweiange…