lisimba / ext.data.websqlproxy Goto Github PK

    removeRecord: function(record) {

        var me = this;
        var id = record.internalId || record[me.pkField] || record.data[me.pkField];

...
Ext.each(fields, function(f) {
            var name = f.name;
            if (name == me.pkField) { // added this
                return; // added this
            } // added this
            var type = f.type.type;
...

id = record.internalId || record[me.pkField] || record.data[me.pkField],

/*for (var i in modifiedData) {
    pairs.push('"'+i+'" = ?');
    values.push(newData[i]);
}*/
var fields = Object.keys(record.data);
for (var i=0; i<fields.length; i++) {
    var field = fields[i];
    if (key == field) {
        // Don't want to update primary key
        continue;
    }
    pairs.push(field + ' = ?');
    values.push(record.data[field]);
}
values.push(id);

    setRecord: function(record) {

        var me = this,
            rawData = record.data,
            fields = [],
            values = [],
            placeholders = [],
            onSuccess = function(tx,rs,record) {
                if (me.insertingInitialData) {
                    me.initialDataCount--;
                    if (me.initialDataCount === 0) {
                        me.insertingInitialData = false;
                        me.fireEvent('initialDataInserted');
                    }
                }

                // If record source did not have an id, then that means
                // the database just generated one. So we'll update the
                // record now.
                if(typeof record.get('id') == 'undefined'){
                    record.internalId = rs.insertId;
                    record.data.id = rs.insertId;
                }
            };

        //extract data to be inserted
        for (var i in rawData) {
            fields.push('"'+i+'"');
            values.push(rawData[i]);
            placeholders.push('?');
        }

        me.db.transaction(function(tx){
            tx.executeSql('INSERT INTO ' + me.dbTable+'('+fields.join(',')+') VALUES ('+placeholders.join(',')+')',
                values,
                Ext.bind(onSuccess, me, [record], true),  //on success
                Ext.bind(me.onError, me));        // on error
        });

        return true;
    },