Перейти к содержанию

Интеграция с базами данных

Для того чтобы добавить функциональную возможность подключения базы данных к приложению Express, необходимо всего лишь загрузить в ваше приложение драйвер Node.js для соответствующей базы данных. В настоящем документе кратко описан способ добавления и использования в приложении Express некоторых наиболее популярных моделей Node.js для систем баз данных.

Это неполный список доступных драйверов баз данных. С другими вариантами можно ознакомиться на сайте npm.

Cassandra

Модуль: cassandra-driver

Установка

$ npm install cassandra-driver

Пример

var cassandra = require('cassandra-driver')
var client = new cassandra.Client({
  contactPoints: ['localhost'],
})

client.execute('select key from system.local', function (
  err,
  result
) {
  if (err) throw err
  console.log(result.rows[0])
})

CouchDB

Модуль: nano

Установка

$ npm install nano

Пример

var nano = require('nano')('http://localhost:5984')
nano.db.create('books')
var books = nano.db.use('books')

//Insert a book document in the books database
books.insert({ name: 'The Art of war' }, null, function (
  err,
  body
) {
  if (!err) {
    console.log(body)
  }
})

//Get a list of all books
books.list(function (err, body) {
  console.log(body.rows)
})

LevelDB

Модуль: levelup

Установка

$ npm install level levelup leveldown

Пример

var levelup = require('levelup')
var db = levelup('./mydb')

db.put('name', 'LevelUP', function (err) {
  if (err) return console.log('Ooops!', err)
  db.get('name', function (err, value) {
    if (err) return console.log('Ooops!', err)
    console.log('name=' + value)
  })
})

MySQL

Модуль: mysql

Установка

$ npm install mysql

Пример

var mysql = require('mysql')
var connection = mysql.createConnection({
  host: 'localhost',
  user: 'dbuser',
  password: 's3kreee7',
})

connection.connect()

connection.query('SELECT 1 + 1 AS solution', function (
  err,
  rows,
  fields
) {
  if (err) throw err
  console.log('The solution is: ', rows[0].solution)
})

connection.end()

MongoDB

Модуль: mongodb

Установка

$ npm install mongodb

Пример

var MongoClient = require('mongodb').MongoClient

MongoClient.connect(
  'mongodb://localhost:27017/animals',
  function (err, db) {
    if (err) {
      throw err
    }
    db.collection('mammals')
      .find()
      .toArray(function (err, result) {
        if (err) {
          throw err
        }
        console.log(result)
      })
  }
)

Если вам необходим драйвер объектной модели для MongoDB, его можно найти на странице Mongoose.

Neo4j

Модуль: apoc

Установка

$ npm install apoc

Пример

var apoc = require('apoc')

apoc
  .query('match (n) return n')
  .exec()
  .then(
    function (response) {
      console.log(response)
    },
    function (fail) {
      console.log(fail)
    }
  )

PostgreSQL

Модуль: pg-promise

Установка

$ npm install pg-promise

Пример

var pgp = require('pg-promise')(/*options*/)
var db = pgp(
  'postgres://username:[email protected]:port/database'
)

db.one('SELECT $1 AS value', 123)
  .then(function (data) {
    console.log('DATA:', data.value)
  })
  .catch(function (error) {
    console.log('ERROR:', error)
  })

Redis

Модуль: redis

Установка

$ npm install redis

Пример

var client = require('redis').createClient()

client.on('error', function (err) {
  console.log('Error ' + err)
})

client.set('string key', 'string val', redis.print)
client.hset(
  'hash key',
  'hashtest 1',
  'some value',
  redis.print
)
client.hset(
  ['hash key', 'hashtest 2', 'some other value'],
  redis.print
)

client.hkeys('hash key', function (err, replies) {
  console.log(replies.length + ' replies:')
  replies.forEach(function (reply, i) {
    console.log('    ' + i + ': ' + reply)
  })

  client.quit()
})

SQLite

Модуль: sqlite3

Установка

$ npm install sqlite3

Пример

var sqlite3 = require('sqlite3').verbose()
var db = new sqlite3.Database(':memory:')

db.serialize(function () {
  db.run('CREATE TABLE lorem (info TEXT)')
  var stmt = db.prepare('INSERT INTO lorem VALUES (?)')

  for (var i = 0; i < 10; i++) {
    stmt.run('Ipsum ' + i)
  }

  stmt.finalize()

  db.each('SELECT rowid AS id, info FROM lorem', function (
    err,
    row
  ) {
    console.log(row.id + ': ' + row.info)
  })
})

db.close()

ElasticSearch

Модуль: elasticsearch

Установка

$ npm install elasticsearch

Пример

var elasticsearch = require('elasticsearch')
var client = elasticsearch.Client({
  host: 'localhost:9200',
})

client
  .search({
    index: 'books',
    type: 'book',
    body: {
      query: {
        multi_match: {
          query: 'express js',
          fields: ['title', 'description'],
        },
      },
    },
  })
  .then(
    function (response) {
      var hits = response.hits.hits
    },
    function (error) {
      console.trace(error.message)
    }
  )