在Node.js中,我们可以使用官方提供的MySQL模块来进行数据库连接和操作。
在终端中执行以下命令来安装MySQL模块:
npm install mysql
在代码中引入mysql模块,然后使用以下代码来连接数据库:
const mysql = require('mysql');
const connection = mysql.createConnection({
host : 'localhost',
user : 'root',
password : '',
database : 'test'
});
connection.connect(function(err) {
if (err) throw err;
console.log('Connected!');
});
其中,host
是数据库的地址,user
是连接数据库的用户名,password
是连接数据库的密码,database
是要连接的数据库名。
使用以下代码来查询数据:
connection.query('SELECT * FROM users', function (error, results, fields) {
if (error) throw error;
console.log(results);
});
其中,SELECT * FROM users
是查询语句,results
是查询结果,fields
是查询到的字段。
使用以下代码来插入数据:
const user = { name: 'John', email: 'john@example.com' };
connection.query('INSERT INTO users SET ?', user, function (error, results, fields) {
if (error) throw error;
console.log(results);
});
其中,INSERT INTO users SET ?
是插入语句,user
是要插入的数据。
使用以下代码来更新数据:
connection.query(
'UPDATE users SET email = ? WHERE id = ?',
['newemail@example.com', 1],
function (error, results, fields) {
if (error) throw error;
console.log(results);
}
);
其中,UPDATE users SET email = ? WHERE id = ?
是更新语句,['newemail@example.com', 1]
是要更新的数据。
使用以下代码来删除数据:
connection.query(
'DELETE FROM users WHERE id = ?',
[1],
function (error, results, fields) {
if (error) throw error;
console.log(results);
}
);
其中,DELETE FROM users WHERE id = ?
是删除语句,[1]
是要删除的数据。
使用以下代码来关闭数据库连接:
connection.end(function(err) {
if (err) throw err;
console.log('Connection closed.');
});