nodejs 连接mysql数据库进行增删改查操作，是进行一次操作就要 connnect 一次数据库 然后关闭吗？

Posted 2023-03-10

比如我想执行多条简单的sql语句 是需要每条语句都需要连接一次数据库 然后关闭吗 还是有更好的解决方案呢？
比如我有三个路由 /login /reg /delete
这三个路由每个请求进来一次都需要连接一次数据库查询然后在关闭吗？

原则上就是这样的。因为网络数据库是要注重并发性的，如果你长时间占用一个连接，那么你这个连接所涉及的记录就会被长时间锁定，其他所有用户都会无法访问，如果有多个用户同时操作数据库，那网站基本上就瘫痪了。所以原则上都要求数据库的查询要做到随用随关闭。 参考技术A 设置为可以执行多条语句：
var connection = mysql.createConnection(
host : constant.DB_HOST_NAME,
user : constant.DB_USER,
password : constant.DB_PWD,
database : constant.DB_NAME,
multipleStatements: true // 支持执行多条 sql 语句
);

Nodejs操作MySQL - 增删改查

先安装npm模块项目

npm init

安装mysql

npm install mysql --save

Nodejs 连接msyql

// 导入mysql
const mysql = require(‘mysql‘);

// 连接mysql
const connection = mysql.createConnection({
    host: ‘127.0.0.1‘,
    user: ‘root‘,
    password: ‘password‘,
    port: ‘3306‘,
    database: ‘test‘
});

connection.connect();

// 结束连接
connection.end();

增

// 引入mysql
const mysql = require(‘mysql‘);

// 连接myql
const connection = mysql.createConnection({
    host: ‘127.0.0.1‘,
    user: ‘root‘,
    password: ‘password‘,
    port: ‘3306‘,
    database: ‘test‘,
});

connection.connect();

// 插入语句
let addSql = "insert into article (title, author, date) values (?, ?, now())";
let addSqlParams = [‘Today is noce‘, ‘Bob‘];

// 执行插入语句
connection.query(addSql, addSqlParams, (err, result) => {
    if (err) {
        throw err;
    }

    // 插入成功输出
    console.log(‘插入成功‘);
    console.log(result);
});

// 断开连接msyql
connection.end();

删

// 引入mysql
const mysql = require(‘mysql‘);

// 连接mysql
const connection = mysql.createConnection({
    host: ‘127.0.0.1‘,
    user: ‘root‘,
    password: ‘password‘,
    port: ‘3306‘,
    database: ‘test‘
});

connection.connect();

// 删除语句
let sql = "delete from article where id = 10";

// 执行删除语句
connection.query(sql, (err, data) => {
    if (err) {
        throw err;
    }

    // 执行成功
    console.log(‘delete success!‘);
    console.log(data);
});

// 断开连接msyql
connection.end();

改

// 导入mysql
const mysql = require(‘mysql‘);

// 连接mysql
const connection = mysql.createConnection({
    host: ‘127.0.0.1‘,
    user: ‘root‘,
    password: ‘password‘,
    port: ‘3306‘,
    database: ‘test‘
});

connection.connect();

// 更新语句
let modSql = "update article set title = ?, author = ? where id like ?";
let modSqlParams = [‘今晚学习nodejs‘, ‘一波万波‘, 12];

// 执行更新语句
connection.query(modSql, modSqlParams, (err, data) => {
    if (err) {
        throw err;
    }
    console.log(‘upload success!‘);
    console.log(data)
});

connection.end();

查

// 导入mysql
const mysql = require(‘mysql‘);

// 连接mysql
const connection = mysql.createConnection({
    host: ‘127.0.0.1‘,
    user: ‘root‘,
    password: ‘password‘,
    port: ‘3306‘,
    database: ‘test‘,
});

connection.connect();

// 查询语句
let sql = ‘SELECT * FROM article‘;

// 执行查询语句
connection.query(sql, (err, data) => {
    if (err) {
        console.log(‘[SELECT ERROR] - ‘, err.message);
        return;
    }

    // 查询成功
    console.log(data);
});
connection.end();