websql的使用/phonegap操作数据库 sqlite

对websql的常用操作进行了一个封装，项目是基于phonegap的，不过phonegap默认已经集成了数据库操作的插件，所以无需再配置什么，直接用就可以了：

/**

*数据库操作辅助类,定义对象、数据操作方法都在这里定义

*/

var dbname='mydb';

var version='1.1';

var dbdesc='mydb';

var table_picture='be_picture';

var dbsize=30000;

var db=null;

/**

 * 打开数据库

 * @returns {Boolean}

 */

function openDB(callback){

	try{

		 if (!window.openDatabase) {

             console.log('该浏览器不支持数据库');

             return false;

         }

		db = window.openDatabase(dbname, version, dbdesc, dbsize);

		return true;

	}catch(e){

		if(e==2){

			console.log("数据库版本无效");

		}else{

			console.log("未知错误 "+e+".");

		}

		return false;

	}

}

/**

 * 执行一段sql

 * @param sql

 */

function execSql(sql,param,callback){

	if(db==null){openDB();}

	db.transaction(function(tx) {

		tx.executeSql(sql,param, function(tx, result) {

			if(typeof(callback) == 'function') {callback(true)}

			return true;

		}, function(tx, error) {

			if(typeof(callback) == 'function') {callback(false)}

			console.log(error);

			return false;

		});

	});

}

var pictureFields=[

   'id',

   'app_flow_no',

   'ptr_type',

   'ptr_name',

   'ptr_address',

   'blurred',

   'original',

   'local_address'

  ]

/**

 * 初始化数据库

 */

function initDB(){

	if(db==null){openDB();}

	createTable(table_picture,pictureFields,{"id":"primary key","app_flow_no":"not null"});

}

/**

 * 创建数据库

 * @param tableName		表名称

 * @param fields		表字段

 * @param constraint	约束或者字段的其他补充，可以为空,

 * 	格式如：{"id":"integer primary key autoincrement","app_flow_no":"not null"}

 */

function createTable(tableName,fields,constraint){

	if(db==null){openDB();}

	var sql = 'CREATE TABLE IF NOT EXISTS '+tableName+' (';

	for(i in fields){

		var key = "";

		if(typeof(constraint)!="undefined" && typeof(constraint[fields[i]]) !="undefined"){

			key = " "+constraint[fields[i]];

		}

		sql+=fields[i]+key+",";

	}

	sql = sql.substr(0,sql.length-1);

	sql += ")";

	//log(sql);

	execSql(sql);

}

/**

 * 更新数据

 * @param tableName	表名称

 * @param setFields	要更新的字段数组

 * @param setParams	要更新的字段对应的参数数组

 * @param whereStr	where语句，如果没有可不传，不包含where关键字，参数用?代替，如：id=? and name=?

 * @param wherParams	where语句用到的参数数组,如['111','2222']

 */

function updateTable(tableName,setFields,setParams,whereStr,wherParams){

	var sql = "update "+tableName+" set ";

	for(i in setFields){

		sql+=setFields[i]+"=?,";

	}

	sql = sql.substr(0,sql.length-1);

	if(typeof(whereStr)!="undefined" && typeof(wherParams)!="undefined"

		&& whereStr!=""){

		sql += " where " + whereStr;

		setParams = setParams.concat(wherParams);

	}

	execSql(sql,setParams);

}

/**

 * 插入数据

 * @param tableName

 * @param insertFields

 * @param insertParams

 */

function insertTable(tableName,insertFields,insertParams){

	var sql = "insert into "+tableName+" (";

	var sql2 = " values(";

	for(i in insertFields){

		sql+=insertFields[i]+",";

		sql2 +="?,"

	}

	sql = sql.substr(0,sql.length-1);

	sql2 = sql2.substr(0,sql2.length-1);

	sql += ")";

	sql2 +=  ")";

	execSql(sql+sql2,insertParams);

}

/**

 * 删除数据

 * @param tableName

 * @param whereStr

 * @param wherParams

 */

function deleteRow(tableName,whereStr,wherParams){

	var sql = "delete from "+tableName;

	if(typeof(whereStr)!="undefined" && typeof(wherParams)!="undefined"

		&& whereStr!=""){

		sql += " where " + whereStr;

	}

	execSql(sql,wherParams);

}	

/**

 * 查询

 * @param tableName

 * @param selectFields	select的字段，用逗号分开，如果全部传"*"

 * @param whereStr		where语句，参数用?代替

 * @param wherParams	参数数组

 * @callback 必填，返回的对象会放在callback函数作为参数传递

 */

function select(tableName,selectFields,whereStr,wherParams,callback){

	if(db==null){openDB();}

	var sql = "SELECT "+selectFields+" FROM "+tableName;

	if(typeof(whereStr)!="undefined" && typeof(wherParams)!="undefined"

		&& whereStr!=""){

		sql += " where " + whereStr;

	}

	 db.transaction(function(tx){

          tx.executeSql(sql,wherParams,function(tx,results){

        	  if(results.rows.length<1){

        		  if (typeof(callback) == 'function') {callback(false)} //没有数据

        	  }else{

              	  if(typeof(callback) == 'function') {callback(results.rows)}

        	  }

          },function(tx,error){

              return false;

          });

      });

}

/**

 * 插入或更新

 * @param tableName

 * @param insertFields

 * @param insertParams

 * @param key			根据该key来判断是否有数据

 * @param keyVal

 */

function saveOrUpdate(tableName,insertFields,insertParams,key,keyVal){

	if(typeof(key)!="undefined" && typeof(keyVal)!="undefined"

		&& key!=""){

		select(tableName,insertFields[0],key+"=?",[keyVal],function(rows){

			if(rows){

				updateTable(tableName,insertFields,insertParams,key+"=?",[keyVal]);

			}else{

				insertFields.push(key);

				insertParams.push(keyVal);

				insertTable(tableName,insertFields,insertParams);

			}

		})

	}else{

		insertTable(tableName,insertFields,insertParams);

	}

}

查询：

	select(table_picture,"*","id=?",[id],function(rows){

		if(rows){

			//如果查询到数据

		}

	})

注意：因为websql是异步执行的，要获取到返回的结果然后进一步操作，需要传入回调函数，如上面的function(rows)....

插入或者更新：

saveOrUpdate(table_picture,['id','app_flow_no','original','ptr_type','ptr_name'],[pic.id,pic.appFlowNo,pic.original,pic.ptrType,pic.ptrName],'id',pic.id);

删除：

deleteRow(table_picture,"id=?",[123])

转自：http://blog.csdn.net/linshutao/article/details/21398483

巴特西

websql的使用/phonegap操作数据库 sqlite

最新文章

热门文章