Tag: node mysql

从节点,mysql,koa中获取数据

我想从我的MySQL数据库中使用Koa和mysql节点包得到一些数据。 我正在查看co-mysql ,但是自述文件build议直接使用thunkify 。 所以我做了以下几点: const query = thunkify(connection.query.bind(connection)); 这似乎工作,我现在可以做的: app.use(function * main() { const races = yield query( "SELECT * FROM `races` where '2016-01-19' between start_date and end_date" )(function(err, rows) { // rows is the data I need }); }); 但是,我无法find一种方法来将thunk中的行数据返回到我的种族variables中。 我logging它,并显示正确的数据,但是当我尝试将其传回时,它总是返回undefined。 我从callback中尝试了几个方法,但我似乎无法弄清楚: return rows生成yield rows (使callback生成器函数) return yield rows … 我经常得到: TypeError: You […]

Async.js系列和node-mysql查询不能得到行

我目前正在尝试使用async.js系列控制streamfunction来运行一组MySQL查询。 但我不断收到以下错误: throw err; // Rethrow non-MySQL errors ^ TypeError: Cannot read property 'status' of undefined 我已经在async.series之外testing了单独的函数中的查询,并且它们都很好,并将数据还给我,我可以认为这个错误的唯一原因是由于asynchronous性质,因此它当时没有数据当我logging我得到的行时的错误EG: [] [] [] 以下是asynchronousfunction: function SQLuserDataAsync() { connection.getConnection(function (err, connection) { async.series([ function (callback) { connection.query('SELECT status FROM users WHERE name= ?;', [userval], function (err, rows) { if (rows[0]['status']) { console.log("Account Status: " + accountval); } else { […]

Promisify自定义方法

我对Node和JS世界相当陌生。 我要实现的目标是“模块化”我的查询,并在各种情况下重用它们。 这是我的dbpipe理器: 'use strict' const mysql = require('mysql') var Promise = require('bluebird') var using = Promise.using Promise.promisifyAll(require('mysql/lib/Connection').prototype) Promise.promisifyAll(require('mysql/lib/Pool').prototype) const config = require('./config') var pool = mysql.createPool({ connectionLimit: 100, host: config.dbHost, user: config.dbUser, password: config.dbPassword, database: config.db, debug: config.dbDebug }) var getConnection = function () { return pool.getConnectionAsync() .disposer(function (connection) { return connection.release() }) } […]

NPM mysql模块中的连接方法是否被阻塞?

Node.js( 这里 )的官方mysql NPM包文档提供了连接数据库和执行基本查询的以下build议: var mysql = require('mysql'); var connection = mysql.createConnection({ host : 'localhost', user : 'me', password : 'secret', database : 'my_db' }); connection.connect(); connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) { if (error) throw error; console.log('The solution is: ', results[0].solution); }); connection.end(); connect方法也采用一个可选的callback函数,文档中提供了下面这个用法的例子(忽略下面例子中的注释;这个例子实际上是试图演示别的): var connection = require('mysql').createConnection({ port: 84943, […]

使用mysql模块为Nodejs存储JSON

我需要在这个表的'data'列中存储一个JSON: 我试图存储一个JSON,但我收到错误,可能是由于引用… connection.connect(); var query = 'INSERT INTO Forecasts (data, createdAt, updatedAt, OrchardId) VALUES ?'; connection.query(query, [['{"id": 1}', '2017-07-06 16:08:19','2017-07-06 16:08:19',3]],function (error, results, fields) { if (error) throw error; console.log('The solution is: ', results[0].solution); }); connection.end(); OUTPUT $ npm开始 revo-weather@1.0.0 start / Users / giovannimarino / Desktop / revo-weather node index.js {“id”:1} INSERT INTO预测(data,createdAt,updatedAt,OrchardId)VALUES(“gio”,“2017-07-06 16:08:13”,“2017-07-06 […]

Cloud Foundry – node.js – MySQL

请帮助我如何使用node.js和node-mysql模块连接/绑定到云代工的mysql服务? 在云代工厂,我们可以连接/绑定到MySQL服务和云代工厂支持types为spring,node.js等的应用程序,… 我已经成功地开发了一个Spring应用程序,并托pipe在cloudfoundry中,并能够连接/绑定到cloudfoundry的mysql服务。 另外我可以连接到使用node-mysql模块在本地运行的mysql。 但是我想用node.js和node-mysql模块连接/绑定到云代工的mysql服务,没有相关的例子。 是否有可能做到这一点? 在这方面的任何帮助都很受欢迎。 谢谢。 问候,Kishan.G

JavaScript范围。 如何从callback函数中检索信息? 节点的MySQL

我是一个新手在Javascript中,我试图做一个函数来返回我从我的数据库中得到的数组。 首先我试过这个: function getItens(userId){ var arr = new Array; var result; var connection = mysql.createConnection({ host : 'localhost', user : 'XXXXXX', password : 'XXXXXX', database : 'XXXXXX', }); connection.connect(); connection.query('SELECT * from itens where userId = '+ userId function(err, rows, fields){ if (err) throw err; arr = rows.slice() }); return arr; connection.end(); } 然后我意识到那里有一个范围问题,经过一番研究,我试图模拟一个像这样的静态variables: function […]

数据库连接的最佳数量(node-mysql)

默认情况下,node-mysql将连接池中的最大连接数限制为10.这对我来说似乎相当保守。 有一个最佳的连接数,我应该设置它? (有没有一个数字超过了性能可能会降低,而不是增加?) 谢谢

Q.all和一系列的承诺似乎并没有工作

我试图用Q来做一些工作。 我循环并调用一个将数据保存到数据库并返回一个承诺的函数。 一旦完成,我需要做其他事情,但Q.all完成,但我可以看到每个解决scheme被调用。 我疯了,有什么想法? 设置: // save the divisions and then do the division checks // data.divisions is an array of objects var promises = []; data.divisions.forEach(function(dd){ var d = new grpl.division.Division(dd), p = d.save(); promises.push(p); }); Q.all(promises) .then(function(){ // do some other stuff here // this never actually gets called }).fail(function(err){ cb(err); }).done(); 这里是d.save() […]

丢失Amazon Ec2服务器上的数据库连接

在过去的几个月中,我遇到了一个问题,我在亚马逊EC2服务器上部署了我的应用程序,但至less每天10到30次,我得到这些错误。 1) Error: connect ETIMEDOUT at errnoException (net.js:904:11) at Object.afterConnect [as oncomplete] (net.js:895:19) 2) Error: getaddrinfo ENOTFOUND at errnoException (dns.js:37:11) at Object.onanswer [as oncomplete] (dns.js:124:16) ——————– at Handshake.Sequence (/var/app/current/node_modules/mysql/lib/protocol/sequences/Sequence.js:15:20) at new Handshake (/var/app/current/node_modules/mysql/lib/protocol/sequences/Handshake.js:9:12) at Protocol.handshake (/var/app/current/node_modules/mysql/lib/protocol/Protocol.js:42:50) at Connection.connect (/var/app/current/node_modules/mysql/lib/Connection.js:72:18) at module.exports.connect (/var/app/current/node_modules/sequelize/lib/dialects/mysql/connector-manager.js:276:16) at Object.pool.Pooling.Pool.create (/var/app/current/node_modules/sequelize/lib/dialects/mysql/connector-manager.js:125:19) at createResource (/var/app/current/node_modules/sequelize/node_modules/generic-pool/lib/generic-pool.js:258:13) at dispense (/var/app/current/node_modules/sequelize/node_modules/generic-pool/lib/generic-pool.js:250:9) at Object.me.acquire (/var/app/current/node_modules/sequelize/node_modules/generic-pool/lib/generic-pool.js:316:5) at […]