mirror of
https://github.com/moparisthebest/PhoneGap-SQLitePlugin-Android
synced 2024-12-01 12:42:16 -05:00
349 lines
8.9 KiB
JavaScript
349 lines
8.9 KiB
JavaScript
/*
|
|
* PhoneGap is available under *either* the terms of the modified BSD license *or* the
|
|
* MIT License (2008). See http://opensource.org/licenses/alphabetical for full text.
|
|
*
|
|
* Copyright (c) 2005-2010, Nitobi Software Inc.
|
|
* Copyright (c) 2010-2011, IBM Corporation
|
|
*/
|
|
|
|
/*
|
|
* This is purely for the Android 1.5/1.6 HTML 5 Storage
|
|
* I was hoping that Android 2.0 would deprecate this, but given the fact that
|
|
* most manufacturers ship with Android 1.5 and do not do OTA Updates, this is required
|
|
*/
|
|
|
|
|
|
// XXX TODO: use function() { ... } () to encapsulate these declarations (except for Java callback)
|
|
|
|
/**
|
|
* SQL result set object
|
|
* PRIVATE METHOD
|
|
* @constructor
|
|
*/
|
|
var DDB_Rows = function() {
|
|
this.resultSet = []; // results array
|
|
this.length = 0; // number of rows
|
|
};
|
|
|
|
/**
|
|
* Get item from SQL result set
|
|
*
|
|
* @param row The row number to return
|
|
* @return The row object
|
|
*/
|
|
DDB_Rows.prototype.item = function(row) {
|
|
return this.resultSet[row];
|
|
};
|
|
|
|
/**
|
|
* SQL result set that is returned to user.
|
|
* PRIVATE METHOD
|
|
* @constructor
|
|
*/
|
|
var DDB_Result = function() {
|
|
this.rows = new DDB_Rows();
|
|
};
|
|
|
|
/**
|
|
* Storage object that is called by native code when performing queries.
|
|
* PRIVATE METHOD
|
|
* @constructor
|
|
*/
|
|
var DDB = function() {
|
|
this.queryQueue = {};
|
|
};
|
|
|
|
/**
|
|
* Callback from native code when query is complete.
|
|
* PRIVATE METHOD
|
|
*
|
|
* @param id Query id
|
|
*/
|
|
DDB.prototype.completeQuery = function(id, data) {
|
|
var query = this.queryQueue[id];
|
|
if (query) {
|
|
try {
|
|
delete this.queryQueue[id];
|
|
|
|
// Get transaction
|
|
var tx = query.tx;
|
|
|
|
// If transaction hasn't failed
|
|
// Note: We ignore all query results if previous query
|
|
// in the same transaction failed.
|
|
if (tx && tx.queryList[id]) {
|
|
|
|
// Save query results
|
|
var r = new DDB_Result();
|
|
r.rows.resultSet = data;
|
|
r.rows.length = data.length;
|
|
if (!!data.length && data.length > 0 && !!data[0].insertId) {
|
|
r.insertId = data[0].insertId;
|
|
}
|
|
if (!!data.length && data.length > 0 && !!data[0].rowsAffected) {
|
|
r.rowsAffected = data[0].rowsAffected;
|
|
}
|
|
try {
|
|
if (typeof query.successCallback === 'function') {
|
|
query.successCallback(query.tx, r);
|
|
}
|
|
} catch (ex) {
|
|
console.log("executeSql error calling user success callback: "+ex);
|
|
}
|
|
|
|
tx.queryComplete(id);
|
|
}
|
|
} catch (e) {
|
|
console.log("executeSql error: "+e);
|
|
}
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Callback from native code when query fails
|
|
* PRIVATE METHOD
|
|
*
|
|
* @param reason Error message
|
|
* @param id Query id
|
|
*/
|
|
DDB.prototype.fail = function(reason, id) {
|
|
var query = this.queryQueue[id];
|
|
if (query) {
|
|
try {
|
|
delete this.queryQueue[id];
|
|
|
|
// Get transaction
|
|
var tx = query.tx;
|
|
|
|
// If transaction hasn't failed
|
|
// Note: We ignore all query results if previous query
|
|
// in the same transaction failed.
|
|
if (tx && tx.queryList[id]) {
|
|
tx.queryList = {};
|
|
|
|
try {
|
|
if (typeof query.errorCallback === 'function') {
|
|
query.errorCallback(query.tx, reason);
|
|
}
|
|
} catch (ex) {
|
|
console.log("executeSql error calling user error callback: "+ex);
|
|
}
|
|
|
|
tx.queryFailed(id, reason);
|
|
}
|
|
|
|
} catch (e) {
|
|
console.log("executeSql error: "+e);
|
|
}
|
|
}
|
|
};
|
|
|
|
var mycreateUUID = function() {
|
|
return myUUIDcreatePart(4) + '-' +
|
|
myUUIDcreatePart(2) + '-' +
|
|
myUUIDcreatePart(2) + '-' +
|
|
myUUIDcreatePart(2) + '-' +
|
|
myUUIDcreatePart(6);
|
|
};
|
|
|
|
myUUIDcreatePart = function(length) {
|
|
var uuidpart = "";
|
|
var i, uuidchar;
|
|
for (i=0; i<length; i++) {
|
|
uuidchar = parseInt((Math.random() * 256),0).toString(16);
|
|
if (uuidchar.length === 1) {
|
|
uuidchar = "0" + uuidchar;
|
|
}
|
|
uuidpart += uuidchar;
|
|
}
|
|
return uuidpart;
|
|
};
|
|
|
|
|
|
/**
|
|
* SQL query object
|
|
* PRIVATE METHOD
|
|
*
|
|
* @constructor
|
|
* @param tx The transaction object that this query belongs to
|
|
*/
|
|
var DDB_Query = function(tx) {
|
|
|
|
// Set the id of the query
|
|
this.id = mycreateUUID();
|
|
|
|
// Add this query to the queue
|
|
dddb.queryQueue[this.id] = this;
|
|
|
|
// Init result
|
|
this.resultSet = [];
|
|
|
|
// Set transaction that this query belongs to
|
|
this.tx = tx;
|
|
|
|
// Add this query to transaction list
|
|
this.tx.queryList[this.id] = this;
|
|
|
|
// Callbacks
|
|
this.successCallback = null;
|
|
this.errorCallback = null;
|
|
|
|
};
|
|
|
|
/**
|
|
* Transaction object
|
|
* PRIVATE METHOD
|
|
* @constructor
|
|
*/
|
|
var DDB_Tx = function() {
|
|
|
|
// Set the id of the transaction
|
|
this.id = mycreateUUID();
|
|
|
|
// Callbacks
|
|
this.successCallback = null;
|
|
this.errorCallback = null;
|
|
|
|
// Query list
|
|
this.queryList = {};
|
|
};
|
|
|
|
/**
|
|
* Mark query in transaction as complete.
|
|
* If all queries are complete, call the user's transaction success callback.
|
|
*
|
|
* @param id Query id
|
|
*/
|
|
DDB_Tx.prototype.queryComplete = function(id) {
|
|
delete this.queryList[id];
|
|
|
|
// If no more outstanding queries, then fire transaction success
|
|
if (this.successCallback) {
|
|
var count = 0;
|
|
var i;
|
|
for (i in this.queryList) {
|
|
if (this.queryList.hasOwnProperty(i)) {
|
|
count++;
|
|
}
|
|
}
|
|
if (count === 0) {
|
|
try {
|
|
this.successCallback();
|
|
} catch(e) {
|
|
console.log("Transaction error calling user success callback: " + e);
|
|
}
|
|
}
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Mark query in transaction as failed.
|
|
*
|
|
* @param id Query id
|
|
* @param reason Error message
|
|
*/
|
|
DDB_Tx.prototype.queryFailed = function(id, reason) {
|
|
|
|
// The sql queries in this transaction have already been run, since
|
|
// we really don't have a real transaction implemented in native code.
|
|
// However, the user callbacks for the remaining sql queries in transaction
|
|
// will not be called.
|
|
this.queryList = {};
|
|
|
|
if (this.errorCallback) {
|
|
try {
|
|
this.errorCallback(reason);
|
|
} catch(e) {
|
|
console.log("Transaction error calling user error callback: " + e);
|
|
}
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Execute SQL statement
|
|
*
|
|
* @param sql SQL statement to execute
|
|
* @param params Statement parameters
|
|
* @param successCallback Success callback
|
|
* @param errorCallback Error callback
|
|
*/
|
|
DDB_Tx.prototype.executeSql = function(sql, params, successCallback, errorCallback) {
|
|
|
|
// Init params array
|
|
if (typeof params === 'undefined') {
|
|
params = [];
|
|
}
|
|
|
|
// Create query and add to queue
|
|
var query = new DDB_Query(this);
|
|
dddb.queryQueue[query.id] = query;
|
|
|
|
// Save callbacks
|
|
query.successCallback = successCallback;
|
|
query.errorCallback = errorCallback;
|
|
|
|
// Call native code
|
|
PhoneGap.exec(null, null, "SQLitePlugin", "executeSql", [sql, params, query.id]);
|
|
};
|
|
|
|
var DatabaseShell = function() {
|
|
};
|
|
|
|
/**
|
|
* Start a transaction.
|
|
* Does not support rollback in event of failure.
|
|
*
|
|
* @param process {Function} The transaction function
|
|
* @param successCallback {Function}
|
|
* @param errorCallback {Function}
|
|
*/
|
|
DatabaseShell.prototype.transaction = function(process, errorCallback, successCallback) {
|
|
var tx = new DDB_Tx();
|
|
tx.successCallback = successCallback;
|
|
tx.errorCallback = errorCallback;
|
|
try {
|
|
process(tx);
|
|
} catch (e) {
|
|
console.log("Transaction error: "+e);
|
|
if (tx.errorCallback) {
|
|
try {
|
|
tx.errorCallback(e);
|
|
} catch (ex) {
|
|
console.log("Transaction error calling user error callback: "+e);
|
|
}
|
|
}
|
|
}
|
|
};
|
|
|
|
/**
|
|
* Open database
|
|
*
|
|
* @param name Database name
|
|
* @param version Database version
|
|
* @param display_name Database display name
|
|
* @param size Database size in bytes
|
|
* @return Database object
|
|
*/
|
|
var DDB_openDatabase = function(name, version, display_name, size) {
|
|
PhoneGap.exec(null, null, "SQLitePlugin", "openDatabase", [name, version, display_name, size]);
|
|
var db = new DatabaseShell();
|
|
return db;
|
|
};
|
|
|
|
/**
|
|
* For browsers with no localStorage we emulate it with SQLite. Follows the w3c api.
|
|
* TODO: Do similar for sessionStorage.
|
|
*/
|
|
|
|
/**
|
|
* @constructor
|
|
*/
|
|
|
|
window.sqlitePlugin = {
|
|
openDatabase: function(name, version, desc, size) {
|
|
window.dddb = new DDB();
|
|
return DDB_openDatabase(name, version, desc, size);
|
|
}
|
|
};
|
|
|