init

src/api_result.js

@@ -0,0 +1,26 @@
+const request = require('request');
+
+// 请求 APi 接口
+async function query(opts) {
+    var return_data = await new Promise((resolve) => {
+        // console.log("opts", opts);
+        request(opts, (error, response, result) => {
+            // console.log("error, response, result", error, response, result);
+            // console.log("error, result", error, result);
+            if (!error && (response.statusCode == 200)) {
+                // 请求成功
+                resolve(result);
+            } else {
+                // 请求失败
+                console.log(`error is ${error}`);
+                resolve({});
+            }
+        });
+    });
+    // console.log(`return_data is ${JSON.stringify(return_data)}`);
+    return return_data;
+}
+
+module.exports = {
+    query: query,
+}

src/db.js

@@ -0,0 +1,30 @@
+//引入MySQL
+const mysql = require('mysql');
+
+async function query(sql = "select * from answer;") {
+    //通过MySQL中方法创建链接对象
+    var connection = mysql.createConnection({
+        charset: 'utf8mb4',
+        host: 'localhost',
+        user: 'root',
+        password: 'root',
+        port: 3306,
+        database: 'answerbook'
+    });
+    //开始连接
+    connection.connect();
+    //执行SQL语句 (添加、删除、更新、查询)
+    connection.query(sql, (err, result) => {
+        if (err) {
+            console.error('err', err);
+            return;
+        }
+        console.log('result', result);
+    })
+    //最后需要关闭连接
+    connection.end();
+}
+
+module.exports = {
+    query: query,
+}

src/db_pool.js

@@ -0,0 +1,75 @@
+const mysql = require('mysql');
+const closeWithGrace = require('close-with-grace');
+
+//创建数据库连接池
+let pool = mysql.createPool({
+    connectionLimit: 10, //连接数量，默认是10
+    charset: 'utf8mb4',
+    host: 'localhost',
+    user: 'root',
+    password: 'root',
+    port: 3306,
+    database: 'answerbook'
+});
+
+//从连接池中获取连接时，将触发该事件
+pool.on('acquire', function (conn) {
+    // console.log('获取连接', conn.threadId);
+});
+
+//在连接池中建立新连接时，将触发该事件
+pool.on('connection', function (conn) {
+    console.log('建立新连接', conn.threadId);
+});
+
+//等待可用连接时，将触发该事件
+pool.on('enqueue', function () {
+    console.log('等待可用连接');
+});
+
+//当连接释放回池中时，触发该事件
+pool.on('release', function (conn) {
+    // console.log('连接被释放回池中', conn.threadId);
+});
+
+
+async function query(sql = 'select * from answer') {
+    return await new Promise(function (resolve, reject) {
+        //pool.query()方法可以自动的帮我们在连接池中获取可用连接
+        pool.query(sql, function (err, data) {
+            if (err) reject(err);
+            // console.log(data);
+            resolve(data);
+        });
+
+        // //当然我们也可以手动获取可用连接
+        // pool.getConnection(function (err, conn) {
+        //     if (err) {
+        //         throw err;
+        //     }
+        //     conn.query('select * from `order`', function (err, data) {
+        //         if (err) {
+        //             throw err;
+        //         }
+        //         data.forEach(function (value) {
+        //             console.log(value.id, value.order_id, value.user_id);
+        //         });
+
+        //         //连接用完之后，需要释放，重新放回连接池中。
+        //         //注意这里并没有销毁该连接，该连接仍然可用，但需要重新获取
+        //         conn.release();
+        //     });
+        // });
+    });
+}
+
+function close() {
+    pool.end(function (err) {
+        console.log('关闭连接池', err);
+    });
+}
+
+module.exports = {
+    query: query,
+    close: close,
+}