Node.js - MySQL Select From

在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();
});

输出

我们可以使用 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();
});

输出

例

在此示例中，* 通配符用于从 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();
});

输出

您可以在 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();
});

输出