Tag: mysql

在nodejs中执行多个可靠的mysql查询: 我正在一个项目中，我必须为用户创build团队，但在此之前，我需要检查该团队名称是否已被同一用户占用。下面是示例代码 var mysql=require('../../config/mysql_connect.js'); var dateFormat = require('dateformat'); var functions={ createTeam:function(data,cb){ this.checkifExists(data,function(err,result){ if(err) { cb(err); } else { if(result.length) { cb(null,0); // Team name exists } else { mysql.getConnectionFromPool(function(err,con){ if(err) { cb(err); } else { var query=con.query("Insert into team SET ? ",data,function(err,result){ if(err) { cb(err); } else { cb(null,result.insertId); } con.release(); }); } }); } } […]

SQL右键连接到JSON /数组: 我试图将来自MySql right join的行数组转换成nodeJS上的array/json格式。考虑到通用的mysql表： emp_id name 1 john 2 bill 3 anna fk_emp_id project 1 p1 1 p2 1 p3 2 p1 2 p4 而他们正确的join： id name fk_emp_id project 1 john 1 p1 1 john 1 p2 1 john 1 p3 2 bill 2 p1 2 bill 2 p4 3 anna 3 null 这是： rows […]

MySQL与Sequelize：ER_BAD_DB_ERROR：未知的数据库: 我正在学习下面的代码： var Sequelize = require('sequelize') var sequelize = new Sequelize('basic-mysql-database.mysql', 'root', 'password', { 'dialect': 'mysql', 'host': "localhost", "port": "3306" }); var Todo = sequelize.define('todo', { description: { type: Sequelize.STRING }, completed: { type: Sequelize.BOOLEAN } }) sequelize.sync().then(function(){ console.log('Everything is synced') Todo.create({ description: 'Walking my dog', completed: false }).then(function (todo){ console.log('Finished!') console.log(todo) }) }); 我已经安装了MySQL。当我进入Settings […]

将类似JSON的数据转换为string，节点mysql: 快速编辑 – 我是一个完整的networking开发初学者，所以我意识到解决scheme可能是愚蠢的明显。我试图通过nodejs / expressjs / mysql将数据集插入MySQL数据库。我有一个成功的连接到数据库，并可以从中查询没有问题。这是我的邮编： app.post('/pyme', function(req,res){ console.log("Data being POSTED to db…"); var post = req.body; console.log(post); var sql_insert_pyme = 'INSERT INTO pyme(NombreComercio,NumeroTelefono) VALUES =?'; sql.query(sql_insert_pyme,post,function(err){ if(err) throw err; }); }); 我收到的POST数据如下所示： { NombreComercio: 'Sebastian Avila', NumeroTelefono: '71021714' } 我需要一个方法来打破这个post到一个简单的： "'Sebastian Avila', '71021714'" 基本上我想结束： post = "'Sebastian Avila', '71021714'"

节点mysql错误不被Promise拒绝: 我正在做一个简单的数据库调用包装在一个承诺，并试图捕捉错误，并通过它的承诺reject（），但拒绝不被处理或由呼叫代码冒泡备份。当mysql调用失败时，代码停止执行。 mysqlcallback中的错误是：拒绝QUERY {错误：您的SQL语法错误; 检查对应于您的MariaDB服务器版本的手册，在“？”附近使用正确的语法。在第1行这里是数据库查询代码： this.query = function(sql, params) { return new Promise((resolve, reject) => { _pool.query(sql, params, function(err, result) { if (err) { console.log("REJECTING QUERY", err); return reject(err); } resolve(result); }); }); } 这里是调用代码： this.createUser = function(data) { var query = "INSERT into users SET ?"; return new Promise((resolve, reject) => […]

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() }) } […]

NodeJS MySQL查询给出'未定义'的行: 我正在使用mysql和nodeJS并创build一个查询。我得到的查询行是'未定义'。这从来没有发生过我，我很难过。 // check if URL already exists in database connection.query("SELECT * FROM shorturl WHERE urlsource='?'", [url], function(error, rows, fields){ if (error) { console.log(error); } if (rows.length == 0) { console.log(rows); //prints 'undefined' insertURL(); } else { console.log("creating new entry"); printURL(); } });

Nodejs网站不显示第二个MySQL表值: 我有一个快速的网站，在MySQL中显示值。它显示新闻，但不显示事件。我确定事件表中有2个值。这里是我的index.js文件的路线： var express = require('express'); var router = express.Router(); var mysql = require('mysql'); //connection variables var connection = mysql.createConnection({ host: 'localhost', port: '3306', user: 'root', password: 'mypassword*', database: 'icomnodejs' }); connection.connect(); router.get('/', function (req, res, next) { connection.query('SELECT * FROM news', function (err, rows, fields) { if (err) throw err; res.render('index', { […]

ng-click不起作用，mysql中没有数据发布: 我一直在尝试通过Shiva Adhikari的教程“AngularJs，Node js，Express js，Bootstrap，EJS，MySQL的CRUD应用程序”学习，当时我意识到自己被困在教程的第5部分。我的问题在提交表单以创build产品类别时，浏览器控制台不执行任何操作。我是新来的，谢谢你的帮助。 app.js // Module Dependencies ============================================================================ var express = require('express'); // call express var app = express(); // define our app using express var routes = require('./routes'); var http = require('http'); var path = require('path'); //var methodOverride = require('method-override'); // simulate DELETE and PUT (express4) var bodyParser = require('body-parser'); […]

有没有更好的方法来监听节点JS中的表更改，而不使用setInterval（）函数: 我正在学习与Codeigniter Node JS集成。这个过程正在完善。我在数据库（MySql）发生某些更改时显示一些实时通知现在我正在使用setInterval()函数，时间为5秒。这将每5秒钟调用一次数据库查询。有没有更好的方式来监听没有setInterval()function的数据库更改？我的代码示例是 io.on('connection', function(socket){ setInterval(check_new_notification, 5000); }); socket.on('check_new_notification', function(user,time){ check_new_notification(user,time); }); function check_new_notification(user,time){ if(user == '' || typeof user == 'undefined' || user == null){ user = user_id; } if(time == '' || typeof time == 'undefined'){ time=0; } if(user != '' && typeof user != 'undefined' && […]