Node.js 数据库

2023-11-11 来源：华拓网

一、Express 框架下Node.js连接数据库的写法

在同一个目录下写setting.js和connet.js，分别负责数据库的设置和连接

setting.js

module.exports = {host:‘……‘,user:‘root‘,password:‘123456‘,port:3306,database:‘数据库名称‘};

connect.js

var settings = require(‘./settings‘);var mysql = require(‘mysql‘);var client = mysql.createConnection(settings, function(err, stream) {});client.connect(function(err) {if (err) {console.log(‘error connecting: ‘ + err.stack);throw err;}console.log(‘connect as id‘ + client.threadId);})client.on(‘error‘, function() {});module.exports = client;

express框架下数据库模块的加载

let db = require(‘./database/querydb.js‘);app.use(express.static(‘./public‘));app.use(express.static(‘./database‘));app.use(express.static(‘./build‘))

二、单纯的Node.js数据库连接与操作

数据库连接：

var mysql = require(‘mysql‘); var connection = mysql.createConnection({ host : ‘localhost‘, user : ‘root‘, password : ‘123456‘, port: ‘3306‘, database: ‘transport‘, });connection.connect(function(err) {if (err) {console.log(‘error connecting: ‘ + err.stack);throw err;}console.log(‘connect as id‘ + client.threadId);})

View Code

select操作

var sql = ‘SELECT * FROM websites‘;//查connection.query(sql,function (err, result) {if(err){console.log(‘[SELECT ERROR] - ‘,err.message);return;}console.log(‘--------------------------SELECT----------------------------‘);console.log(result);console.log(‘------------------------------------------------------------‘); });connection.end();

View Code

delete操作

var delSql = ‘DELETE FROM websites where id=6‘;//删connection.query(delSql,function (err, result) {if(err){console.log(‘[DELETE ERROR] - ‘,err.message);return;}console.log(‘--------------------------DELETE----------------------------‘);console.log(‘DELETE affectedRows‘,result.affectedRows);console.log(‘-----------------------------------------------------------------‘); });connection.end();

View Code

insert操作

var mysql = require(‘mysql‘);var connection = mysql.createConnection({ host : ‘localhost‘, user : ‘root‘, password : ‘123456‘, port: ‘3306‘, database: ‘test‘, }); connection.connect();var addSql = ‘INSERT INTO websites(Id,name,url,alexa,country) VALUES(0,?,?,?,?)‘;var addSqlParams = [‘菜鸟工具‘, ‘https://c.runoob.com‘,‘23453‘, ‘CN‘];//增connection.query(addSql,addSqlParams,function (err, result) {if(err){console.log(‘[INSERT ERROR] - ‘,err.message);return;} console.log(‘--------------------------INSERT----------------------------‘);//console.log(‘INSERT ID:‘,result.insertId); console.log(‘INSERT ID:‘,result); console.log(‘-----------------------------------------------------------------‘); });connection.end();

View Code

update操作

var modSql = ‘UPDATE websites SET name = ?,url = ? WHERE Id = ?‘;var modSqlParams = [‘菜鸟移动站‘, ‘https://m.runoob.com‘,6];//改connection.query(modSql,modSqlParams,function (err, result) {if(err){console.log(‘[UPDATE ERROR] - ‘,err.message);return;} console.log(‘--------------------------UPDATE----------------------------‘);console.log(‘UPDATE affectedRows‘,result.affectedRows);console.log(‘-----------------------------------------------------------------‘);});connection.end();

View Code

Node.js 数据库

标签：pen mod gif lex ase log 连接数据库 sites websites

小编还为您整理了以下内容，可能对您也有帮助：

nodejs怎么连接数据库

通常在NodeJS开发中我们经常涉及到操作数据库，尤其是 MySQL ，作为应用最为广泛的开源数据库则成为我们的首选，本篇就来介绍下如何通过NodeJS来操作 MySQL 数据库。安装MySQL模块到NodeJS中我们需要让NodeJS支持MySQL，则需要将MySQL模块添加到系统支持库

想要快速了解Node.js ，赞生推荐亲看看 node.js_guide.pdf — node.js 开发指南：想要电子版高清的留言发送

如果不想留言可以带你做飞机！直接下载

Node.js
简单介绍一下node.js的操作吧
安装 node-mysql
$ npm install mysql
创建测试表
//数据库名 NodeSampleCREATE TABLE `NodeSample`.`MyTable` (

`id` INT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY ,
`firstname` VARCHAR( 20 ) NOT NULL ,
`lastname` VARCHAR( 20 ) NOT NULL ,
`message` TEXT NOT NULL
) ENGINE = MYISAM ;

连接数据库
Js代码

var sys = require('sys');

var Client = require('mysql').Client;
var client = new Client();

client.user = 'someuser';
client.password = 'password';

client.connect(function(error, results) {
if(error) {
console.log('Connection Error: ' + error.message);
return;
}
console.log('Connected to MySQL');
});

nodejs怎么连接数据库

node.js调用数据库数据

mysql = require(‘mysql‘); var connection = mysql.createConnection({ host : ‘localhost‘,//本机数据库使用localhost user : ‘root‘,//用户名 password : ‘23191306‘,//密码 port: ‘3306‘,//端口号（默认3306） database: ‘study_sql‘//数据库名称 }); connection.connect(); var sql = ‘SELECT * FROM emp‘;//查询的表 select * frome 表名//打印表中所有内容connection.query(sql,function (err, result) { if(err){ console.log(‘[SELECT ERROR] - ‘,err.message); return; } console.log(‘--------------------------SELECT----------------------------‘); console.log(result); console.log(‘------------------------------------------------------------‘); });connection.end();

安装node,js，官网傻瓜式安装，忽略

win+R 打开运行输入cmd

cd到 node.js 脚本目录

技术图片

添加数据库依赖

技术图片

运行脚本：

技术图片

成功返回数据库表中内容：

技术图片

错误：

Error: Cannot find module ‘mysql‘

原因：数据库依赖和node.脚本必须在同一目录

解决方法：

1.CD到node。脚本中安装依赖

2.将脚本移到依赖安装目录中运行

在window执行node.js文件查询数据库

标签：word 内容 err js代码 info local class inf 脚本

node.js调用数据库数据

安装node,js，官网傻瓜式安装，忽略

win+R 打开运行输入cmd

cd到 node.js 脚本目录

技术图片

添加数据库依赖

技术图片

运行脚本：

技术图片

成功返回数据库表中内容：

技术图片

错误：

Error: Cannot find module ‘mysql‘

原因：数据库依赖和node.脚本必须在同一目录

解决方法：

1.CD到node。脚本中安装依赖

2.将脚本移到依赖安装目录中运行

在window执行node.js文件查询数据库

标签：word 内容 err js代码 info local class inf 脚本

nodejs简单访问及操作mysql数据库的方法示例

本文实例讲述了nodejs简单访问及操作mysql数据库的方法。分享给大家供大家参考，具体如下：
var
mysql
=
require('mysql');
//调用MySQL模块
mysql模块要安装
$
npm
install
mysql
//创建一个connection
var
connection
=
mysql.createConnection({
host
:
'127.0.0.1',
//主机
user
:
'root',
//MySQL认证用户名
password
:
'',
//MySQL认证用户密码
port:
'3306',
//端口号
database:''
//数据库名
});
//创建一个connection
connection.connect(function(err){
if(err){
console.log('[query]
-
:'+err);
return;
}
console.log('[connection
connect]
succeed!');
});
//执行SQL语句
connection.query('SELECT
1
+
1
AS
solution',
function(err,
rows,
fields)
{
if
(err)
{
console.log('[query]
-
:'+err);
return;
}
console.log('The
solution
is:
',
rows[0].solution);
});
//关闭connection
connection.end(function(err){
if(err){
return;
}
console.log('[connection
end]
succeed!');
});
注：nodejs在操作数据库的时候不用设置数据库的编码格式
set
names
utf8
希望本文所述对大家nodejs程序设计有所帮助。
您可能感兴趣的文章:nodejs连接mysql数据库简单封装示例-mysql模块nodejs进阶(6)—连接MySQL数据库示例nodejs实现的连接MySQL数据库功能示例Nodejs连接mysql并实现增、删、改、查操作的方法详解nodeJs实现基于连接池连接mysql的方法示例nodejs中操作mysql数据库示例NodeJS链接MySql数据库的操作方法Nodejs使用mysql模块之获得更新和删除影响的行数的方法NodeJs使用Mysql模块实现事务处理实例nodejs连接mysql数据库及基本知识点详解

nodejs简单访问及操作mysql数据库的方法示例

nodejs用mysql连接数据库怎么连接多个数据表

Nodejs要连接MySQL，可以使用Nodejs的MysQL驱动来实现。比如，我们这里使用“node-mysql”连接数据库。我们使用下面的方式来连接数据库：
首先，我们需要使用nodejs的包管理工具（npm）安装mysql的驱动。命令行如下：

[plain] view plain copy
npm install musql

现在，要在js文件中使用mysql，添加下面的代码到你的文件中：

[plain] view plain copy

nodejs用mysql连接数据库怎么连接多个数据表

idea创建nodejs连接mysql

在 IDEA 中创建 Node.js 项目连接 MySQL 数据库，可以按照以下步骤进行操作：

打开 IDEA，选择“Create New Project”创建一个新的 Node.js 项目。

在新建项目的目录下打开终端，使用 npm 命令安装 mysql 模块，命令如下：

css

Copy code

npm install mysql --save

在项目的根目录下创建一个名为 index.js 的文件，编写以下代码：

javascript

Copy code

const mysql = require('mysql');

// 创建连接对象

const connection = mysql.createConnection({

host: 'localhost', // 数据库服务器地址

user: 'root', // 数据库用户名

password: 'password', // 数据库密码

database: 'test', // 数据库名称

port: 3306 // 数据库端口号，默认为 3306

});

// 连接数据库

connection.connect();

// 执行 SQL 查询语句

connection.query('SELECT * FROM user', function (error, results, fields) {

if (error) throw error;

console.log('The solution is: ', results);

});

// 关闭连接

connection.end();

其中，需要将 host、user、password、database 等参数设置为实际的数据库连接信息。

在终端中运行 index.js 文件，命令如下：

Copy code

node index.js

这样，就可以连接到 MySQL 数据库，并查询指定的表中的数据。

以上是使用 Node.js 连接 MySQL 数据库的简单示例，如果需要进行更复杂的操作，可以参考 mysql 模块的文档，了解更多的 API 和用法。

node.js是什么

Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境。 Node.js 使用了一个事件驱动、非阻塞式 I/O 的模型。

Node 是一个让 JavaScript 运行在服务端的开发平台，它让 JavaScript 成为与PHP、Python、Perl、Ruby 等服务端语言平起平坐的脚本语言。发布于2009年5月，由Ryan Dahl开发，实质是对Chrome V8引擎进行了封装。

Node对一些特殊用例进行优化，提供替代的API，使得V8在非浏览器环境下运行得更好。V8引擎执行Javascript的速度非常快，性能非常好。Node是一个基于Chrome JavaScript运行时建立的平台，用于方便地搭建响应速度快、易于扩展的网络应用。Node 使用事件驱动，非阻塞I/O 模型而得以轻量和高效，非常适合在分布式设备上运行数据密集型的实时应用。

扩展资料：

Node采用一系列“非阻塞”库来支持事件循环的方式。本质上就是为文件系统、数据库之类的资源提供接口。向文件系统发送一个请求时，无需等待硬盘（寻址并检索文件），硬盘准备好的时候非阻塞接口会通知Node。

该模型以可扩展的方式简化了对慢资源的访问，直观，易懂。尤其是对于熟悉onmouseover、onclick等DOM事件的用户，更有一种似曾相识的感觉。

node.js是什么

Node.js 是一个基于 Chrome V8 引擎的 JavaScript 运行环境。 Node.js 使用了一个事件驱动、非阻塞式 I/O 的模型。

扩展资料：

该模型以可扩展的方式简化了对慢资源的访问，直观，易懂。尤其是对于熟悉onmouseover、onclick等DOM事件的用户，更有一种似曾相识的感觉。

Node.jsSequelize如何实现数据库的读写分离

一、前言

在构建高并发的Web应用时，除了应用层要采取负载均衡方案外，数据库也要支持高可用和高并发性。使用较多的数据库优化方案是：通过主从复制(Master-Slave)的方式来同步数据，再通过读写分离(MySQL-Proxy)来提升数据库的并发负载能力。

1. replication选项与读写分离

Sequelize 支持读/写分离，要实现读/写分离可以分别为读和写各创建一个Sequelize实例，更方便的使用方式是在创建实例时，通过replication选项分别指定读/写数据库。

要在Sequelize中使用读/写复制，可以在初始化Sequelize时有时向其replication选项传递一个对象.这个对象read、write两个属性。write是一个单一的对象(即：由单台服务器处理写入)，而read是一个包含对象的数组(即：由多台服务器处理读取)。每台read、write服务器都可以包含以下属性：

· host - 数据库服务器的主机

· port - 数据库服务器的主机端口

· username - 验证用户名

· password - 验证密码

· database - 要连接的数据库

2. Sequelize读/写分离示例

在使用主从复制的多台数据库集群中，可以通过在replication对象的read属性中设置，该属性是一个数组，可以在其中传入一个或多个服务器连接副本。读操作相当于对数据库集群中的从节点进行操作，它会处理所有SELECT查询操作(读操作)。而replication对象的write属性是一个表示服务器连接的对象，写操作相当于主节点，它会处理所有插入、更新、删除操作(写操作)。

var sequelize = new Sequelize('database', null, null, {

dialect: 'mysql',

port: 3306

replication: {

read: [

{ host: '192.168.1.33', username: 'itbilu.com', password: 'pwd' },

{ host: 'localhost', username: 'root', password: null }

write: { host: 'localhost', username: 'root', password: null }

pool: { // 如果需要重写链接池，请在 pool 选项中修改

maxConnections: 20,

maxIdleTime: 30000

})所有的整体性设置，都会适用于所有节点副本，所以并不需要为每个实例单独指定。在上例中，数据库名和端口号会应用于所有节点副本，用户名和密码选项也同样适用。如果某一节点副本不使用全局设置，则需要在replication选项中单独指定。

注意：Sequelize 并不会设置主从复制节点及节点间的数据同步(复制)，这些操作实际由MySQL(或你所使用的数据库)完成。而 Sequelize 只负责从主从节点写入或读取数据。

Sequelize 会使用连接池来管理节点副本。

默认选项是：

{

maxConnections: 10,

minConnections: 0,

maxIdleTime:1000

}总结

NodeJS，mysql2/promise，连接池执行，将数据复制到另一个数据库

产品开发了新版本，数据不兼容，新版本的数据结构比旧版本复杂一些，目前，旧版本是在线系统，需要将旧版本程序的数据适配至新版本程序。数据库是MySQL，这里选择使用NodeJS来完成。

使用的版本：

需要的依赖

案例一，单表的数据同步：

databasemysqlmysql.tools.js

databasemysql2mysql2.tools.js

syncdata0.basesyncData.js

syncdata1.manufactormain.manufactor.js

syncdata2.brandmain.brand.js

syncdata3.categorymain.category.js

案例二，关联表的数据同步：

databasemysql2mysql2.promise.tools.js

syncdata4.general_namemain.general_name.js

syncdata5.goodsmain.goods.js

显示全文

全部频道

Node.js 数据库