我对 nodejs、knex、bookshelf 等还很陌生,目前正在开发一个 Web 应用程序,该应用程序将根据登录的用户连接到不同的 mysql 数据库。
第一个连接工作正常,然后我注销并在注销代码中执行 knex.destroy()。
当我重新登录时,我得到一个
未处理的拒绝错误:当前客户端上没有定义池
似乎 knex 不会重新创建一个池,一旦它被销毁,即使它被重新初始化。
有没有人试过这个并且知道怎么做?
我尝试在没有数据库的情况下进行初始化,并在用户登录时添加一个,但连接似乎并没有连接到数据库。我尝试在不破坏以前的情况下实例化与数据库的新连接,这导致用户使用第一个用户的数据库。销毁连接会删除 MySQL 连接,甚至会与正确的数据库建立新连接,但显然没有池。
从阅读来看,knex 似乎不是为执行此操作而设计的,但肯定有一种方法可以实例化与新池的新连接?
我正在使用本地护照 代码片段如下
passport.use(new LocalStrategy({
usernameField: 'email',
passwordField: 'password'
},
function(email, password, done) {
new userModel.User({email: email}).fetch().then(function(data) {
var user = data;
if(user === null) {
return done(null, false, {message: 'Invalid username or password'});
} else {
user = data.toJSON();
if(!bcrypt.compareSync(password, user.password)) {
return done(null, false, {message: 'Invalid username or password'});
} else {
ctrl = new DB();
ctrl.connect(user.db);
dbModel = require('../server/models/dbModel');
return done(null, user);
}
}
});
}));
DB.js
function DB(){
}
DB.prototype.connect = function (db){
if (db !== "crm" && db !== null){
db = "crm-" + db;
}
DB.knex = require('knex')({
client: 'mysql',
connection:{
host: 'localhost', // your host
user: MYSQL_USR, // your database user
password: MYSQL_PWD, // your database password
database: db,
charset: 'UTF8_GENERAL_CI' //,
// debug : true
}
});
DB.bookshelf = require('bookshelf')(DB.knex);
};
DB.prototype.destroy = function (){
DB.knex.destroy().then(console.log("destroyed"));
};
module.exports = DB;
请帮忙! 让我知道您可能还需要什么其他代码。
有没有人这样做过,如果有,怎么做?拜托,我还没有或找到任何答案。
最佳答案
我不确定这是否有帮助,但我得到了这个精简版的工作。我对 knex 不是很熟悉,但我创建了两个非常简单的数据库,并且能够连接到这两个数据库并获得简单的输出。
index.js
var DB = require('./DB');
function userConnect(db_name){
var db = new DB();
var knex = db.connect(db_name);
knex.select('color').from('test').then(function(result){
console.log(result);
knex.destroy();
});
}
userConnect('db_one');
userConnect('db_two');
DB.js
function DB(){
}
DB.prototype.connect = function (db){
return require('knex')({
client: 'mysql',
connection:{
host: MYSQL_HOST, // your host
user: MYSQL_USER, // your database user
password: MYSQL_PASSWORD, // your database password
database: db
}
});
};
module.exports = DB;
关于node.js - 尝试使用 node.js 和 mysql 连接到每个用户的不同数据库 - 最好使用池,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31084425/