Node.js - MySQL Select From_Node.js 菜鸟教程

在MySQL数据库上执行的最常见操作是从表中检索数据。SELECT 查询对应于 CRUD 首字母缩略词中的 Retrieve 操作。要使用 Node.js 程序执行检索，应将 SELECT 查询字符串传递给 MySQL 连接对象的 query（）方法。

MySQL中的SELECT FROM语句具有以下语法 -

 SELECT field1, field2, ... FROM table_name;

要从表中定义的所有字段中选择数据，可以使用 Asterix （*）字符。

 SELECT * FROM table_name;

还有一些附加子句可以与主 SELECT 语句一起使用，例如 LIKE、WHERE、ORDER BY 等。

SELECT 语句返回一个结果集，其中包含从表中检索的行列表。

MySQL命令行客户端类似于Node.js REPL环境。SELECT 语句检索到的结果集紧接在查询语句之后显示。

mysql> use mydb;
Database changed
mysql> SELECT name, age, salary FROM employee;
+-------+------+--------+
| name 	| age  | salary |
+-------+------+--------+
| Ravi 	| 25   | 25000  |
| Anil 	| 26   | 30000  |
| Meena | 26   | 27000  |
+-------+------+--------+

但是，使用 Node.js，当 SELECT 查询传递给 MySQL 连接对象的 query（）方法时，它会返回一个 RowDataPacket 对象数组。要处理检索到的数据，必须对其进行 JSON 化。

例

在下面的代码中，我们将 SELECT 查询字符串传递给 con.query（）方法，并在控制台上显示结果集。

var mysql = require('mysql');
var con = mysql.createConnection({
	 	host: "localhost",
	 	user: "root",
	 	password: "mypassword",
	 	database: "mydb"
});

var qry =`SELECT name,salary FROM employee;`;
con.connect(function (err) {
	 	if (err) throw err;
	 	console.log("Connected!");
	 	con.query(qry, function (err, results) {
	 	 	 if (err) throw err;
	 	 	 console.log(results);
	 	});
	 	con.end();
});

输出

[
RowDataPacket { name: 'Ravi', salary: 25000 },
RowDataPacket { name: 'Anil', salary: 30000 },
RowDataPacket { name: 'Meena', salary: 27000 }
]

我们可以使用 JSON.stringify（）方法将 RowDataPacket 对象转换为字符串，而不是原始结果集。

var qry =`SELECT name,salary FROM employee;`;
con.connect(function (err) {
	 	if (err) throw err;
	 	console.log("Connected!");
	 	con.query(qry, function (err, results) {
	 	 	 if (err) throw err;
	 	 	 console.log(JSON.stringify(results));
	 	});
	 	con.end();
});

输出

[{"name":"Ravi","salary":25000},{"name":"Anil","salary":30000},{"name":"Meena","salary":27000}]

例

在此示例中，* 通配符用于从 employee 表中的所有字段中检索数据。我们还使用 forEach 循环对 SELECT 查询返回的结果集进行逐行迭代。通过将字段名称放在方括号中来获取行中每个字段的值。例如，行的 ID 由 row['id'] 给出。

var mysql = require('mysql');
var con = mysql.createConnection({
	 	host: "localhost",
	 	user: "root",
	 	password: "mypassword",
	 	database: "mydb"
});

var qry =`SELECT * FROM employee;`;
con.connect(function (err) {
	 	if (err) throw err;
	 	console.log("Connected!");
	 	con.query(qry, function (err, results) {
	 	 	 if (err) throw err;
	 	 	 results.forEach((row) => {
	 	 	 	 	console.log(`ID: ${row['id']}, NAME: ${row['name']}, AGE: ${row['age']}, SALARY: ${row['salary']}`);
	 	 	 });
	 	});
	 	con.end();
});

输出

ID: 1, NAME: Ravi, AGE: 25, SALARY: 25000
ID: 2, NAME: Anil, AGE: 26, SALARY: 30000
ID: 3, NAME: Meena, AGE: 26, SALARY: 27000

您可以在 SELECT 语句的字段列表中包含派生列或计算列，其中其值取决于涉及结构中定义的字段的表达式。您还可以为带有 AS 关键字的字段指定别名。

 SELECT expression AS COLUMN_name FROM table_name;

在以下示例中，SELECT 语句具有 TAX 列。其值计算为工资字段的 5%。

var mysql = require('mysql');
var con = mysql.createConnection({
	 	host: "localhost",
	 	user: "root",
	 	password: "mypassword",
	 	database: "mydb"
});

var qry =`SELECT name, salary, salary*0.05 as tax FROM employee;`;
con.connect(function (err) {
	 	if (err) throw err;
	 	console.log("Connected!");
	 	con.query(qry, function (err, results) {
	 	 	 if (err) throw err;
	 	 	 console.log(JSON.stringify(results));
	 	});
	 	con.end();
});

输出

[{"name":"Ravi","salary":25000,"tax":1250},
{"name":"Anil","salary":30000,"tax":1500},
{"name":"Meena","salary":27000,"tax":1350}]

<< Node.js - MySQL Insert Into Node.js - MySQL Where 子句 >>