1

src/workserver/config.js

@@ -0,0 +1,18 @@
+const configs = {
+    mysql: {
+      host: '118.195.213.51',
+      port: '3306',
+      user: 'root',
+      password: '123456',  // 自己设置的密码
+      database: 'expressFrame' // 数据库的名字
+    },
+    // 打印错误
+    log: {
+      error (message) {
+        console.log('[knex error]', message)
+      }
+    }
+  }
+  
+  module.exports = configs
+  

src/workserver/controllers/user.js

@@ -0,0 +1,42 @@
+// 引用用户模版数据
+const User = require('../model/user');
+
+const userController = {
+  // showUser 获取用户数据并返回到页面
+  showUser: async function(req,res,next){
+    try{
+      let userData = await User.all()
+      console.log(userData);
+      res.json({
+        code: 200,
+        message: "操作成功",
+        data: userData
+      })
+    }catch(e){
+      res.json({ code: 0, message: "操作失败", data: e })
+    }
+  },
+  // 新增用户
+  addUser: async function(req, res, next) {
+    try {
+      const userData = req.body; // 从请求中获取用户数据
+      console.log("ddddd");
+      const result = await User.insert(userData);
+      res.json({
+        code: 200,
+        message: "用户添加成功",
+        data: result
+      });
+    } catch (e) {
+      res.json({
+        code: 0,
+        message: "用户添加失败",
+        data: e
+      });
+    }
+  },
+
+}
+
+module.exports = userController;
+

src/workserver/model/base.js

@@ -0,0 +1,31 @@
+const knex = require('../model/kenx');
+
+class Base{
+  constructor(props){
+    this.table = props;
+  }
+
+  // 查找
+  all (){
+    return knex(this.table).select();
+  }
+
+  // 新增
+  insert (params){
+    return knex(this.table).insert(params);
+  }
+
+  // 更改
+  update (id, params){
+    return knex(this.table).where('id', '=', id).update(params);
+  }
+
+  // 删除
+  delete (id){
+    return knex(this.table).where('id', '=', id).del();
+  }
+
+}
+
+module.exports = Base;
+

src/workserver/model/kenx.js

@@ -0,0 +1,20 @@
+// 引用配置文件
+const configs = require('../config');
+// 把配置文件中的信息，设置在初始化配置中
+module.exports = require('knex')({
+  client: 'mysql',
+  connection: {
+    host: configs.mysql.host,
+    port: configs.mysql.port,
+    user: configs.mysql.user,
+    password: configs.mysql.password,
+    database: configs.mysql.database
+  },
+  // 打印错误
+  log: {
+    error (message) {
+      console.log('[knex error]', message)
+    }
+  }
+})
+

src/workserver/model/user.js

@@ -0,0 +1,10 @@
+const Base = require('./base');
+
+class User extends Base {
+  // 定义参数默认值为 user 表
+  constructor(props = 'user'){
+    super(props);
+  }
+}
+
+module.exports = new User();