我刚刚开始接触Node.js。我来自PHP背景,所以我相当习惯使用MySQL来满足我的所有数据库需求。
我如何使用MySQL与Node.js?
我刚刚开始接触Node.js。我来自PHP背景,所以我相当习惯使用MySQL来满足我的所有数据库需求。
我如何使用MySQL与Node.js?
当前回答
因为这是一个旧线程,只是添加了一个更新:
安装MySQL node.js驱动程序:
如果你只是运行npm install mysql,你需要在运行服务器的同一个目录下。我建议按照下面的例子来做:
全球安装:
npm install -g mysql
本地安装:
1-把它添加到你的包里。Json的依赖项:
"dependencies": {
"mysql": "~2.3.2",
...
2-运行NPM install
注意,为了建立连接,你还需要运行mysql服务器(它是独立于节点的)
安装MySQL服务器:
有很多教程解释了这一点,它有点依赖于操作系统。只要去谷歌搜索如何安装mysql服务器[Ubuntu|MacOSX|Windows]。但一句话:你必须去http://www.mysql.com/downloads/并安装它。
其他回答
以下是生产代码,可能会对您有所帮助。
Package.json
{
"name": "node-mysql",
"version": "0.0.1",
"dependencies": {
"express": "^4.10.6",
"mysql": "^2.5.4"
}
}
这是服务器文件。
var express = require("express");
var mysql = require('mysql');
var app = express();
var pool = mysql.createPool({
connectionLimit : 100, //important
host : 'localhost',
user : 'root',
password : '',
database : 'address_book',
debug : false
});
function handle_database(req,res) {
pool.getConnection(function(err,connection){
if (err) {
connection.release();
res.json({"code" : 100, "status" : "Error in connection database"});
return;
}
console.log('connected as id ' + connection.threadId);
connection.query("select * from user",function(err,rows){
connection.release();
if(!err) {
res.json(rows);
}
});
connection.on('error', function(err) {
res.json({"code" : 100, "status" : "Error in connection database"});
return;
});
});
}
app.get("/",function(req,res){-
handle_database(req,res);
});
app.listen(3000);
参考资料:https://codeforgeek.com/2015/01/nodejs-mysql-tutorial/
在我看来,你应该尝试MySQL Connector/Node.js,这是MySQL的官方Node.js驱动程序。 详见ref-1和ref-2。 我尝试了mysqljs/mysql,这里是可用的,但我没有找到这个库的类,方法,属性的详细文档。
所以我切换到标准的MySQL Connector/Node.js和X DevAPI,因为它是一个异步的基于承诺的客户端库,并提供了良好的文档。 看一下下面的代码片段:
const mysqlx = require('@mysql/xdevapi');
const rows = [];
mysqlx.getSession('mysqlx://localhost:33060')
.then(session => {
const table = session.getSchema('testSchema').getTable('testTable');
// The criteria is defined through the expression.
return table.update().where('name = "bar"').set('age', 50)
.execute()
.then(() => {
return table.select().orderBy('name ASC')
.execute(row => rows.push(row));
});
})
.then(() => {
console.log(rows);
});
您可以跳过ORM,构建器等,并使用sqler和sqler-mdb简化您的DB/SQL管理。
-- create this file at: db/mdb/setup/create.database.sql
CREATE DATABASE IF NOT EXISTS sqlermysql
const conf = {
"univ": {
"db": {
"mdb": {
"host": "localhost",
"username":"admin",
"password": "mysqlpassword"
}
}
},
"db": {
"dialects": {
"mdb": "sqler-mdb"
},
"connections": [
{
"id": "mdb",
"name": "mdb",
"dir": "db/mdb",
"service": "MySQL",
"dialect": "mdb",
"pool": {},
"driverOptions": {
"connection": {
"multipleStatements": true
}
}
}
]
}
};
// create/initialize manager
const manager = new Manager(conf);
await manager.init();
// .sql file path is path to db function
const result = await manager.db.mdb.setup.create.database();
console.log('Result:', result);
// after we're done using the manager we should close it
process.on('SIGINT', async function sigintDB() {
await manager.close();
console.log('Manager has been closed');
});
查看node.js模块列表
node-mysql -一个实现MySQL协议的node.js模块 node-mysql2 -另一个纯JS异步驱动程序。流水线,准备好的语句。 node-mysql-libmysqlclient -基于libmysqlclient的MySQL异步绑定
Node-mysql看起来很简单:
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'example.org',
user : 'bob',
password : 'secret',
});
connection.connect(function(err) {
// connected! (unless `err` is set)
});
查询:
var post = {id: 1, title: 'Hello MySQL'};
var query = connection.query('INSERT INTO posts SET ?', post, function(err, result) {
// Neat!
});
console.log(query.sql); // INSERT INTO posts SET `id` = 1, `title` = 'Hello MySQL'
node-mysql可能是用于MySQL数据库的最好的模块之一,它是积极维护和良好的文档。