博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Nodejs 连接各种数据库集合例子
阅读量:6232 次
发布时间:2019-06-21

本文共 7380 字,大约阅读时间需要 24 分钟。

Cassandra

Module: cassandra-driver Installation

$ npm install cassandra-driver

Example

1 var cassandra = require('cassandra-driver')2 var client = new cassandra.Client({ contactPoints: ['localhost'] })3  4 client.execute('select key from system.local', function (err, result) {5   if (err) throw err6   console.log(result.rows[0])7 })

Couchbase

Module: couchnode Installation

$ npm install couchbase

Example

1 var couchbase = require('couchbase') 2 var bucket = (new couchbase.Cluster('http://localhost:8091')).openBucket('bucketName') 3   4 // add a document to a bucket 5 bucket.insert('document-key', { name: 'Matt', shoeSize: 13 }, function (err, result) { 6   if (err) { 7     console.log(err) 8   } else { 9     console.log(result)10   }11 })12  13 // get all documents with shoe size 1314 var n1ql = 'SELECT d.* FROM `bucketName` d WHERE shoeSize = $1'15 var query = N1qlQuery.fromString(n1ql)16 bucket.query(query, [13], function (err, result) {17   if (err) {18     console.log(err)19   } else {20     console.log(result)21   }22 })

CouchDB

Module: nano Installation

$ npm install nano

Example

1 var nano = require('nano')('http://localhost:5984') 2 nano.db.create('books') 3 var books = nano.db.use('books') 4   5 // Insert a book document in the books database 6 books.insert({ name: 'The Art of war' }, null, function (err, body) { 7   if (err) { 8     console.log(err) 9   } else {10     console.log(body)11   }12 })13  14 // Get a list of all books15 books.list(function (err, body) {16   if (err) {17     console.log(err)18   } else {19     console.log(body.rows)20   }21 })

LevelDB

Module: levelup Installation

$ npm install level levelup leveldown

Example

1 var levelup = require('levelup') 2 var db = levelup('./mydb') 3   4 db.put('name', 'LevelUP', function (err) { 5   if (err) return console.log('Ooops!', err) 6   7   db.get('name', function (err, value) { 8     if (err) return console.log('Ooops!', err) 9  10     console.log('name=' + value)11   })12 })

Oracle

Module: oracle Installation

$ npm install oracledb
1 var oracledb = require('oracledb'); 2 var config = { 3   user:'******',  //用户名 4   password:'******',  //密码 5   //IP:数据库IP地址,PORT:数据库端口,SCHEMA:数据库名称 6   connectString : "IP:PORT/SCHEMA" 7 }; 8 oracledb.getConnection( 9   config,10   function(err, connection)11   {12     if (err) {13       console.error(err.message);14       return;15     }16   //查询某表十条数据测试,注意替换你的表名17     connection.execute("SELECT * FROM ( SELECT A.*, ROWNUM RN FROM (SELECT * FROM 你的表名) A WHERE ROWNUM <= 10 ) WHERE RN >= 0",18       function(err, result)19       {20         if (err) {21           console.error(err.message);22           doRelease(connection);23           return;24         }25         //打印返回的表结构26         console.log(result.metaData);27         //打印返回的行数据28         console.log(result.rows);29       });30   });31 32 function doRelease(connection)33 {34   connection.close(35     function(err) {36       if (err) {37         console.error(err.message);38       }39     });40 }

MySQL

Module: mysql Installation

$ npm install mysql

Example

1 var mysql = require('mysql') 2 var connection = mysql.createConnection({ 3   host     : 'localhost', 4   user     : 'dbuser', 5   password : 's3kreee7', 6   database : 'my_db' 7 }); 8   9 connection.connect()10  11 connection.query('SELECT 1 + 1 AS solution', function (err, rows, fields) {12   if (err) throw err13  14   console.log('The solution is: ', rows[0].solution)15 })16  17 connection.end()

 

MongoDB

Module: mongodb Installation

$ npm install mongodb

Example

1 var MongoClient = require('mongodb').MongoClient 2   3 MongoClient.connect('mongodb://localhost:27017/animals', function (err, db) { 4   if (err) throw err 5   6   db.collection('mammals').find().toArray(function (err, result) { 7     if (err) throw err 8   9     console.log(result)10   })11 })

If you want an object model driver for MongoDB, look at Mongoose.

Neo4j

Module: apoc Installation

$ npm install apoc

Example

1 var apoc = require('apoc') 2   3 apoc.query('match (n) return n').exec().then( 4   function (response) { 5     console.log(response) 6   }, 7   function (fail) { 8     console.log(fail) 9   }10 )

PostgreSQL

Module: pg-promise Installation

$ npm install pg-promise

Example

1 var pgp = require('pg-promise')(/*options*/) 2 var db = pgp('postgres://username:password@host:port/database') 3   4 db.one('SELECT $1 AS value', 123) 5   .then(function (data) { 6     console.log('DATA:', data.value) 7   }) 8   .catch(function (error) { 9     console.log('ERROR:', error)10   })

Redis

Module: redis Installation

$ npm install redis

Example

1 var client = require('redis').createClient() 2   3 client.on('error', function (err) { 4   console.log('Error ' + err) 5 }) 6   7 client.set('string key', 'string val', redis.print) 8 client.hset('hash key', 'hashtest 1', 'some value', redis.print) 9 client.hset(['hash key', 'hashtest 2', 'some other value'], redis.print)10  11 client.hkeys('hash key', function (err, replies) {12   console.log(replies.length + ' replies:')13  14   replies.forEach(function (reply, i) {15     console.log('    ' + i + ': ' + reply)16   })17  18   client.quit()19 })

SQL Server

Module: tedious Installation

$ npm install tedious

Example

1 var Connection = require('tedious').Connection; 2 var Request = require('tedious').Request; 3   4 var config = { 5   userName: 'your_username', // update me 6   password: 'your_password', // update me 7   server: 'localhost' 8 } 9  10 var connection = new Connection(config);11  12 connection.on('connect', function(err) {13   if (err) {14     console.log(err);15   } else {16     executeStatement();17   }18 });19  20 function executeStatement() {21   request = new Request("select 123, 'hello world'", function(err, rowCount) {22     if (err) {23       console.log(err);24     } else {25       console.log(rowCount + ' rows');26     }27     connection.close();28   });29  30   request.on('row', function(columns) {31     columns.forEach(function(column) {32       if (column.value === null) {33         console.log('NULL');34       } else {35         console.log(column.value);36       }37     });38   });39  40   connection.execSql(request);41 }

SQLite

Module: sqlite3 Installation

$ npm install sqlite3

Example

1 var sqlite3 = require('sqlite3').verbose() 2 var db = new sqlite3.Database(':memory:') 3   4 db.serialize(function () { 5   db.run('CREATE TABLE lorem (info TEXT)') 6   var stmt = db.prepare('INSERT INTO lorem VALUES (?)') 7   8   for (var i = 0; i < 10; i++) { 9     stmt.run('Ipsum ' + i)10   }11  12   stmt.finalize()13  14   db.each('SELECT rowid AS id, info FROM lorem', function (err, row) {15     console.log(row.id + ': ' + row.info)16   })17 })18  19 db.close()

ElasticSearch

Module: elasticsearch Installation

$ npm install elasticsearch

Example

1 var elasticsearch = require('elasticsearch') 2 var client = elasticsearch.Client({ 3   host: 'localhost:9200' 4 }) 5   6 client.search({ 7   index: 'books', 8   type: 'book', 9   body: {10     query: {11       multi_match: {12         query: 'express js',13         fields: ['title', 'description']14       }15     }16   }17 }).then(function (response) {18   var hits = response.hits.hits19 }, function (error) {20   console.trace(error.message)21 })  来自 express 框架里面的文档

转自 https://blog.csdn.net/m0_37450089/article/details/78727782

转载于:https://www.cnblogs.com/joyo-w/p/10660952.html

你可能感兴趣的文章
VB编程技巧推荐
查看>>
Django 简介
查看>>
golang array, slice, string笔记
查看>>
java 集合、接口
查看>>
AutoMapper用法
查看>>
维护后面的position + 离线 + 线段树 bzoj 3585
查看>>
StringUtils常用方法+StringUtils详细介绍
查看>>
iOS开发之JSON解析
查看>>
iOS开发之Run Loop
查看>>
PDF 补丁丁 0.5.0.2731 发布(增加去除页面表单和链接水印功能)
查看>>
PDF 补丁丁 0.6.0.3355 版发布(修复阅读模式、书签缩放的问题)
查看>>
python 内嵌模块——time
查看>>
关于form与表单操作
查看>>
网络协议
查看>>
同源策略
查看>>
Date——时间戳转化为YYYY-MM-DD h:m:s时间格式
查看>>
MySQL_PHP学习笔记_2015_0907_PHP用pdo连接数据库时报错 could not find driver
查看>>
字符类型
查看>>
Algs4-1.1.5位于0与1之间则打印true,否则打印false
查看>>
分布式存储 FastDFS-5.0.5线上搭建
查看>>