-
Notifications
You must be signed in to change notification settings - Fork 0
Database client example
Fredrick Lusako Mwasekaga edited this page Aug 27, 2019
·
1 revision
function SqlConnection(host, user, pass){
if(DB != undefined && DB != null){
return DB.connection(host, user, pass, "sql");
}
return null;
}
function MySqlConnection(host, user, pass){
if(DB != undefined && DB != null){
return DB.connection(host, user, pass, "mysql");
}
return null;
}
function SqlLiteConnection(host, user, pass){
if(DB != undefined && DB != null){
return DB.connection(host, user, pass, "sqlite");
}
return null;
}
//Asynchronous
var con = new app.db.MySqlConnection("127.0.0.1;Port=3306","root","test123$");
if(con != null){
con.open();
con.changeDatabase("fake_database");
var cmd = con.createCommand("Selet * from fake_table where `fake_column` = @fake_colun");
if(cmd != null){
cmd.addParameter("@fake_colun", "Text", "bla bla bla");
var reader = comm.executeReader(function(readerID){
if(reader != null){
var _close = function(){
reader.close();
con.close();
console.log("completed");
};
var _loopBack = function(){
var row = JSON.parse(reader.getValues());
console.log(row);
if(reader.read())setTimeout(_loopBack,1);
else _close();
};
if(reader.read())setTimeout(_loopBack,1);
else _close();
});
}
else con.Close();
}
else con.close();
}
//synchronize
var con = new app.db.SqlConnection("127.0.0.1,1433","root","test123$");
if(con != null){
con.open();
con.changeDatabase("fake_database");
var cmd = con.createCommand("Selet * from fake_table where `fake_column` = @fake_colun");
if(cmd != null){
cmd.addParameter("@fake_colun", "Text", "bla bla bla");
var reader = comm.executeReader();
if(reader != null){
while(reader.read()){
var row = JSON.parse(reader.getValues());
console.log(row);
}
}
else reader.close();
con.close();
}
else con.close();
}