Node.js实战:连接MySQL执行CRUD操作指南

0 下载量 72 浏览量 更新于2024-08-30 收藏 91KB PDF 举报
"本文主要介绍如何使用Node.js连接MySQL数据库并执行基本的CRUD(创建、读取、更新、删除)操作。文章首先指出虽然很多Node.js教程使用MongoDB作为示例,但作者选择MySQL,因为对它有一定了解。文中使用的数据库驱动是`mysql`,版本为2.5.4。在开始之前,需要配置数据库连接,包括主机名、用户名、密码、端口和数据库名称。然后,假设存在一个名为`my_news_test`的数据库,其中有一个`node_user`表,包含id(自增主键)、name(有唯一约束)和age(年龄)三个字段。文章接下来将展示如何创建数据库和插入五条记录。" 在Node.js中连接MySQL并进行数据操作,首先需要安装`mysql`库,可以通过npm(Node.js包管理器)来安装: ```bash npm install mysql ``` 之后,可以创建数据库连接: ```javascript var mysql = require('mysql'); var connection = mysql.createConnection({ host: '127.0.0.1', user: 'root', password: 'root123', port: '3306', database: 'my_news_test' }); ``` 这里的`createConnection`方法用于设置连接参数,如数据库服务器地址、用户名、密码等。 连接成功后,可以进行数据操作。例如,插入数据到`node_user`表: ```javascript connection.connect(function(err) { if (err) throw err; var sql = "INSERT INTO node_user (name, age) VALUES ('John Doe', 30)"; connection.query(sql, function (err, result) { if (err) throw err; console.log("Record inserted successfully"); connection.end(); // 关闭连接 }); }); ``` 这里使用`query`方法执行SQL语句。对于读取数据,可以使用类似的方式: ```javascript connection.connect(function(err) { if (err) throw err; var sql = "SELECT * FROM node_user"; connection.query(sql, function (err, results) { if (err) throw err; console.table(results); connection.end(); }); }); ``` 更新数据: ```javascript connection.connect(function(err) { if (err) throw err; var sql = "UPDATE node_user SET age = 31 WHERE name = 'John Doe'"; connection.query(sql, function (err, result) { if (err) throw err; console.log("Record updated successfully"); connection.end(); }); }); ``` 以及删除数据: ```javascript connection.connect(function(err) { if (err) throw err; var sql = "DELETE FROM node_user WHERE name = 'John Doe'"; connection.query(sql, function (err, result) { if (err) throw err; console.log("Record deleted successfully"); connection.end(); }); }); ``` 以上就是使用Node.js连接MySQL并进行增、删、改、查的基本操作。在实际应用中,通常会封装成更复杂的数据库操作模块,并处理异步回调的问题,比如使用Promise或async/await来提高代码可读性和可维护性。此外,对于大量数据操作,应考虑事务处理以确保数据一致性。