当前位置: 首页 > 文档资料 > ORM2 中文文档 >

1. 连接到数据库

优质
小牛编辑
133浏览
2023-12-01

在连接之前,你需要一个受支持的驱动。下面是一些测试过的驱动及其版本,把你所需要的加入到package.json中。

驱动npm 包版本
mysqlmysql2.0.0-alpha9
postgres
redshift
pg2.6.2 [1]
sqlitesqlite32.1.7
mongodbmongodb1.3.19

[1] 如果你要连接到Heroku,请使用版本2.5.0

这些是测试过的版本,使用其它的版本(新的或者旧的)带来的风险由你自己承担。

例如,使用MySQL要这样做:

  1. $ npm install --save mysql@2.0.0-alpha8

你可以传递一个URL字符串来连接数据库,其中scheme为受支持的驱动,或者你可以传递一个带有连接参数的Object

  1. var orm = require('orm');
  2. orm.connect('mysql://root:password@localhost/test', function(err, db) {
  3. if (err) return console.error('Connection error: ' + err);
  4. // connected
  5. // ...
  6. });

回调函数只在连接建立成功(或失败)时调用。如果你愿意的话,可以不传入回调函数,而是监听connect事件。

  1. var orm = require('orm');
  2. var db = orm.connect('mysql://root:password@localhost/test');
  3. db.on('connect', function(err) {
  4. if (err) return console.error('Connection error: ' + err);
  5. // connected
  6. // ...
  7. });

连接URL遵循下面的语法:driver://username:password@hostname/database?option1=value1&option2=value2..

可选参数为:

  • debug(默认为false):将连接输出到控制台;
  • pool(默认为false):使用驱动内建的组件管理连接池(仅对mysqlpostgres有效);
  • strdates(默认为false):以字符串形式保存日期(仅对sqlite有效);
  • timezone(默认为local):在数据库中使用指定的时区储存日期(仅对mysqlpostgres有效);

debugpool也可以使用settings对象来设置。

连接到多个数据库

ORM模型受数据库连接约束,所以如果你需要“多租户”,即连接到不同的服务器或数据库,你可以使用像下面这样的方法:

  1. // db.js
  2. var connections = {};
  3. function setup(db) {
  4. var User = db.define('user', ...);
  5. var Shirt = db.define('shirt', ...);
  6. Shirt.hasOne('user', User, ...);
  7. }
  8. module.exports = function(host, database, cb) {
  9. if (connections[host] && connections[host][database]) {
  10. return connections[host][database];
  11. }
  12. var opts = {
  13. host: host,
  14. database: database,
  15. protocol: 'mysql',
  16. port: '3306',
  17. query: {pool: true}
  18. };
  19. orm.connect(opts, function(err, db) {
  20. if (err) return cb(err);
  21. connections[host] = connections[host] || {};
  22. connections[host][database] = db;
  23. setup(db);
  24. cb(null, db);
  25. });
  26. };
  27. // somewhere else, eg, middleware
  28. var database = require('./db');
  29. database('dbserver1', 'main', function(err, db) {
  30. if (err) throw err;
  31. db.models.user.find({foo: 'bar'}, function(err, rows) {
  32. // ...
  33. });
  34. });

连接是被缓存的,所以模型在每个服务器+数据库上面只会定义一次。由于我们使用了连接池,我们并不需要担心用完所有的连接,而且我们可以一次性执行多个查询。

问题排除

如果你在连接MySQL数据库的时候遇到了如下错误:

  1. Error: connect ECONNREFUSED
  2. at errnoException (net.js:670:11)
  3. at Object.afterConnect [as oncomplete] (net.js:661:19)

你可以尝试添加socketPath参数:

  1. var db = orm.connect({
  2. host: 'localhost',
  3. database: 'database',
  4. user: 'user',
  5. password: 'pass',
  6. protocol: 'mysql',
  7. socketPath: '/var/run/mysqld/mysqld.sock',
  8. port: '3306',
  9. query: {pool: true, debug: true}
  10. });