• 1、基本封裝

  import * as mysql from 'mysql';
  
  /**
   * 封裝一個數據庫連線的方法
   * @param {string} sql SQL語句
   * @param arg SQL語句插入語句的資料
   * @param callback SQL語句的回撥
   */
  export function db(sql: string, arg: any, callback?: any) {
      // 1.建立連線
      const config = mysql.createConnection({
          host: 'localhost', // 資料庫地址
          user: 'root'
   
  , // 資料庫名
          password: 'root', // 資料庫密碼
          port: 3306, // 埠號
          database: 'cms' // 使用資料庫名字
      });
      // 2.開始連線資料庫
      config.connect();
      // 3.封裝對資料庫的增刪改查操作
      config.query(sql, arg, (err:any, data:any) => {
          callback(err, data);
      });
      // 4.關閉資料庫
      config.end();
  }

• 2、基本使用

db('insert into message_board(message,create_time) values(?,?)'
 
, [message, new Date()], (err: any, data: any) => {
    if (err) {
        websocket.send(`提交資料有錯誤`);
    }
    if(data){
        // 把接收的資料傳送到客戶端
        websocket.send(message);
    }
})

• 3 、程式碼地址