mysqli/3.x.md at 3.0.7 - mysqli

bytedo

mysqli

12 KiB

Raw Permalink Blame History

实例化

实例化可以传入一个数组,或单个 object 配置。只有 1 个数据库时，默认是主库; 多于 1 个数据库服务时,自动以第 1 个为主库,其他的从库，故实例化时注意顺序。

let Mysqli = require('mysqli')

//传入json
let conn = new Mysqli({
  host: '', // IP/域名
  post: 3306, //端口， 默认 3306
  user: '', //用户名
  passwd: '', //密码
  charset: '', // 数据库编码，默认 utf8mb4 【可选】
  db: '' // 可指定数据库，也可以不指定 【可选】
})

// 传入数组
let conn = new Mysqli([
  {
    host: 'host1', // IP/域名
    ...
  },
  ...
])

实例 API

静态方法 escape(val)

可以对 sql 的各种类型的值进行安全转义。

emit([slave], [db])

slave <Boolean> [可选]是否"从库", 默认为 false,
db <String> [可选]要连接的数据库名, 默认为空

返回一个 db 实例, 这个方法是必须要的, 所有的 sql 操作,都要先实例一个 db 对象。

let db = conn.emit(false, 'test')
db
  .tableList()
  .then(list => {
    log(list)
  })
  .catch(err => {
    log(err)
  })

DB API

是指直接对 db 进行操作的接口。如果没有特别说明,以下所有的方法, 返回的都是一个 Promise 对象。

query(sql)

sql <String> sql 语句, [必传]

直接执行 sql 语句, 用于在内置的 API 不满足需求的情况下, 可以自己手写 sql 执行。

db.query('select * from `student` limit 10').then(result => {
  log(result)
})

// 前面没有指定数据库时, 也可以在这里写上
db.query('select * from `test`.`student` limit 10').then(result => {
  log(result)
})

drop(db)

db <String> [可选] 要删除 db 名, 不传则删除当前连接的数据库

删除当前或指定数据库。

db.drop()

// 也可以删除指定的数据库
db.drop('foo')

dbList()

返回当前账号权限下的所有的数据名(数组)

db.dbList().then(list => {
  log(list)
})

tableList()

返回当前连接的数据库下的所有的表名(数组)

db.tableList().then(list => {
  log(list)
})

dbCreate(name, options)

name <String> [必传], 数据库名字
options <Object>, [必传], 数据库的配置
- charset <String> 默认 utf8mb4

创建新的数据库, 成功返回true。

db.dbCreate('foo', { charset: 'utf8' }) // 默认是utf8mb4

tableCreate(name, columns ,options)

name <String> [必传], 表名字
columns <Array>, [必传], 表字段的配置
- name <String> 字段名, 区分大小写, 建议全小写+下划线
- type <String> 字段类型, 不区分大小写
- primary <Boolean> 是否主键(有且只能有 1 个主键)
- inc <Boolean> 是否自增(只允许主键设置,且为整型时才可设置)
- notnull <Boolean> 是否允许非空
- index <Boolean> 是否设为索引
- unique <Boolean> 是否为唯一索引
- default <Any> 设置默认值
- update <Boolean> 是否自动更新(只有 datetime & timestamp 可以设)
options <Object>, [必传], 表的配置
- charset <String> 默认 utf8mb4
- engine <String> 默认 InnoDB

创建新的数据表, 成功返回true。

db.tableCreate('student',
  [
    {
      name: 'id',
      type: 'int(5)',
      primary: true,
      inc: true
    },
    {
      name: 'name',
      type: 'varchar(64)',
      index: true
    },
    {
      name: 'age',
      type: 'int(3)'
    },
    {
      name: 'sex',
      type: 'tinyint(1)',
      index: true
    },
    ...
  ])

table(name)

name <String> [必传], 数据表名字

选择指定表。返回一个表操作的 API 实例

let table = db.table('student') //

TABLE API

是指直接对 table 进行操作的接口。

leftJoin(tables)

tables <Array> 左联, 可以联多个表
- table <String> 表名
- on <String> 左联的条件

db.table('student')
  .leftJoin([
    {
      table: 'classroom',
      on: 'student.classroom = classroom.id'
    },
    ...
  ])

rightJoin(tables)

参考 leftJoin()

join(tables)

参考 leftJoin()

options <Object>

查询过滤, 这个方法是增删改查中使用率最高的。也是 Mysqli 模块的核心方法之一。也是参数最复杂的方法, 一条查询里, 只能出现一次 filter, 多次调用, 会覆盖之前的条件. options 里有几个特殊的关键字

$and (逻辑"且")

$or (逻辑"或")

$like 模糊查询

$sql 以某个 sql 语句的结果作为查询条件

$in 包含

$between 在某某值和某某值之间

$lt 小于

$lte 小于等于

$gt 大于

$gte 大于等于

$eq 等于

$ne 不等于

db
  .table('student')
  .filter({ id: 1234 }) // 最基本的过滤查询, 即条件为 找"id=1234"的

  .filter({ name: { $like: '李%' } }) // 模糊查询, 找所有"李姓的学生"

  // 现有的API不满足时, 可以自己写sql条件, 更复杂自己根据需求写即可
  .filter({ name: { $sql: 'IS NULL' } })
  .filter({ score: { $sql: 'score + 1' } })

  .filter({ id: { $in: [11, 13, 29] } }) // 查询id在给定的这几个值的所有学生

  .filter({ age: { $between: [15, 17] } }) // 查询年龄在 15~17岁的所有学生

  .filter({ age: { $lt: 16 } }) // 查询年龄小于16岁的所有学生
  .filter({ age: { $lt: 16, $gt: 13 } }) // 查询年龄小于16岁且大于13岁的所有学生

  // ***** 以下是多条件的示例 *********
  // 查询所有姓李的,年龄15岁以上, 且为男生(假设 男生是1,女生是2)
  .filter({ name: { $like: '李%' }, age: { $gt: 15 }, sex: 1 })

  // **** 从上面的示例可以看出,多个字段时, 自动为"AND" 查询 ****
  // **** 所以下面该 $and 和 $or 出场了 ****

  // 查询所有 姓李的, 或 年龄在15岁以上的
  .filter({
    $or: [{ name: { $like: '李%' } }, { age: { $gt: 15 } }]
  })

  // 姓李的 或 年龄15岁以上且为男生的
  .filter({
    $or: [{ name: { $like: '李%' } }, { age: { $gt: 15 }, sex: 1 }]
  })

  // 姓李的或15岁以上的, 且必须是男生的
  .filter({
    $and: [
      {
        $or: [{ name: { $like: '李%' } }, { age: { $gt: 15 } }]
      },
      { sex: 1 }
    ]
  })

// filter基本上满足了你日常绝大部分的查询需求, 如果还有没满足的, 可以自己写sql语句.

sort(keys)

keys <Object>

对结果集排序

db
  .table('student')
  .sort({ age: -1 }) // -1为逆序, 1为正序

  // 先排年龄(逆序), 再排学号(正序)
  .sort({ age: -1, id: 1 })

skip(num)

num <Number>

跳过指定条数, 可用于分页。

db.table('student').skip(10) // 跳过前9条, 即从第10条结果开始返回

limit(num)

num <Number>

限制返回的结果总数, 做分页时, 配合 skip 方法使用。

db.table('student').limit(10) // 限制只返回10条记录

slice(start, end)

start <Number>
end <Number>

截取指定范围的结果集, 这是 skip & limit 结合体。

db
  .table('student')
  .slice(11, 20) // 限制只返回10条记录

  // 等价于
  .skip(11)
  .limit(10)

withFields(fields)

fields <Array> [可选], 不传则返回所有的字段

指定要返回的字段

db.table('student').withFields(['id', 'name', 'sex']) // 只取 学号,姓名,性别3个字段返回

getAll([ids])

ids <Array> [可选],返回指定 id 的结果集; 不传则返回所有结果集。(仅当没有调用过 filter 的情况下,本参数才有效)

返回符合条件的所有记录, 这个方法是查询必须要调用的方法之一, 上面 .filter, .sort 等方法, 只是组件条件, 并不会返回结果, 只有调用了 getAll/get 之后, 才会返回结果集。 这里有一个地方要注意的, 传入的参数ids, 即意味着, 该数据表里, 必须有一个字段为"id", 否则会出错, 没有id的表, 查询时请使用 .filter过滤。

db
  .table('student')
  .withFields(['id', 'name', 'sex'])
  .getAll()
  .then(list => {
    log(list)
  })

// 以下是查询学号为 11,13,28的学生
db
  .table('student')
  .withFields(['id', 'name', 'sex'])
  .getAll([11, 13, 28])
  .then(list => {
    log(list)
  })

// 等价于
db
  .table('student')
  .withFields(['id', 'name', 'sex'])
  .filter({ id: { $in: [11, 13, 28] } })
  .getAll()
  .then(list => {
    log(list)
  })

// 在getAll()方法里传参数, 只是一种快捷的filter,
// 没有"id"字段的表, 请使用 .filter()方法来查询

get(id)

id <Any> [可选], 传入单个 ID。

该方法是对 getAll 的补充, 它最终是调用 getAll 来实现, 目的在于返回单个结果集(不是数组)。

// 以下是查询学号为 11的学生
db
  .table('student')
  .withFields(['id', 'name', 'sex'])
  .getAll(11)
  .then(doc => {
    log(doc)
  })

// 等价于
db
  .table('student')
  .withFields(['id', 'name', 'sex'])
  .filter({ id: 11 })
  .get()
  .then(doc => {
    log(doc)
  })

count()

该方法同样是对 getAll 的补充, 它最终是调用 getAll 来实现, 返回结果集的总数。

// 返回所有姓李的学生的总数
db
  .table('student')
  .filter({name: {$like: '李%'}})
  .count()
  .then(total => {
    log(total)
  })

insert(doc)

doc <Object> 要插入的记录

用于插入单条记录。如果有自增ID的话, 将返回刚插入的记录的自增ID。

db
  .table('student')
  .insert({
    name: '张三',
    age: 18,
    sex: 1,
    ...
  })
  .then(lastId => {
    log(lastId) // 如果表结构里没有自增ID, 则这个返回值永远为0
  })

update(doc)

doc <Object> 要插入的记录

用于更新指定条件的记录, 返回成功修改的总数

// 将张三的年龄改为 17岁
db
  .table('student')
  .filter({name: '张三'})
  .update({
    age: 17
  })
  .then(successNum => {
    log(successNum) 
  })

remove()

删除记录。返回成功删除的总数。

// 将姓名为空的记录全删除了。
db
  .table('student')
  .filter({name: {$sql: 'IS NULL'}})
  .remove()
  .then(successNum => {
    log(successNum) 
  })

drop()

删除当前数据表, 属于危险操作哦。成功返回true。

// 将学生表给删除了
db
  .table('student')
  .drop()
  .then(result => {
    log(result) 
  })

renameTo(name)

重命名表。成功返回true。

db
  .table('student')
  .renameTo('student_bac')
  .then(result => {
    log(result) 
  })

indexList()

返回当前表的索引列表.

db
  .table('student')
  .indexList()
  .then(list => {
    log(list) 
    // {
    //   name,
    //   column,
    //   unique,
    //   cardinality,
    //   collation,
    // }
  })

indexDrop(name)

name <String> 索引名

删除当前表的指定索引. 成功返回true。

// 将学生表给删除了
db
  .table('student')
  .indexDrop('name_idx')
  .then(result => {
    log(result) 
  })

indexDrop(name, options)

name <String> 索引名
options <Object> 索引的配置
- field <String> 该索引绑定的字段
- unique <Bollean> 是否是唯一索引

给当前表创建索引. 成功返回true。

// 将学生表给删除了
db
  .table('student')
  .indexCreate('name_idx', {field: 'name'})
  .then(result => {
    log(result) 
  })

MySQL tool

Releases

JavaScript 100%

12 KiB Raw Permalink Blame History

实例化

实例 API

静态方法 escape(val)

emit([slave], [db])

DB API

query(sql)

drop(db)

dbList()

tableList()

dbCreate(name, options)

tableCreate(name, columns ,options)

table(name)

TABLE API

leftJoin(tables)

rightJoin(tables)

join(tables)

filter(options)

sort(keys)

skip(num)

limit(num)

slice(start, end)

withFields(fields)

getAll([ids])

get(id)

count()

insert(doc)

update(doc)

remove()

drop()

renameTo(name)

indexList()

indexDrop(name)

indexDrop(name, options)

12 KiB

Raw Permalink Blame History