Tag: mysql

NodeJS和mysql:等待查询结果

我有一个用nodejs + express做的小项目,我也做了一些小的服务,在它的某些页面上共享。 var mysql = require('mysql'); var pool = mysql.createPool({ connectionLimit : 100, host : 'host', user : 'user', password : 'password', database : 'database', debug : false }); function executeQuery(query, callback) { pool.getConnection(function (err, connection) { if (err) { return callback(err, null); } else if (connection) { connection.query(query, function (err, rows, fields) { […]

Node-Mysql抛出连接超时

我的node.js应用程序给予5xx由于连接超时随机时间。 以下是我如何连接和查询: var mysql = require('mysql'); var config = { host: '172.10.1.1', port: 3306, user: 'user', password: 'pwd', database: 'mydb', connectionLimit: 15, queueLimit: 30 } var poolCluster = mysql.createPool(config); var queryDB = function(query, cb) { poolCluster.getConnection(function(err, connection) { if(err) { cb(err, null); } else { connection.query(query, function (err, rows) { connection.release(); cb(err, rows); }); } […]

使用mysql在nodejs中进行分页

在我的项目中,我需要使用分页查询数据库,并提供用户根据当前search结果进行查询的function。 有点像限制,我无法find任何使用nodejs的东西。 我的后端是MySQL,我正在写restapi。

通过Node.js,Express和mysql模块进行筛选

我正在尝试通过将node.js和mysql模块https://npmjs.org/package/mysql的快速框架集成起来。 我有一个简单的应用程序设置(通过使用快速命令行),我也有一个模块声明与一些数据库属性的工作。 我的DB模块是这样设置的: app.js node_modules |___db | node_modules |___mysql 将mysql模块设置为db模块的依赖关系。 在我的DB模块的index.js中,我有一些模块导出设置可以被应用程序访问: /* * Connection params for database */ var mysql = require('mysql'); var connection = mysql.createConnection({ host: 'localhost', user: 'user', password: 'password', database: 'database', }); var connect = connection.connect(function(err){ if(!err){ console.log("You are connected to the database."); } else{ throw err; } }); var end = […]

插入多个值时,节点mysql上的'ER_PARSE_ERROR'

我试图在节点中使用node-mysql将多个值放入数据库。 我的源代码 engine.files.forEach(function(file) { torrentpath = file.path.replace(/&/g, "&amp;").replace(/>/g, "&gt;").replace(/</g, "&lt;").replace(/"/g, "&quot;").replace(/'/g, "&apos;").replace(/\\/g, "/"); torrentFiles.push([ result.insertId, torrentpath, file.length ]); }); console.log(torrentFiles); app.mysql.query('INSERT INTO `files` (`torrentid`, `filename`, `filesize`) VALUES ?', torrentFiles, function(err, result) { if (err) throw err; }); 我得到的错误是 [ [ 11, 'ubuntu-14.04-desktop-amd64.iso', 1010827264 ] ] Error: ER_PARSE_ERROR: You have an error in your SQL syntax; […]

我如何设置Sequelize.jsstream数据而不是承诺/callback?

我正在使用MySQL并有一个非常大的响应(15,000 +行)。 这需要..时间。 但是我可以马上处理第一个结果。 我可以设置一个stream以某种方式sequelize ? 如果是这样,怎么样?

续集复合唯一约束

定义模型: export default function(sequelize, DataTypes) { return sequelize.define('Item', { minor: DataTypes.INTEGER, major: DataTypes.INTEGER, }); } 我可以将minor和major定义为复合UNIQUE约束吗?

Node.js – 连接到MySQL数据库服务器

我得到了服务器A,这是一个node.js服务器,服务器B是Apache的PHP服务器。 我想知道如何使用服务器A从服务器B上的数据库获取数据。有没有一个模块或中间件可以做到这一点?

Node.JS + MySQL连接池需要?

使用node-mysql模块,有两个连接选项 – 一个连接和一个连接池。 build立与MySQL数据库的连接,为所有请求使用单个全局连接,或为每个请求创build一个连接池并从池中取出一个连接池的最佳方法是什么? 还是有更好的方法来做到这一点? 我是否会针对所有请求使用单个共享连接来运行问题?

使用node-mysql创build同步查询

我试图确保一个MySQL查询导致另一个,并没有完成,直到所有的子查询完成。 因此,例如,我从一个select和stream行开始,并执行该行结果的后续查询。 这可以通过callback来实现,但是我最终会耗尽内存,所以我想减慢进程并运行批处理,但是由于调度的asynchronous性,我不能保持相同的状态并结束在所有的行都被处理之后进行连接。 这是一个例子: var query = conn.query('select id from table1 limit 10'); query.on('result', function(row){ console.log('query1', row); var query2 = conn.query('select id from books where id = ? ', [row.id]); query2.on('result', function(row2){ console.log('query2', row2); var query3 = conn.query('insert into test (id) values (?)', [row2.id]); query3.on('result', function(row3){ console.log(row3); }); }); }); query.on('end', function(){ conn.end(); }); 以上失败,因为在初始查询结束后仍然有行要在query3中处理。 […]