orm2 中文文檔 1. 鏈接到數據庫

譯者：飛龍

來源：Connecting to Database

在鏈接以前，你須要一個受支持的驅動。下面是一些測試過的驅動及其版本，把你所須要的加入到package.json中。

驅動	npm 包	版本
mysql	mysql	2.0.0-alpha9
postgres redshift	pg	2.6.2 \[1\]
sqlite	sqlite3	2.1.7
mongodb	mongodb	1.3.19

\[1\] 若是你要鏈接到Heroku，請使用版本2.5.0。

這些是測試過的版本，使用其它的版本（新的或者舊的）帶來的風險由你本身承擔。

例如，使用MySQL要這樣作：

$ npm install --save mysql@2.0.0-alpha8

你能夠傳遞一個URL字符串來鏈接數據庫，其中scheme爲受支持的驅動，或者你能夠傳遞一個帶有鏈接參數的Object。

var orm = require('orm');

orm.connect('mysql://root:password@localhost/test', function(err, db) {
  if (err) return console.error('Connection error: ' + err);

  // connected
  // ...
});

回調函數只在鏈接創建成功（或失敗）時調用。若是你願意的話，能夠不傳入回調函數，而是監聽connect事件。

var orm = require('orm');

var db = orm.connect('mysql://root:password@localhost/test');

db.on('connect', function(err) {
  if (err) return console.error('Connection error: ' + err);

  // connected
  // ...
});

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

可選參數爲：

• debug（默認爲false）：將鏈接輸出到控制檯；

• pool（默認爲false）：使用驅動內建的組件管理鏈接池（僅對mysql和postgres有效）；

• strdates（默認爲false）：以字符串形式保存日期（僅對sqlite有效）；

• timezone（默認爲local）：在數據庫中使用指定的時區儲存日期（僅對mysql和postgres有效）；

debug和pool也可使用settings對象來設置。

鏈接到多個數據庫

ORM模型受數據庫鏈接約束，因此若是你須要「多租戶」，即鏈接到不一樣的服務器或數據庫，你可使用像下面這樣的方法：

// db.js
var connections = {};

function setup(db) {
  var User = db.define('user', ...);
  var Shirt = db.define('shirt', ...);
  Shirt.hasOne('user', User, ...);
}

module.exports = function(host, database, cb) {
  if (connections[host] && connections[host][database]) {
    return connections[host][database];
  }

  var opts = {
    host:     host,
    database: database,
    protocol: 'mysql',
    port:     '3306',
    query:    {pool: true}
  };

  orm.connect(opts, function(err, db) {
    if (err) return cb(err);

    connections[host] = connections[host] || {};
    connections[host][database] = db;
    setup(db);
    cb(null, db);
  });  
};

// somewhere else, eg, middleware

var database = require('./db');

database('dbserver1', 'main', function(err, db) {
  if (err) throw err;

  db.models.user.find({foo: 'bar'}, function(err, rows) {
    // ...
  });
});

鏈接是被緩存的，因此模型在每一個服務器+數據庫上面只會定義一次。因爲咱們使用了鏈接池，咱們並不須要擔憂用完全部的鏈接，並且咱們能夠一次性執行多個查詢。

問題排除

若是你在鏈接MySQL數據庫的時候遇到了以下錯誤：

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

你能夠嘗試添加socketPath參數：

var db = orm.connect({
    host:     'localhost',
    database: 'database',
    user:     'user',
    password: 'pass',
    protocol: 'mysql',
    socketPath: '/var/run/mysqld/mysqld.sock',
    port:     '3306',
    query:    {pool: true, debug: true}
});