测试版本，尚不稳定

后续会加上 mysql按配置连接 为了测试 现在写死了！！！
直接通过传递配置项，生成实例，连接直接变成一个实例属性

Release Note

1  version:0.0.2
2
3  新增format和now实例方法
4  新增cipher和hash实例方法

1  version 0.0.2
2
3  增加 raw_select(sql,arr)实例方法
4  废弃 selectByParams 和 selectByPage实例方法
5
6  新增直接生成带有连接的实例
7  let conf1 ={
8    host:your host,
9    user:your username,
10    password:your pwd,
11    database:your chosed database
12    ......
13  }
14  let db2 .....
15
16  const db = new database(conf1)
17  const db2 = new database(conf2)
18  //此时db1 和 db2 为两个不同的连接，都具有自己的实例方法，独立进行不同数据库间的操作
19
20  新增showPool和endPool实例方法，用于显示pool实例和关闭pool实例
21  注意（3遍） 官方说endPool会等到队列结束才会平滑关闭 实测会立即关闭和destroy效果差不多
22  官方原话：
23  The end method takes an optional callback that you can use to know once all the connections have ended.   
24  The connections end gracefully, so all pending queries will still complete and the time to end the pool will vary.  
25
26  //建议像下面这样使用
27
28  const db = new database(conf)
29
30  async test_end(){
31    let some = await db.somequery()
32    //返回查询后再终结
33    db.endPool()
34    db.showPool()
35  }
36
37  test_end()
38

Install

1npm install async-mysql-query
2

Introduction

引入

1  const database = require('async-mysql-query')
2  const db = new database()
3  let obj = {
4    id:'1234',
5    hasGirlFriend:'yes',
6    name:'joker'
7  }
8  //所有db实例的方法均会返回一个promise实例
9  db.insert('user_info',obj)
10  .then(t=>console.log(t))
11  .catch(e=>console.log(e))

使用NodeJs8.0的util.promisify和async await 解决node-mysql模块的进行数据库操作时陷入callback hell

Async MySQL

insert

使用方法如下

1//插入数据
2db.raw_insert([arr])
3usage:
4    db.raw_insert(['user_info',['id','name','hasGirlFriend'],['1234','joker','yes']])
5    .then(t=>console.log(t))
6    .catch(err=>console.log(err))
7execude as:
8    let sql =
9    `insert into user_info (id,name,hasGirlFriend) values ('1234','joker','1234')`
10
11    pool.query(sql,(e,r)=>console.log(r))
12
13db.insert(tableName,opt)
14usage:
15    let opt = {
16      id:'1234',
17      name:'joker',
18      hasGirlFriend:'yes'
19    }
20    db.insert('user_info',opt)
21    .then(t=>console.log(t))
22    .catch(e=>console.log(e))
23

实例方法

方法	参数	说明
db.raw_insert	arr
db.insert	tableName,opt

select

1db.selectByParams(sql,[arr])
2
3usage:
4    let sql =
5    `select ?? from ?? where name = ? and hasGirlFriend = ? `
6    let opt = [['id','name','age','hasGirlFriend'],'user_info','joker','nope']
7    db.selectByParams(sql,opt)
8    .then((t)=>console.log(t))
9    .catch(e=>console.log(e))
10
11
12db.selectByPages(sql,[arr])
13//此方法可与上述方法合并
14
15usage:
16    let sql = `select ?? from ?? where name = ? and hasGirlFriend = ? limit ?,?`
17    //此类分页方法扫描数据表时过慢  TODO  
18    let opt = [['id','name','age','hasGirlFriend'],'user_info','joker','nope',0,5]
19    db.selectByPages(sql,opt)
20    .then(t=>console.log(t))
21    .catch(e=>console.log(e))
22
23db.countTable(tableName)
24
25usage:
26
27    db.countTable('user_info')
28    .then(t=>console.log(t))
29    .catch(e=>console.log(e))
30

实例方法

方法名	参数	说明
db.selectByParams	sql,opt	废弃
db.selectByPages	sql,opt	废弃
db.raw_select(sql,arr)	sql,arr	替代以上两方法
db.countTable	tableName

update

1  db.update(arr)
2  //arr = [tableName,obj,params]
3  //适用一个过滤条件
4  usage:
5      let opt = {
6        name:'joker',
7        hasGirlFriend:'no'
8      }
9      let params = {
10        id:'12345'
11      }
12      db.update('user_info',opt,params)
13      .then(t=>console.log(t))
14      .catch(e=>console.log(e))
15
16  db.raw_update(sql,opt)
17  //自定义更新语句 适用多个过滤条件的
18  usage:
19      let sql =
20      `update ?? set ? where name = ? and hasGirlFriend = ?`
21      let opt = {
22        age:19,
23        hasDream:'no'
24      }
25      let arr = ['user_info',opt,'joker','yes']
26      db.update(sql,arr)
27      .then(t=>console.log(t))
28      .catch(e=>console.log(e))
29

delete

1
2  db.delete(arr)
3  usage:
4      let arr = ["user_info",{name:'joker'}]
5  execude as:
6      sql = `delete from user_info where name = 'joker'`
7      pool.query(sql,……)
8
9
10  db.raw_delete(sql,arr)
11  usage:
12      let sql = `delete from ?? where name = ? and age = ? `
13      let arr = ["user_info",'joker','22']
14      db.delete(sql,arr)
15      .then(t=>console.log(t))
16      .catch(e=>console.log(e))