新建better-mysql.js
const mysql = require('mysql');const config = require('../config/sqlConfig.js')let pool = mysql.createPool({ user:config.mysql_user, password:config.mysql_password, database:config.mysql_database, host:config.mysql_host, port:config.port})let query = ( sql, values ) => { return new Promise(( resolve, reject ) => { pool.getConnection(function(err, connection) { if (err) { reject( err ) } else { connection.query(sql, values, ( err, fields) => { if ( err ) reject( err ) else resolve( fields ) connection.release(); }) } }) })}let createTable = ( sql ) => { return query( sql ,[])}let tb_users = `create table if not exists tb_users( user_id VARCHAR(32) NOT NULL COMMENT '用户ID', username VARCHAR(100) NOT NULL COMMENT '用户名', password VARCHAR(100) NOT NULL COMMENT '密码', avator VARCHAR(100) NOT NULL COMMENT '头像', create_time VARCHAR(100) NOT NULL COMMENT '注册时间', login_status VARCHAR(100) NOT NULL COMMENT '登录状态', user_rule VARCHAR(100) NOT NULL COMMENT '用户角色', PRIMARY KEY ( user_id ) );`// 建用户表createTable(tb_users)module.exports = {query}
调用方法演示,新建index.js文件
const Router = require("koa-router");const { query } = require("./better-mysql.js");const moment = require('moment');let router = new Router({ prefix:"/user"})let userModel = { insertUser(value)=>{ let _sql = "insert into tb_users set user_id=?, username=?,password=?,avator=?,create_time=?,login_status=?,user_rule=?;" return query( _sql, value) }}// 注册router.post('/registor',async (ctx)=>{ let username = "amisu10"; let password = '1' password = common.md5(password); let user_id = common.uuid() ; let create_time = moment().format('YYYY-MM-DD HH:mm:ss'); let avator = "头像"; let login_status = "0"; let user_rule = "1"; await userModel.insertUser([user_id,username,password,avator,create_time,login_status,user_rule]).then(res => { console.log('注册成功',res); ctx.body = { code:0, count:count, message:'注册成功' } }) }})