[转]html5 js 访问 sqlite 数据库的操作类

2022-11-08 13:41:55

本文转自：http://blog.csdn.net/tsxw24/article/details/7613815

webkit 核心的浏览器提供了 3个 api接口，用于访问本地sqlite数据，但使用起来很不方便 故而做这个js封装，以方便使用

参考文章：

sqlite API 说明

http://www.mhtml5.com/resources/html5-js-api%E6%95%99%E7%A8%8B%EF%BC%88%E4%B8%89%EF%BC%89-%E6%9C%AC%E5%9C%B0%E6%95%B0%E6%8D%AE%E5%BA%93

另外的操作类

http://levi.cg.am/?p=1679

sqlite 语法

http://blog.csdn.net/ejzhang/article/details/6224915

  1. /**
  2. * js 操作数据库类
  3. *
  4. * @author 肖武<phpxiaowu@gmail.com>
  5. */
  6. /**
  7. * 1、数据库名（mydb）
  8. 2、版本号（1.0）
  9. 3、描述（Test DB）
  10. 4、数据库大小（2*1024*1024）
  11. */
  12. var DB = function( db_name, size ){
  13. var _db = openDatabase(db_name, '1.0.0','', size );
  14. return {
  15. /**
  16. * 执行sql，回调返回影响条数
  17. */
  18. execute:function( sql, param, callback ) {
  19. //参数处理
  20. if( !param ){
  21. param = [];
  22. }else if(typeof param == 'function' ){
  23. callback = param;
  24. param = [];
  25. }
  26. this.query( sql, param, function(result){
  27. if( typeof callback == 'function' ){
  28. callback(result.rowsAffected);
  29. }
  30. });
  31. },
  32. /**
  33. * 执行sql，回调返回sql查询对象
  34. * 查询时，有数据返回数组，无数据返回0
  35. * 增删改时：返回int，影响条数
  36. * void query( string[, function])
  37. * void query( string[, array[, function]])
  38. */
  39. query:function(sql, param, callback){
  40. //参数处理
  41. if( !param ){
  42. param = [];
  43. }else if(typeof param == 'function' ){
  44. callback = param;
  45. param = [];
  46. }
  47. var self=this;
  48. //只有一个参数
  49. _db.transaction(function (tx) {
  50. //4个参数：sql，替换sql中问号的数组，成功回调，出错回调
  51. tx.executeSql(sql,param,function(tx,result){
  52. if (typeof callback == 'function' ){
  53. callback(result);
  54. }
  55. },self.onfail) ;
  56. })
  57. },
  58. /**
  59. * 插入，回调返回last id
  60. * void insert( string, object[, function])
  61. */
  62. insert:function( table, data, callback ){
  63. if( typeof data != 'object' && typeof callback == 'function' ){
  64. callback(0);
  65. }
  66. var k=[];
  67. var v=[];
  68. var param=[];
  69. for(var i in data ){
  70. k.push(i);
  71. v.push('?');
  72. param.push(data[i]);
  73. }
  74. var sql="INSERT INTO "+table+"("+k.join(',')+")VALUES("+v.join(',')+")";
  75. this.query(sql, param, function(result){
  76. if ( typeof callback == 'function' ){
  77. callback(result.insertId);
  78. }
  79. });
  80. },
  81. /**
  82. * 修改，回调返回影响条数
  83. * void update( string, object[, string[, function]])
  84. * void update( string, object[, string[, array[, function]]])
  85. */
  86. update:function( table, data, where, param, callback ){
  87. //参数处理
  88. if( !param ){
  89. param = [];
  90. }else if(typeof param == 'function' ){
  91. callback = param;
  92. param = [];
  93. }
  94. var set_info = this.mkWhere(data);
  95. for(var i=set_info.param.length-1;i>=0; i--){
  96. param.unshift(set_info.param[i]);
  97. }
  98. var sql = "UPDATE "+table+" SET "+set_info.sql;
  99. if( where ){
  100. sql += " WHERE "+where;
  101. }
  102. this.query(sql, param, function(result){
  103. if( typeof callback == 'function' ){
  104. callback(result.rowsAffected);
  105. }
  106. });
  107. },
  108. /**
  109. * 删除
  110. * void toDelete( string, string[, function]])
  111. * void toDelete( string, string[, array[, function]])
  112. */
  113. toDelete:function( table, where, param, callback ){
  114. //参数处理
  115. if( !param ){
  116. param = [];
  117. }else if(typeof param == 'function' ){
  118. callback = param;
  119. param = [];
  120. }
  121. var sql = "DELETE FROM "+table+" WHERE "+where;
  122. this.query(sql, param, function(result){
  123. if( typeof callback == 'function' ){
  124. callback(result.rowsAffected);
  125. }
  126. });
  127. },
  128. /**
  129. * 查询，回调返回结果集数组
  130. * void fetch_all( string[, function] )
  131. * void fetch_all( string[, param[, function]] )
  132. */
  133. fetchAll:function( sql, param, callback ){
  134. //参数处理
  135. if( !param ){
  136. param = [];
  137. }else if(typeof param == 'function' ){
  138. callback = param;
  139. param = [];
  140. }
  141. this.query( sql, param, function(result){
  142. if (typeof callback == 'function' ){
  143. var out=[];
  144. if (result.rows.length){
  145. for (var i=0;i<result.rows.length;i++){
  146. out.push(result.rows.item(i));
  147. }
  148. }
  149. callback(out);
  150. }
  151. });
  152. },
  153. /**
  154. * 查询表的信息
  155. * table_name: 表名称，支持 % *，
  156. */
  157. showTables:function( table_name, callback){
  158. this.fetchAll("select * from sqlite_master where type='table' and name like ?", [table_name], callback);
  159. },
  160. /**
  161. * 组装查询条件
  162. */
  163. mkWhere:function(data){
  164. var arr=[];
  165. var param=[];
  166. if( typeof data === 'object' ){
  167. for (var i in data){
  168. arr.push(i+"=?");
  169. param.push(data[i]);
  170. console.log('data.i:'+i);
  171. }
  172. }
  173. return {sql:arr.join(' AND '),param:param};
  174. },
  175. /**
  176. * 错误处理
  177. */
  178. onfail:function(tx,e){
  179. console.log('sql error: '+e.message);
  180. }
  181. }
  182. }
  183. /*
  184. //使用示例：
  185. //1.获取db对象,连接数据库 test，分配2M大小
  186. var db = new DB('test',1024*1024*2);
  187. //2.创建表
  188. d.query("CREATE TABLE ids (id integer primary key autoincrement , ctime integer)");
  189. //3.查看已经创建的表，支持表名通配符搜索。如："%"查询所有表，"user_%"查询"user_"开头的表
  190. db.showTables("%",function(ret){console.log(ret)})
  191. //4.查询表里数据
  192. db.fetchAll('select * from ids',function(ret){console.log(ret)});
  193. //5.修改
  194. db.update('ids',{ctime:123},"id=?",[1],function(ret){console.log(ret)});
  195. //6.删除
  196. db.toDelete('ids',"id=?",[1],function(ret){console.log(ret)});
  197. //7.其它，如删表
  198. db.query('drop table ids');
  199. */
上一篇：fastCMS数据库相关操作类


下一篇：换掉Tomcat默认图标