nodejs环境快速操作mysql数据库

2021-10-25 11:37:48 浏览数 (1)

github地址https://github.com/dmhsq/dmhsq-mysql-db 可用于腾讯云SCF以及云开发环境 错误处理尚未完善 错误参考mysql错误 引入依赖包 npm install dmhsq-mysql-db 效果如下 简化了mysql的使用

未经本人允许，禁止转载

nodejs环境快速操作mysql数据库

  • 安装
  • 使用示例
  • 引入资源
  • 连接数据库
  • 引用表
  • 条件匹配
  • 模糊匹配
  • 查询数据返回格式
  • 查询全部/获取数据
  • 统计个数
  • 条件查询
  • 模糊查询
  • 插入数据
  • 更新数据
  • 删除数据
  • 返回指定字段(不添加会返回全部)
  • 排序
  • 自定义查询语句

安装

普通版本 npm install dmhsq-mysql-db

数据连接池版本 npm install dmhsq-mysql-pool

使用示例

快速操作mysql 错误处理尚未完善 部分错误参考mysql错误

返回的均为Promise对象

所有操作结束末尾必须携带get()

比如 collection.sort({}).get() collection.del({}).get() collection.add({}).get()

所有操作除了get()必须末尾调用 都可以不分先后调用

比如 collection.sort({}).where().get()可以写出 collection.where().sort({}).get()

引入资源

代码语言：javascript复制
const database = require("dmhsq-mysql-db")

连接数据库

代码语言：javascript复制
let db = new database({
	host: 'xxx',
	port: 'xxx',
	user: 'xxxx',
	password: 'xxxx',
	database: "xxxx"
})

引用表

代码语言：javascript复制
let collection = db.table("user")

条件匹配

collection.where(params)

params 对象类型 格式为{username:“zc”,old:18} 其中username,old是你要查询的字段值

代码语言：javascript复制
//如果需要获取数据 就要调用collection.where({username:"zcc"}).get()
collection.where({username:"zcc"})

模糊匹配

collection.like(array)

array 数组类型 格式为[[“数据库键名1”,“值”,like],[“数据库键名2”,“值”,like]]

like 值可取 “top”:以字段开头的 “end”:是以字段结尾的 “in”:包含字段 输入其他非法值均以in处理

代码语言：javascript复制
//如果需要获取数据 就要调用
//collection.like([
//	["username", "z", "top"],
//	["old", "8", "end"],
//	["address", "村", "in"]
//]).get()
collection.like([
	["username", "z", "top"],
	["old", "8", "end"],
	["address", "村", "in"]
])

查询数据返回格式

模糊查询 条件查询 只要是查询 都是这个格式

data为查询到的数据 为数组类型

代码语言：javascript复制
{
  code: 0,
  msg: 'SUCCESS',
  data: [ //这里的返回数据 是模拟数据
    {
      username: 'dmhsq1',
      password: '123zc',
      phone: 11,
      email: null,
      _id: 2,
      token: null,
      token_expired: null,
      last_login_time: null
    },
    {
      username: 'zcc1',
      password: '123',
      phone: 3,
      email: null,
      _id: 1,
      token: null,
      token_expired: null,
      last_login_time: null
    }
  ]
}

查询全部/获取数据

collection.get()

代码语言：javascript复制
collection.get().then(res => {
	console.log(res)
})

统计个数

collection.count().get()

可搭配下面的where(条件查询) like(模糊查询)

代码语言：javascript复制
collection.count().get().then(res => {
	console.log(res)
})

返回格式

代码语言：javascript复制
{
	code: 0,
	msg: 'SUCCESS',
	data: {
		count: 2
	},
	count: '查询到2个数据'
}

条件查询

条件匹配 获取数据

collection.where(params).get()

params:对象类型 格式为 {数据库键1:“值”,数据库键2:“值”}

代码语言：javascript复制
collection.where({
	username: "dmhsq"
}).get().then(res => {
	console.log(res)
})

模糊查询

模糊匹配 获取数据

collection.like(array).get()

array 数组类型 格式为[[“数据库键名1”,“值”,like],[“数据库键名2”,“值”,like]]

like 值可取 “top”:以字段开头的 “end”:是以字段结尾的 “in”:包含字段 输入其他非法值均以in处理

代码语言：javascript复制
collection.like([
	["username", "z", "top"],
	["old", "8", "end"],
	["address", "村", "in"]
]).get()

返回格式

代码语言：javascript复制
{
  code: 0,
  msg: 'SUCCESS',
  data: [ //这里的返回数据 是模拟数据
    {
      username: 'dmhsq1',
      password: '123zc',
      phone: 11,
      email: null,
      _id: 2,
      token: null,
      token_expired: null,
      last_login_time: null
    },
    {
      username: 'zcc1',
      password: '123',
      phone: 3,
      email: null,
      _id: 1,
      token: null,
      token_expired: null,
      last_login_time: null
    }
  ]
}

插入数据

collection.add(params,isIgnore)

params:对象类型 格式为 {数据库键1:“值”,数据库键2:“值”}

isIgnore 可选 默认false 当为true时 使用 INSERT IGNORE INTO

代码语言：javascript复制
collection.add({
	username: "dmhsq",
	password: "dmhsq",
	_id: 123176312
}).get().then(res => {
	console.log(res)
})

返回格式

代码语言：javascript复制
{
	code: 0,
	msg: 'SUCCESS',
	data: {
		add: 1 //数据增加个数
	},
	add: '增加1个数据'
}

更新数据

collection.updata(params)

params:对象类型 格式为 {数据库键1:“值”,数据库键2:“值”}

可使用 where like

代码语言：javascript复制
collection.updata({
	password: "zccc",
	old:18
}).where({
	username: "dmhsq"
}).get().then(res=>{
	console.log(res)
})

删除数据

collection.del() 删除操作

可使用 where like

代码语言：javascript复制
collection.del().where({
	username: "dmhsq"
}).get().then(res => {
	console.log(res)
})

返回格式

代码语言：javascript复制
{
	code: 0,
	msg: 'SUCCESS',
	data: {
		del: 1
	},
	del: '删除1个数据'
}

返回指定字段(不添加会返回全部)

collection.field(array)

array:数组类型 格式为[“数据库键名1”,“数据库键名2”]

代码语言：javascript复制
//获取全部
collection.field(["username"]).get()

//模糊匹配
collection.field(["username"]).like({username:"z"},"top").get().then(res=>{
	console.log(res)
})

//条件匹配
collection.field(["username"]).where({username:"zcc"}).get().then(res=>{
	console.log(res)
})

返回格式

代码语言：javascript复制
{
	code: 0,
	msg: 'SUCCESS',
	data: [{
		username: 'zcc1',
		_id: 1
	}, {
		username: 'dmhsq1',
		_id: 2
	}]
}

排序

collection.sort(params)

params:对象类型 格式为 {数据库键名1:“DESC”,数据库键名2:“ASC”}

DESC为降序 ASC降序

单个字段 collection.sort({_id:“DESC”})

多个字段 collection.sort({_id:“DESC”,phone:“DESC”})

代码语言：javascript复制
collection.sort({_id:"DESC",phone:"DESC"}).like({username:"1"},"in").get().then(res=>{
	console.log(res)
})
//或者
collection.like({username:"1"},"in").sort({_id:"DESC",phone:"DESC"}).get().then(res=>{
	console.log(res)
})

排序后返回的数据格式和查询数据结果格式一样

自定义查询语句

如果以上方法无法满足您的需求 您可以自定义查询语句

collection.sqlQuery(sql,type)

sql为自定义查询语句

type可不填 不填自动识别操作类型

type不影响查询 只是格式化返回的数据格式

type可选值为 updata(更新) del(删除) count(计数) add(插入)

无需后缀添加get()

代码语言：javascript复制
//如果是查询数据库数据
collection.sqlQuery("SELECT * FROM user").then(res=>{
	console.log(res)
})

//如果是删除数据
collection.sqlQuery("DELETE FROM user WHERE username = 'zcc2'").then(res=>{
	console.log(res)
})
数据库 sql 云数据库SQLServer npm http

0 人点赞