Nodejs连接各种数据库集合例子
<h2>Cassandra</h2> <p>Module: cassandra-driver Installation</p> <pre> <code class="language-javascript">$ npm install cassandra-driver</code></pre> <p>Example</p> <pre> <code class="language-javascript">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]) })</code></pre> <h2>Couchbase</h2> <p>Module: couchnode Installation</p> <pre> <code class="language-javascript">$ npm install couchbase</code></pre> <p>Example</p> <pre> <code class="language-javascript">var couchbase = require('couchbase') var bucket = (new couchbase.Cluster('http://localhost:8091')).openBucket('bucketName') // add a document to a bucket bucket.insert('document-key', { name: 'Matt', shoeSize: 13 }, function (err, result) { if (err) { console.log(err) } else { console.log(result) } }) // get all documents with shoe size 13 var n1ql = 'SELECT d.* FROM `bucketName` d WHERE shoeSize = $1' var query = N1qlQuery.fromString(n1ql) bucket.query(query, [13], function (err, result) { if (err) { console.log(err) } else { console.log(result) } })</code></pre> <h2>CouchDB</h2> <p>Module: nano Installation</p> <pre> <code class="language-javascript">$ npm install nano</code></pre> <p>Example</p> <pre> <code class="language-javascript">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(err) } else { console.log(body) } }) // Get a list of all books books.list(function (err, body) { if (err) { console.log(err) } else { console.log(body.rows) } })</code></pre> <h2>LevelDB</h2> <p>Module: levelup Installation</p> <pre> <code class="language-javascript">$ npm install level levelup leveldown</code></pre> <p>Example</p> <pre> <code class="language-javascript">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) }) })</code></pre> <h2>MySQL</h2> <p>Module: mysql Installation</p> <pre> <code class="language-javascript">$ npm install mysql</code></pre> <p>Example</p> <pre> <code class="language-javascript">var mysql = require('mysql') var connection = mysql.createConnection({ host : 'localhost', user : 'dbuser', password : 's3kreee7', database : 'my_db' }); 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()</code></pre> <h2>MongoDB</h2> <p>Module: mongodb Installation</p> <pre> <code class="language-javascript">$ npm install mongodb</code></pre> <p>Example</p> <pre> <code class="language-javascript">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) }) })</code></pre> <p>If you want an object model driver for MongoDB, look at Mongoose.</p> <h2>Neo4j</h2> <p>Module: apoc Installation</p> <pre> <code class="language-javascript">$ npm install apoc</code></pre> <p>Example</p> <pre> <code class="language-javascript">var apoc = require('apoc') apoc.query('match (n) return n').exec().then( function (response) { console.log(response) }, function (fail) { console.log(fail) } )</code></pre> <h2>PostgreSQL</h2> <p>Module: pg-promise Installation</p> <pre> <code class="language-javascript">$ npm install pg-promise</code></pre> <p>Example</p> <pre> <code class="language-javascript">var pgp = require('pg-promise')(/*options*/) var db = pgp('postgres://username:password@host:port/database') db.one('SELECT $1 AS value', 123) .then(function (data) { console.log('DATA:', data.value) }) .catch(function (error) { console.log('ERROR:', error) })</code></pre> <h2>Redis</h2> <p>Module: redis Installation</p> <pre> <code class="language-javascript">$ npm install redis</code></pre> <p>Example</p> <pre> <code class="language-javascript">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() })</code></pre> <h2>SQL Server</h2> <p>Module: tedious Installation</p> <pre> <code class="language-javascript">$ npm install tedious</code></pre> <p>Example</p> <pre> <code class="language-javascript">var Connection = require('tedious').Connection; var Request = require('tedious').Request; var config = { userName: 'your_username', // update me password: 'your_password', // update me server: 'localhost' } var connection = new Connection(config); connection.on('connect', function(err) { if (err) { console.log(err); } else { executeStatement(); } }); function executeStatement() { request = new Request("select 123, 'hello world'", function(err, rowCount) { if (err) { console.log(err); } else { console.log(rowCount + ' rows'); } connection.close(); }); request.on('row', function(columns) { columns.forEach(function(column) { if (column.value === null) { console.log('NULL'); } else { console.log(column.value); } }); }); connection.execSql(request); }</code></pre> <h2>SQLite</h2> <p>Module: sqlite3 Installation</p> <pre> <code class="language-javascript">$ npm install sqlite3</code></pre> <p>Example</p> <pre> <code class="language-javascript">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()</code></pre> <h2>ElasticSearch</h2> <p>Module: elasticsearch Installation</p> <pre> <code class="language-javascript">$ npm install elasticsearch</code></pre> <p>Example</p> <pre> <code class="language-javascript">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) })</code></pre> <p> </p> <p>来自:https://segmentfault.com/a/1190000008753686</p> <p> </p>
本文由用户 LorPeppin 自行上传分享,仅供网友学习交流。所有权归原作者,若您的权利被侵害,请联系管理员。
转载本站原创文章,请注明出处,并保留原始链接、图片水印。
本站是一个以用户分享为主的开源技术平台,欢迎各类分享!