Tag: mysql

使用node.js，我如何写入一个MySQL数据库并从另一个读取？: 具体来说，我正在谈论MySQL Master-Slave(s) Replication 。据我所知，我所有的读取应该发生在从机（或多个从机隐藏在负载均衡器之后），而我所有的直接写入主机。我怎样才能做到这一点node.js ？我为我的数据库查询使用MySQL活动logging包，我不认为它支持本地。我想我可以破解包，并有一个if is write-query, then use db1types的情况，但我不知道是否有一个更简单的方法。

应用程序不会终止于MySQL池: 我正在编写一个nodejs应用程序，并希望使用连接池。但是，下面的应用程序不会终止 – 虽然我希望它在connection.end()调用后终止。应用程序工作得很好，如果我使用一个连接，而不是池。我需要以某种方式终止游泳池吗？使用的库： https ： //github.com/felixge/node-mysql Ubuntu上的node.js版本：0.10.4 var mysql = require('mysql'); var pool = mysql.createPool({ host : 'example.org', user : 'myuser', password : 'youbet', database : 'notrevealingdetails', insecureAuth: true }); function getCampaignData(callback) { pool.getConnection(function(err, connection) { if(err) throw err; connection.query( 'SELECT cam.id, cam.name AS campaign_name, cam.subdomain, usr.email, usr.display_name AS […]

从行中获取值，并与Sequelize关联: 我使用Sequelize，MySQL和Node来编写Web应用程序。对于我的大部分数据库需求，我通常会进行一些validation，然后提取我的模型（热切地与关联）并将它们发送回客户端，几乎总是按照原样（至less到现在为止）。我写了一个小的实用函数getValuesFromRows从一个返回的行数组中提取值： getValuesFromRows: function(rows, valuesProp) { // get POD (plain old data) values valuesProp = valuesProp || 'values'; if (rows instanceof Array) { var allValues = []; for (var i = 0; i < rows.length; ++i) { allValues[i] = rows[i][valuesProp]; } return allValues; } else if (rows) { // only one object return rows[valuesProp]; […]

Sails js：如何在Sails js的单个模型中定义两个到两个不同数据库的MySQL连接？: 我创build了一个模型Employee.js和EmployeeController.js。我在Employee.js文件中定义了两个连接： module.exports = { connection: 'LocalhostMysqlServer', attributes: { name:{ type:"string", required:true, }, empnum:{ type:"integer", required:true, unique: true }, email:{ type:"string", required:true, unique: true } }, connection: 'LocalhostMysqlServer1', attributes: { username:{ type:"string", required:true, }, usrnum:{ type:"integer", required:true, unique: true }, email:{ type:"string", required:true, unique: true } }, }; 下面是我的EmployeeController.js文件，其中包含两个视图：CreateEmp和CreateUsr，与此模型和控制器关联。另外，我定义了两个函数来处理来自这些视图的请求。在这里，我想从CreateEmp插入数据到不同的数据库，并从CreateUsr插入到不同的数据库。 module.exports = { createEmp: […]

Sequelize.js：如何处理与MySQL的重新连接: 我一直使用Mongo和Node，但现在由于现有的数据源，我需要连接一个节点应用程序与Mysql。 Sequelize似乎是一个很好的解决scheme，但我不知道如何处理连接错误，重新连接和重新尝试。在第一次运行时检查连接错误.authenticate().then().catch(function(error){…}); 但是，如果我失去连接，并希望重新连接？

MYSQL：需要帮助快速增长的表和减less速度（4mio行）: 我正在以快速增长的速度增长的桌面（目前有4百万行，每天插入30万行）面临一些问题。我希望我能在这里得到一些想法和build议，以改善我的设置，挤出我的盒子里的最后一点，在不久的将来把我的网站拿下来之前。设置： Intel i7 720 8GB RAM 2x750GB SATA RAID 0 CentOS MySQL 5.5.10 Node.js + node-lib_mysql-client 表格定义： CREATE TABLE IF NOT EXISTS `canvas` ( `id` bigint(20) unsigned NOT NULL AUTO_INCREMENT, `x1` int(11) NOT NULL, `y1` int(11) NOT NULL, `x2` int(11) NOT NULL, `y2` int(11) NOT NULL, `c` int(4) unsigned NOT NULL, `s` int(3) […]

node.js：对于每个行和更新asynchronous？: 我需要从数据库查询行，每行处理一些信息，然后用结果更新每一行。这是我的示例代码，其目的是循环遍历每一行并更新标签： var mysql = require('mysql'); var db = mysql.createConnection(config.database); db.connect(function() { db.query('SELECT id FROM testTable', function (err, rows) { if (err) { console.log(err); } else { if (rows.length) { for (var i = 0, len = rows.length; i < len; i++) { var row = rows[i]; console.log(row); var label = "Label_"+row.id; db.query('UPDATE testTable SET […]

ER_CON_COUNT_ERROR：node-mysql中的连接错误太多: 我是一个节点初学者。以下是我试图使用节点mysql执行的代码，但它不断给我这个错误： error connecting: Error: ER_CON_COUNT_ERROR: Too many connections ：：码：： var size = item.length;// size is ~1500 for (var i=0; i<size;i++) { var connection = mysql.createConnection({ host : 'xxx.xxx.xxx.xxx', database : 'mydb', user : 'test', password : 'test' }); connection.connect(function(err, callback) { if (err) { console.error('error connecting: ' + err.stack); return; } }); var entry […]

在sequelize.js中自定义json响应: 我使用sequelize从MySQL数据库获取JSON。所以我有两个模型Menu和Product进一步的关联，如： Menu.js classMethods: { associate: function(models) { Menu.hasMany(models.Product, {foreignKey: 'menu_id'}) } } Product.js classMethods: { associate: function(models) { Product.belongsTo(models.Menu, {foreignKey: 'menu_id'}) } }, // IF I ADD BELOW CODE I HAVE ERROR: Possibly unhandled ReferenceError: menu is not defined instanceMethods: { toJSON: function () { var values = this.get(); if (this.Menu) { values.icon = […]