Articles of node mysql

NodeJS / Express – 在路由器文件中创build可用的MySQL连接对象

我有我的app.js文件中的以下内容: var mysql = require('mysql'); var connection = mysql.createConnection({ host: 'localhost', port: 3306, user: 'user', password: 'password', database: 'mydatabase' }); connection.connect(); 在routes/index.js ,我目前只有样板代码: var express = require('express'); var router = express.Router(); module.exports = router; 如何使routes/index.js的app.js文件中的connection对象可用?

什么是最好的Node.js MySQL模块连接到MySQL通过SSL?

我已经使用node-mysql构build了我的应用程序。 我只使用AWS RDS服务设置了一个安全可访问的mysql数据库,并已经成功地通过mysql命令行客户端testing了一个SSL连接。 我有亚马逊的公钥.pem文件。 node-mysql似乎没有SSL连接选项的api。 到目前为止,我发现的唯一一个是Node-mysql-libmysqlclient,但是我尝试连接它时出现了错误,关于绑定依赖项为null,所以我不确定是否应该信任它。 build议使用哪个模块/ api? 另外,如果你知道我需要在node-mysql中修改什么,我会愿意修补一下,但它看起来像使用较低级别的套接字来连接到MySQL,所以我不知道有多难,得到已添加SSL部分。

在node-mysql中selectWHERE

有谁知道如何在节点mysql中使用SELECT WHERE IN ? 我试过下面的代码,但我得到以下错误信息: 'You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near ''(`PHP`,`apache`)'' at line 1' 这是我的代码: whereIn = '('; for ( var i in tagArray ) { if ( i != tagArray.length – 1 ) { […]

为什么Node.js中的MySQL如此之慢?

我的Node.js代码如下所示 CODE1:下面 var http=require('http'); var MySQL = require('mysql'); mysql = MySQL.createConnection(…) http.createServer(function(req, res){ // the query will take several seconds mysql.query("SELECT SLEEP(1)", function….) }); http.listen(…); 问题是当我刷新页面过快时服务器会崩溃。 我认为是node-mysql模块的问题,它处理队列中的查询。所以我尝试创build一个连接池。 CODE2:下面 …. var pool = require('generic-pool'); var mp = pool.Pool({ … create: function(cb){ client = MySQL.createConnection(…); cb(null, client) }, max: 10, // up to 10 connection min: 2, […]

node-mysql – 何时释放连接回池

我正在使用连接池的node-mysql驱动程序。 只有一个查询时,将连接释放回池中很容易: pool.getConnection(function(err, connection) { if (err) { throw err; } query = "SELECT * FROM user WHERE id = ?"; connection.query(query, [id], function(err, users) { connection.release(); if (err) { throw err; } // … }); }); 如果我需要再次使用连接,该怎么办? 我不得不将release()移动几行。 但是,如果错误被抛出,会发生什么? 连接是否永远不会返回到池中? 我是否必须使用一些控制stream程lib才能释放它? 任何更好的想法?

如何使用mysql数据库在node.js中进行login表单

我是新的node.js,我想使用快递和MySQL数据库做一个login页面,请与我分享您的想法与示例。

node.js,以同步的方式在循环中一个接一个地执行mysql查询

在我的node.js中,表示应用程序,我用superagent中间件做了一个ajax调用。 该调用通过相当多的数据库查询使用node-mysql中间件获取复杂数组中的数据库数据。 在粘贴代码之前,我试图用言语解释我正在尝试做什么,尽pipe代码足以说明在第一个callback中的所有asynchronous事件应该以同步的方式完成。 说明: 在第一个查询的callback中,执行for循环多次运行第二个查询,在每个循环之后,只有在第二个查询的callback完成后才会调用下一个循环。 下一个代码行也是一样的。 码: 但是 ,如果你愿意的话,你可以跳过 for循环的内部(标注在注释中)来使事情变得简单和简单。 conn.query("SELECT * FROM `super_cats`",function(error, results, fields) { if(error){console.log("erro while fetching products for homepage "+ error);} for(var i in results) { // FIRST FOR LOOP INSIDE THE FIRST QUERY CALLBACK /*Innards of for loop starts*/ var elem = new Object(); var supcat_id=results[i].id; elem.super_id =supcat_id; elem.cats=new Array(); […]

node.js-MySQL COUNTlogging的数量

我有以下代码。 var mysql = require('mysql'); var connection = mysql.createConnection({ host : 'localhost', user : 'root', password : '', database : 'test' }); connection.connect(); var userdata = '24'; var sql = 'SELECT COUNT(*) FROM names WHERE age = ?' connection.query(sql, [userdata], function(err, rows, fields) { if (err) throw err; console.log('Query result: ', rows); }); connection.end(); 我想从表'姓名'的年龄= […]

Node.js找不到模块的“可读stream”

我是node.js的新手,并坚持以下几点。 任何帮助将不胜感激: 我在Ubuntu(12.10)上运行node.js(0.10.28)。 我正在处理的代码是: "use strict"; var mysql = require('node-mysql'), connection = mysql.createConnection({ host: "127.0.0.1", user: "user", password: "password", database: "dbname" }); if(connection) { console.log("Query"); connection.query("select * from client",function(err,res) { if(err)console.log(err); console.log(res); }); } 我得到以下错误 Error: Cannot find module 'readable-stream' at Function.Module._resolveFilename (module.js:338:15) at Function.Module._load (module.js:280:25) at Module.require (module.js:364:17) at require (module.js:380:17) at Object.<anonymous> (/root/RonakNodeEmail/node_modules/node-mysql/lib/protocol/sequences/Query.js:7:20) […]

如何使用ExpressJS在XML中进行响应?

我有一个简单的代码,为特定的路线提供JSON响应。 这是我现在的代码: var express = require('express') , async = require('async') , http = require('http') , mysql = require('mysql'); var app = express(); var connection = mysql.createConnection({ host: 'localhost', user: '****', password: "****", database: 'restaurants' }); connection.connect(); // all environments app.set('port', process.env.PORT || 1235); app.use(express.static(__dirname + '/public/images')); app.get('/DescriptionSortedRating/',function(request,response){ var name_of_restaurants; async.series( [ // Get the first […]