examples/tasks/db/ext-db.js

   1 /*!
   2  * Ext JS Library 3.1.0
   3  * Copyright(c) 2006-2009 Ext JS, LLC
   4  * licensing@extjs.com
   5  * http://www.extjs.com/license
   6  */
   7 \r
   8 // Asbtract base class for SqlDB classes\r
   9 Ext.data.SqlDB = function(config){\r
  10         Ext.apply(this, config);\r
  11         Ext.data.SqlDB.superclass.constructor.call(this);\r
  12 \r
  13         this.addEvents({\r
  14                 open : true,\r
  15                 close: true\r
  16         });\r
  17 };\r
  18 \r
  19 Ext.extend(Ext.data.SqlDB, Ext.util.Observable, {\r
  20         maxResults: 10000,\r
  21         openState : false,\r
  22 \r
  23     // abstract methods\r
  24     open : function(file, cb, scope){\r
  25         },\r
  26 \r
  27         close : function(){\r
  28         },\r
  29 \r
  30     exec : function(sql, cb, scope){\r
  31         },\r
  32 \r
  33         execBy : function(sql, args, cb, scope){\r
  34         },\r
  35 \r
  36         query : function(sql, cb, scope){\r
  37         },\r
  38 \r
  39         queryBy : function(sql, args, cb, scope){\r
  40         },\r
  41 \r
  42     // protected/inherited method\r
  43     isOpen : function(){\r
  44                 return this.openState;\r
  45         },\r
  46 \r
  47         getTable : function(name, keyName){\r
  48                 return new Ext.data.SqlDB.Table(this, name, keyName);\r
  49         },\r
  50 \r
  51         createTable : function(o){\r
  52                 var tableName = o.name;\r
  53                 var keyName = o.key;\r
  54                 var fs = o.fields;\r
  55                 var cb = o.callback;\r
  56                 var scope = o.scope;\r
  57                 if(!(fs instanceof Array)){ // Ext fields collection\r
  58                         fs = fs.items;\r
  59                 }\r
  60                 var buf = [];\r
  61                 for(var i = 0, len = fs.length; i < len; i++){\r
  62                         var f = fs[i], s = f.name;\r
  63                         switch(f.type){\r
  64                     case "int":\r
  65                     case "bool":\r
  66                     case "boolean":\r
  67                         s += ' INTEGER';\r
  68                         break;\r
  69                     case "float":\r
  70                         s += ' REAL';\r
  71                         break;\r
  72                     default:\r
  73                         s += ' TEXT';\r
  74                 }\r
  75                 if(f.allowNull === false || f.name == keyName){\r
  76                         s += ' NOT NULL';\r
  77                 }\r
  78                 if(f.name == keyName){\r
  79                         s += ' PRIMARY KEY';\r
  80                 }\r
  81                 if(f.unique === true){\r
  82                         s += ' UNIQUE';\r
  83                 }\r
  84 \r
  85                 buf[buf.length] = s;\r
  86             }\r
  87             var sql = ['CREATE TABLE IF NOT EXISTS ', tableName, ' (', buf.join(','), ')'].join('');\r
  88         this.exec(sql, cb, scope);\r
  89         }\r
  90 });\r
  91 \r
  92 \r
  93 Ext.data.SqlDB.getInstance = function(db, config){\r
  94     if(window.htmlControl){ // air\r
  95         return new Ext.data.AirDB(config);\r
  96     } else { // gears\r
  97         return new Ext.data.GearsDB(config);\r
  98     }\r
  99 };\r
 100 \r
 101 \r
 102 Ext.data.SqlDB.Table = function(conn, name, keyName){\r
 103         this.conn = conn;\r
 104         this.name = name;\r
 105         this.keyName = keyName;\r
 106 };\r
 107 \r
 108 Ext.data.SqlDB.Table.prototype = {\r
 109         update : function(o, cb, scope){\r
 110                 var clause = this.keyName + " = :" + this.keyName;\r
 111                 this.updateBy(o, clause, {}, cb, scope);\r
 112         },\r
 113 \r
 114         updateBy : function(o, clause, args, cb, scope){\r
 115                 var sql = "UPDATE " + this.name + " set ";\r
 116                 var fs = [], a = [];\r
 117                 for(var key in o){\r
 118                         if(o.hasOwnProperty(key)){\r
 119                                 fs[fs.length] = key + ' = ?';\r
 120                                 a[a.length] = o[key];\r
 121                         }\r
 122                 }\r
 123                 for(var key in args){\r
 124                         if(args.hasOwnProperty(key)){\r
 125                                 a[a.length] = args[key];\r
 126                         }\r
 127                 }\r
 128                 sql = [sql, fs.join(','), ' WHERE ', clause].join('');\r
 129                 this.conn.execBy(sql, a, cb, scope);\r
 130         },\r
 131 \r
 132         insert : function(o, cb, scope){\r
 133                 var sql = "INSERT into " + this.name + " ";\r
 134                 var fs = [], vs = [], a = [];\r
 135                 for(var key in o){\r
 136                         if(o.hasOwnProperty(key)){\r
 137                                 fs[fs.length] = key;\r
 138                                 vs[vs.length] = '?';\r
 139                                 a[a.length] = o[key];\r
 140                         }\r
 141                 }\r
 142                 sql = [sql, '(', fs.join(','), ') VALUES (', vs.join(','), ')'].join('');\r
 143         this.conn.execBy(sql, a, cb, scope);\r
 144     },\r
 145 \r
 146         select : function(clause, cb, scope){\r
 147                 this.selectBy(clause, null, cb, scope);\r
 148         },\r
 149 \r
 150         selectBy : function(clause, args, cb, scope){\r
 151                 var sql = "select * from " + this.name;\r
 152                 if(clause){\r
 153                         sql += ' ' + clause;\r
 154                 }\r
 155                 args = args || {};\r
 156                 this.conn.queryBy(sql, args, cb, scope);\r
 157         },\r
 158 \r
 159         remove : function(clause, cb, scope){\r
 160                 this.deleteBy(clause, null, cb, scope);\r
 161         },\r
 162 \r
 163         removeBy : function(clause, args, cb, scope){\r
 164                 var sql = "delete from " + this.name;\r
 165                 if(clause){\r
 166                         sql += ' where ' + clause;\r
 167                 }\r
 168                 args = args || {};\r
 169                 this.conn.execBy(sql, args, cb, scope);\r
 170         }\r
 171 };\r
 172 \r
 173 Ext.data.SqlDB.Proxy = function(conn, table, keyName, store){\r
 174     Ext.data.SqlDB.Proxy.superclass.constructor.call(this);\r
 175     this.conn = conn;\r
 176     this.table = this.conn.getTable(table, keyName);\r
 177     this.store = store;\r
 178 \r
 179     this.store.on('add', this.onAdd, this);\r
 180     this.store.on('update', this.onUpdate, this);\r
 181     this.store.on('remove', this.onRemove, this);\r
 182 };\r
 183 \r
 184 Ext.extend(Ext.data.SqlDB.Proxy, Ext.data.DataProxy, {\r
 185     load : function(params, reader, callback, scope, arg){\r
 186         if(!this.conn.isOpen()){ // assume that the connection is in the process of opening\r
 187                 this.conn.on('open', function(){\r
 188                         this.load(params, reader, callback, scope, arg);\r
 189                 }, this, {single:true});\r
 190                 return;\r
 191         };\r
 192         if(this.fireEvent("beforeload", this, params, reader, callback, scope, arg) !== false){\r
 193                         var clause = params.where || '';\r
 194                         var args = params.args || [];\r
 195                         var group = params.groupBy;\r
 196                         var sort = params.sort;\r
 197                         var dir = params.dir;\r
 198 \r
 199                         if(group || sort){\r
 200                                 clause += ' ORDER BY ';\r
 201                                 if(group && group != sort){\r
 202                                         clause += group + ' ASC, ';\r
 203                                 }\r
 204                                 clause += sort + ' ' + (dir || 'ASC');\r
 205                         }\r
 206 \r
 207                         this.table.selectBy(clause, args,\r
 208                                         this.onLoad.createDelegate(this, [{callback:callback, scope:scope, arg:arg, reader: reader}], 0));\r
 209         }else{\r
 210             callback.call(scope||this, null, arg, false);\r
 211         }\r
 212     },\r
 213 \r
 214     onLoad : function(trans, rs, e, stmt){\r
 215         if(rs === false){\r
 216                 this.fireEvent("loadexception", this, null, trans.arg, e);\r
 217             trans.callback.call(trans.scope||window, null, trans.arg, false);\r
 218             return;\r
 219         }\r
 220         var result = trans.reader.readRecords(rs);\r
 221         this.fireEvent("load", this, rs, trans.arg);\r
 222         trans.callback.call(trans.scope||window, result, trans.arg, true);\r
 223     },\r
 224 \r
 225     processData : function(o){\r
 226         var fs = this.store.fields;\r
 227         var r = {};\r
 228         for(var key in o){\r
 229                 var f = fs.key(key), v = o[key];\r
 230                         if(f){\r
 231                                 if(f.type == 'date'){\r
 232                                         r[key] = v ? v.format('Y-m-d H:i:s') : '';\r
 233                                 }else if(f.type == 'boolean'){\r
 234                                         r[key] = v ? 1 : 0;\r
 235                                 }else{\r
 236                                         r[key] = v;\r
 237                                 }\r
 238                         }\r
 239                 }\r
 240                 return r;\r
 241     },\r
 242 \r
 243     onUpdate : function(ds, record){\r
 244         var changes = record.getChanges();\r
 245         var kn = this.table.keyName;\r
 246         this.table.updateBy(this.processData(changes), kn + ' = ?', [record.data[kn]]);\r
 247         record.commit(true);\r
 248     },\r
 249 \r
 250     onAdd : function(ds, records, index){\r
 251         for(var i = 0, len = records.length; i < len; i++){\r
 252                 this.table.insert(this.processData(records[i].data));\r
 253         }\r
 254     },\r
 255 \r
 256     onRemove : function(ds, record, index){\r
 257         var kn = this.table.keyName;\r
 258         this.table.removeBy(kn + ' = ?', [record.data[kn]]);\r
 259     }\r
 260 });