94 lines
2.6 KiB
JavaScript
94 lines
2.6 KiB
JavaScript
///////////////////////////////////////////////////
|
||
///////////// cls_mysql: 数据库操作 ///////////////
|
||
///////////////////////////////////////////////////
|
||
var cls_mysql = cls_mysql || {
|
||
|
||
//构造函数
|
||
new: function(url, func_fail_sendpack){
|
||
var mysql = {};
|
||
//php地址
|
||
mysql.url = url;
|
||
//发生错误时的回包函数
|
||
mysql.func_fail_sendpack = func_fail_sendpack;
|
||
|
||
//执行sql语句
|
||
mysql.execsql = function(method, sql, para, func_succ, pack) {
|
||
/*
|
||
method: php方法名 execsql/opensql
|
||
sql: 要执行的sql语句
|
||
para: 要执行的sql语句的参数数组
|
||
func_succ: sql语句执行成功后的回调函数
|
||
pack: 客户端发来的数据包，执行失败的话会根据pack返回客户端执行失败的结果
|
||
*/
|
||
var data = {}
|
||
data.m = method;
|
||
data.s = sql;
|
||
data.p = para;
|
||
|
||
var strdata = JSON.stringify(data);
|
||
//将=号替换为^，php收到后再替换回来，以避免=号POST传参会截断的问题
|
||
strdata = strdata.replace(/\=/g,"^");
|
||
//将+号替换为#，php收到后再替换回来，以避免+号POST传参会截断的问题
|
||
strdata = strdata.replace(/\+/g,"#");
|
||
//将&号替换为!，php收到后再替换回来，以避免&号POST传参会截断的问题
|
||
strdata = strdata.replace(/\&/g,"!");
|
||
|
||
var cfg = {};
|
||
cfg.url = mysql.url;
|
||
cfg.data = "data=" + strdata;
|
||
cfg.type = "POST";
|
||
cfg.success = function(str) {
|
||
try {
|
||
var result = JSON.parse(str);
|
||
} catch(e) {
|
||
console.log(min_now() + " 数据库执行结果转换json失败.");
|
||
console.log(str);
|
||
console.log(data);
|
||
return;
|
||
}
|
||
|
||
if (result.state != 0) {
|
||
console.log(min_now() + " 请求" + mysql.url + "失败.");
|
||
console.log(result);
|
||
console.log(data);
|
||
|
||
if (pack) {
|
||
console.log(JSON.stringify(pack));
|
||
//返回客户端执行失败的结果
|
||
if (mysql.func_fail_sendpack) {
|
||
pack.data = {};
|
||
pack.data.state = result.state;
|
||
pack.data.error = result.error;
|
||
mysql.func_fail_sendpack(pack);
|
||
}
|
||
}
|
||
} else {
|
||
//执行sql成功执行回调函数
|
||
// console.log(result);
|
||
if (func_succ) {
|
||
func_succ(result.data);
|
||
}
|
||
}
|
||
};
|
||
cfg.error = function(str){
|
||
console.log(min_now() + " 请求" + mysql.url + "失败.");
|
||
console.log(str);
|
||
console.log(data);
|
||
|
||
if (pack) {
|
||
console.log(JSON.stringify(pack));
|
||
//返回客户端执行失败的结果
|
||
if (mysql.func_fail_sendpack) {
|
||
pack.data = {};
|
||
pack.data.state = 99;
|
||
pack.data.error = "请求数据库失败.";
|
||
mysql.func_fail_sendpack(pack);
|
||
}
|
||
}
|
||
};
|
||
min_http(cfg);
|
||
}
|
||
return mysql;
|
||
}
|
||
}
|