express操作数据库

Express

集成数据库

为 Express 应用添加连接数据库的能力,只需要加载相应数据库的 Node.js 驱动即可。这里将会简要介绍如何为 Express 应用添加和使用一些常用的数据库 Node 模块。

这些数据库驱动只是其中一部分,可在 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

模块mongoskin
安装

$ npm install mongoskin

示例

var db = require(‘mongoskin‘).db(‘localhost:27017/animals‘);

db.collection(‘mamals‘).find().toArray(function(err, result) {
  if (err) throw err;
  console.log(result);
});

If you want a object model driver for MongoDB, checkout 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
安装

$ npm install pg

示例

var pg = require(‘pg‘);
var conString = "postgres://username:[email protected]/database";

pg.connect(conString, function(err, client, done) {

  if (err) {
    return console.error(‘error fetching client from pool‘, err);
  }
  client.query(‘SELECT $1::int AS number‘, [‘1‘], function(err, result) {
    done();
    if (err) {
      return console.error(‘error running query‘, err);
    }
    console.log(result.rows[0].number);
  });

});

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);
});

Github Repo

Express 项目由 StrongLoop 赞助。

Edit this page on GitHub

Copyright ? StrongLoop, Inc., and other expressjs.com contributors.

Bootstrap中文网 Grunt中文网 Gulp中文网 BootCDN Node.js 中文文档

冀ICP备15008021号|? Express 中文网 2015

原文地址:https://www.cnblogs.com/leigepython/p/9244767.html

时间: 2024-10-04 16:55:20

express操作数据库的相关文章

Python操作数据库(mysql redis)

一.python操作mysql数据库: 数据库信息:(例如211.149.218.16   szz  123456) 操作mysql用pymysql模块 #操作其他数据库,就安装相应的模块 import  pymysql ip='211.149.218.16' port=3306 passwd='123456' user='root' db='szz' conn=pymysql.connect(host=ip,user=user,port=port,passwd=passwd,db=db,cha

adb命令详解(二)——手机缺失sqlite3时操作数据库的多种解决方案

在android应用开发无处不在SQLite数据库的身影.那么在开发中怎么使用adb命令操作数据库的功能呢? 下面我们将完整的介绍与数据库操作相关的命令集及当手机缺少sqlite3的时候的多种解决方案. 1.当手机缺失sqlite3时,如何操作数据库 先来看看手机缺失sqlite3时候的效果图: 这个时候你想操作刚刚编写应用程序中执行的数据库文件内容,显然是执行不了sql语句的.下面我们将介绍三种方法让你可以查看应用程序下的数据库文件: ㈠向手机导入sqlite3文件 ①第一步,下载sqlite

C#编写程序操作数据库如何防止SQL注入漏洞的发生

我们在使用C# 编程的时候,经常会遇到操作数据库的地方,如果我们不注意,可能编写的代码就是下面这样 在前台定义了一个文本框,name值为btnName;  定义了一个查询按钮,name值为btnSearch,Click事件为 btnSearch_Click, private void btnSearch_Click(object sender, RoutedEventArgs e)         {             using (SqlConnection conn = new Sql

Asp.net连接数据库及操作数据库--入门

1.创建公共类DB--4个方法.GetCon()//连接数据库,sqlEx//执行数据库操作, reDt//返回数据表, reDr//返回SqlDataReader对象 dr ///<summary>连接数据库</summary>返回SqlConnection对象 public SqlConnection GetCon()//连接数据库,ConfigurationManager对象的AppSettings属性值获取配置节中连接数据库的字符串实例化SqlConnection对象,并返

python 全栈 数据库 (三) python操作数据库

python 操作MYSQL数据库主要有两种方式: 使用原生模块:pymysql ORM框架:SQLAchemy 一.pymysql 1.1下载安装模块 第一种:cmd下:执行命令下载安装:pip3 install pymysql 第二种:IDE下pycharm python环境路径下添加模块 1.2使用操作 #导入模块 import pymysql #建立连接通道,建立连接填入(连接数据库的IP地址,端口号,用户名,密码,要操作的数据库,字符编码) conn = pymysql.connect

MySQL---连接器(python如何操作数据库媒介,基于python语言)

MySQL — 连接器 连接器的概念 它们往往是一类Python包,或者是一类已经写好的Python库.这些库提供了我们Python去连接数据库服务器的基本功能. ? 既然它是一个包,那么我们首先学会导入这个包 #! /usr/bin/env python3 # coding: utf-8 ? from mysql import connector print('导入成功') 执行以上代码 $ python3 test_connector.py 导入成功 表示我们成功导入了相关的包或者模块 连接

使用内置函数操作数据库

0.视频:http://www.imooc.com/video/3383 1.笔记: ContentValues: 1)用于存储一组可以被ContentResolve处理的值: 2)代码示例: ContentValues values=new ContentValues();//类似hashMap key value values.put("name", "张三"); 3)执行对应的Sql操作: db.update("stutb", values

初学时简单的操作数据库方法

一:cmd操作数据库--开启数据库net start mysql --关闭数据库net stop mysql --1:连接数据库mysql -uroot -p --2:查询数据库show databases; --3:设置字符编码set names gbk; --4:增加数据库create database if not exists 库名; --5:查看数据库的创建语句(是如何创建的)show create database 库名: --6:删除数据库drop database if exis

封装JDBC操作数据库的方法

自己动手封装java操作数据库的方法: 一:目录结构 二:所需依赖的第三方jar包 这里只需引入mysql-connector-java-5.1.8-bin.jar,mysql数据库驱动jar包 三:代码 1:和数据库进行交互,首先是数据源,获取连接,代码如下: 1 /** 2 * 3 */ 4 package com.hlcui.datasource; 5 6 import java.sql.Connection; 7 import java.sql.DriverManager; 8 impo