dbconn.user.query('INSERT INTO verification SET ?',verificationData,function(err,results,fields){
if(err){
returndbconn.user.rollback(function(){
throwerr
});
}
});
// COMMIT
dbconn.user.commit(function(err){
if(err){
returndbconn.user.rollback(function(){
throwerr
})
}
})
})
})
});
});
...
...
@@ -57,7 +69,7 @@ var methods = {
})
},
getUserByEmail:function(email,callback){
dbconn.user.query('SELECT salutation, title, firstname, lastname, industry, organisation, speciality FROM user WHERE email = "'+email+'"',function(err,rows,fields){
dbconn.user.query('SELECT verificationStatus, salutation, title, firstname, lastname, industry, organisation, speciality FROM user WHERE email = "'+email+'"',function(err,rows,fields){
if(err){
throwerr;
}
...
...
@@ -70,7 +82,7 @@ var methods = {
});
},
checkUserEmail:function(email,callback){
varuser;
letuser
dbconn.user.query('SELECT id, email FROM user WHERE email = "'+email+'"',function(err,rows,fields){
if(err){
throwerr;
...
...
@@ -84,7 +96,7 @@ var methods = {
});
},
getUserByToken:function(token,callback){
varuser;
letuser
dbconn.user.query('SELECT t1.user_id, t2.email FROM userdb.credential AS t1 INNER JOIN userdb.user AS t2 ON t1.user_id = t2.id AND t1.resetPasswordToken = "'
+token+'" and resetPasswordExpires > '+Date.now(),function(err,rows,fields){
if(err){
...
...
@@ -100,42 +112,92 @@ var methods = {
}
);
},
updateUser:function(userData,callback){
dbconn.user.query('UPDATE user SET ? WHERE email = "'+userData.email+'"',userData,function(err,rows,fields){
if(err)throwerr;
callback(err);
updateUserById:function(userData,callback){
dbconn.user.query('UPDATE user SET ? WHERE id = '+userData.id,userData,function(err,rows,fields){
if(err)throwerr
callback(err)
})
},
updateCredential:function(data,callback){
dbconn.user.query('UPDATE credential SET ? WHERE user_id = '+data.user_id,data,function(err,rows,fields){
if(err)throwerr;
callback(err);
if(err)throwerr
callback(err)
})
},
getUserIdByEmail:function(email,callback){
varuserId
letuserId
dbconn.user.query('SELECT id FROM user WHERE email = "'+email+'"',function(err,rows,fields){
if(err){
throwerr;
throwerr
}
else{
if(rows.length>0){
userId=rows[0].id;
userId=rows[0].id
}
}
callback(userId,err);
callback(userId,err)
});
},
getUserProjectRole:function(userId,callback){
dbconn.user.query('SELECT project_id, role_id FROM user_project_role WHERE user_id = "'+userId+'"',function(err,rows,fields){
if(err)throwerr;
callback(rows,err);
if(err)throwerr
callback(rows,err)
});
},
addUserProjectRole:function(data,callback){
dbconn.user.query('INSERT INTO user_project_role SET ?',data,function(err,results,fields){