NodeJs操作MYSQL方法详细介绍

NodeJs操作MYSQL方法详细介绍

在 Node.js 中，可以通过第三方模块 mysql 来连接 MySQL 数据库。通过该模块，我们可以在 Node.js 中对 MySQL 数据库进行管理、操作。

安装

安装 mysql 模块：

npm install mysql

连接

连接 MySQL 数据库：

const mysql = require('mysql');

const connection = mysql.createConnection({
  host: 'localhost',    // 数据库的地址
  user: 'root',         // 数据库用户的用户名
  password: 'password', // 数据库用户的密码
  database: 'database'  // 需要操作的数据库名称
});

connection.connect();  // 建立连接

// 如果连接成功，则控制台输出连接成功
connection.on('connect', function() {
  console.log('连接成功！');
});

// 如果连接失败，则抛出异常
connection.on('error', function(err) {
  console.log('连接失败，' + err.stack);
});

查询

执行查询操作：

const mysql = require('mysql');

const connection = mysql.createConnection({
  host: 'localhost',    // 数据库的地址
  user: 'root',         // 数据库用户的用户名
  password: 'password', // 数据库用户的密码
  database: 'database'  // 需要操作的数据库名称
});

connection.connect();  // 建立连接

// 查询语句
const querySql = "SELECT * FROM users";

connection.query(querySql, function(err, results, fields) { 
  if (err) { 
    console.log('查询失败，' + err.stack); 
    return; 
  } 

  console.log('查询成功：'); 
  console.log('查询结果：', results); 
});

connection.end();  // 关闭连接

查询结果将会以数组形式返回，每一行数据都是一个对象，可以通过属性访问。例如，获取第一条记录的 Email 和密码：

console.log('Email:', results[0].Email); 
console.log('密码：', results[0].Password);

插入

执行插入操作：

const mysql = require('mysql');

const connection = mysql.createConnection({
  host: 'localhost',    // 数据库的地址
  user: 'root',         // 数据库用户的用户名
  password: 'password', // 数据库用户的密码
  database: 'database'  // 需要操作的数据库名称
});

connection.connect();  // 建立连接

// 需要插入的数据
const insertData = { 
  Email: '[e-mail]',
  Password: '123456'
};

// 插入数据
const insertSql = "INSERT INTO users SET ?";

connection.query(insertSql, insertData, function (err, results, fields) { 
  if (err) { 
    console.log('插入失败，' + err.stack); 
    return; 
  } 

  console.log('插入成功：');
  console.log('插入数据的 ID 为：', results.insertId); 
});

connection.end();  // 关闭连接

示例说明：

示例一：

需要使用 Node.js 连接 MySQL 数据库并查询其中的一些记录。

连接数据库的过程中，需要指定数据库的地址、用户名、密码以及需要操作的数据库名称。查询操作是通过执行 SQL 语句来实现的。

例如，下面示例查询了 test 数据库中的 users 表，并输出结果：

const mysql = require('mysql');

const connection = mysql.createConnection({
  host: 'localhost',    // 数据库的地址
  user: 'root',         // 数据库用户的用户名
  password: 'password', // 数据库用户的密码
  database: 'test'      // 需要操作的数据库名称
});

connection.connect();  // 建立连接

// 查询语句
const querySql = "SELECT * FROM users";

connection.query(querySql, function(err, results, fields) { 
  if (err) { 
    console.log('查询失败，' + err.stack); 
    return; 
  } 

  console.log('查询成功：'); 
  console.log('查询结果：', results); 
});

connection.end();  // 关闭连接

示例二：

需要使用 Node.js 连接 MySQL 数据库并插入一些记录。

连接数据库的过程中，需要指定数据库的地址、用户名、密码以及需要操作的数据库名称。插入操作是通过执行 SQL 语句来实现的。

例如，下面示例向 test 数据库中的 users 表中插入一条记录：

const mysql = require('mysql');

const connection = mysql.createConnection({
  host: 'localhost',    // 数据库的地址
  user: 'root',         // 数据库用户的用户名
  password: 'password', // 数据库用户的密码
  database: 'test'      // 需要操作的数据库名称
});

connection.connect();  // 建立连接

// 需要插入的数据
const insertData = { 
  Email: '[e-mail]',
  Password: '123456'
};

// 插入数据
const insertSql = "INSERT INTO users SET ?";

connection.query(insertSql, insertData, function (err, results, fields) { 
  if (err) { 
    console.log('插入失败，' + err.stack); 
    return; 
  } 

  console.log('插入成功：');
  console.log('插入数据的 ID 为：', results.insertId); 
});

connection.end();  // 关闭连接

以上两个示例分别展示了 Node.js 连接 MySQL 数据库中的查询和插入操作。可以根据实际需求进行修改和扩展。