Tag: node mysql

如果我们不closuresmysql节点js模块中的mysql连接,是否有任何问题

如果我们不closures或结束节点js中的mysql连接,它是否影响function。 我正在这样做 var mysql = require('mysql'); var connection = mysql.createConnection(…); connection.query('SELECT 1', function(err, rows) { // connected! (unless `err` is set) }); 我的代码中没有结束mysql连接。 我的问题是需要closuresmysql连接。 如果我们不closuresmysql连接,将来我会遇到其他任何问题。 请帮我joinnodejs 编辑1我不会遇到任何问题,如无法连接,打开等太多的连接,意味着任何资源相关的问题? 对。 EDIT2 如果我们不手动结束它或使用end函数,在哪一瞬间mysql连接将会closures?

更正node-mysql的UPDATE查询语法

我有一个数组“标志”,我已经改变了我的函数中的数组的值。 现在我需要更新到数据库,但我无法这样做。 我已经在桌上有了旗帜专栏。 我不知道如何更新表中variables标志的值 如果我尝试 connection.query('UPDATE visentry SET flag = "flag" ', function(err,rows,fields) { } 它用值标志更新列标志。 如果我尝试以下 var sql = 'UPDATE visentry SET flag= ?'; connection.query(sql,[{flag:flag}], function(err,rows,fields) { 它给出了一个错误 错误:ER_PARSE_ERROR:您的SQL语法中有错误; 检查与您的MySQL服务器版本相对应的手册,在第1行附近使用正确的语法 任何build议,请

在node.js中的mysql查询,检查是否找不到匹配

我如何检查在mysql(node.js)中找不到匹配项? mysql.query("select * from table1 where name = 'abcd'", function(error, result, field) { if(error) { exist(error); //No error } else if(result) { console.log(result); //displays '[]' exist(null, result); } else { exist(null, null); //It is never execute } }); function exist(error, result) { if(result) console.log("Test:"+result); //Executed and displays 'Test:' } 我的数据库不包含名称='abcd'。 那么,如何检查查询是否不匹配呢?

如何从node.js中的mysql SELECT查询中返回一个值

我还是很新的Node.js,我试图了解如何callback工作。 所以,这是我的问题: 我应该把更多的代码: POST: app.post('/register', function(req, res) { //get data from the request var data = { username: req.body.username, email: req.body.email, password: req.body.password }; function fetchID(callback) { connection.query('SELECT id_user FROM USERS WHERE username = ?', data.username, function(err, rows) { if (err) { callback(err, null); } else callback(null, rows[0].id_user); }); } var user_id; fetchID(function(err, content) { […]

Node.js的mysql事务

任何人都可以提供一个如何在Node.js中实现MySQL事务的例子。 我正在尝试使用node-mysql驱动程序和node-mysql-queue。 据我所知,使用node-mysql-queue大大降低了Node.js的asynchronous性质,因为新的查询必须等到现有的查询完成。 为了解决这个问题,有人试图将node-mysql-queue和node-mysql的连接池function结合起来。 即为每个新的http请求启动一个新的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才能释放它? 任何更好的想法?