mysqls

It is written in JavaScript,crud for mysql.You can also use transactions very easily.

mysqls 一款專為node.js生成sql語句的外掛，鏈式呼叫，使用靈活。支援生成sql語法，也支援生成語法之後直接呼叫，支援事物等特性。

API參考很流行的ThinkPHP模型API。

npm地址：www.npmjs.com/package/mys…

github: github.com/wangweiange…

mysqls是筆者在開發過程中為了更簡單、更高效的開發效率而封裝的一個庫，年初做的，最近從新小修改和加強了一下。分享給有需要的人，感興趣的也可以看看筆者的思路。因為個人使用過ThinkPHP,認為其對mysql的封裝呼叫方式是非常友好和易用的，因此絕大部分api參考其中。如果你有其他的意見和建議也希望可以跟我分享。

安裝：

npm install mysqls --save-dev複製程式碼

mysqls引數說明

• 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')複製程式碼

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)

只生成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)
    })複製程式碼

使用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複製程式碼

插入

sql
    .table('node_table')
    .data({name:'zane',email:'[email protected]'})
    .insert()

INSERT INTO node_table (name,email) VALUES (`zane`,`[email protected]`)複製程式碼

更新

sql
    .table('node_table')
    .data({name:'zane',email:'[email protected]'})
    .update()

UPDATE node_table SET name=`zane`,email=`[email protected]`複製程式碼

刪除

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)複製程式碼

更多用法請檢視詳細文件：

github.com/wangweiange…