taffydb4ti.js

/*
TAFFYDB4TI LICENSE SECTION

As long as you respect the below license I don;t care what you do with the code.
Just have fun :)


==============================================================================================================================
TITAFFYDB LICENSE SECTION

Project Name : TiTaffyDb
Ti Hacker: Ben Bahrenburg ( twitter @benCoding)
About: This project is a Titanium Port of the TaffyDb created by Ian Smit ( twitter @mriansmith) project available at taffydb.com 
To make TaffyDb more Titanium friendly several updates have been made, please check the readme for details.


==============================================================================================================================
TAFFYDB LICENSE SECTION

 Software License Agreement (BSD License)
 http://taffydb.com
 Copyright (c)
 All rights reserved.


 Redistribution and use of this software in source and binary forms, with or without modification, are permitted provided that the following condition is met:

 * Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer.

 THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

==============================================================================================================================
 */

/*jslint        browser : true, continue : true,
 devel  : true, indent  : 2,    maxerr   : 500,
 newcap : true, nomen   : true, plusplus : true,
 regexp : true, sloppy  : true, vars     : false,
 white  : true
*/

// BUILD 193d48d, modified by mmikowski to pass jslint
// Setup TAFFY name space to return an object with methods
var TAFFY, exports, T;
(function() {
	'use strict';
	var
	typeList, makeTest, idx, typeKey, version, TC, idpad, cmax, API, protectJSON, each, eachin, isIndexable, returnFilter, runFilters, numcharsplit, orderByCol, run;

	if (!TAFFY) {
		// TC = Counter for Taffy DBs on page, used for unique IDs
		// cmax = size of charnumarray conversion cache
		// idpad = zeros to pad record IDs with
		version = '2.6.2'; // proposed mmikowski 2012-08-06
		TC = 1;
		idpad = '000000';
		cmax = 1000;
		API = {};

		protectJSON = function(t) {
			// ****************************************
			// *
			// * Takes: a variable
			// * Returns: the variable if object/array or the parsed variable if JSON
			// *
			// ****************************************  
			if (TAFFY.isArray(t) || TAFFY.isObject(t)) {
				return t;
			} else {
				return JSON.parse(t);
			}
		};

		each = function(a, fun, u) {
			var r, i, x, y;
			// ****************************************
			// *
			// * Takes:
			// * a = an object/value or an array of objects/values
			// * f = a function
			// * u = optional flag to describe how to handle undefined values
			//   in array of values. True: pass them to the functions,
			//   False: skip. Default False;
			// * Purpose: Used to loop over arrays
			// *
			// ****************************************  
			if (a && ((T.isArray(a) && a.length === 1) || (!T.isArray(a)))) {
				fun((T.isArray(a)) ? a[0] : a, 0);
			} else {
				for (r, i, x = 0, a = (T.isArray(a)) ? a : [a], y = a.length;
				x < y; x++) {
					i = a[x];
					if (!T.isUndefined(i) || (u || false)) {
						r = fun(i, x);
						if (r === T.EXIT) {
							break;
						}

					}
				}
			}
		};

		eachin = function(o, fun) {
			// ****************************************
			// *
			// * Takes:
			// * o = an object
			// * f = a function
			// * Purpose: Used to loop over objects
			// *
			// ****************************************  
			var x = 0,
				r, i;

			for (i in o) {
				if (o.hasOwnProperty(i)) {
					r = fun(o[i], i, x++);
					if (r === T.EXIT) {
						break;
					}
				}
			}

		};

		API.extend = function(m, f) {
			// ****************************************
			// *
			// * Takes: method name, function
			// * Purpose: Add a custom method to the API
			// *
			// ****************************************  
			API[m] = function() {
				return f.apply(this, arguments);
			};
		};

		isIndexable = function(f) {
			var i;
			// Check to see if record ID
			if (T.isString(f) && /[t][0-9]*[r][0-9]*/i.test(f)) {
				return true;
			}
			// Check to see if record
			if (T.isObject(f) && f.___id && f.___s) {
				return true;
			}

			// Check to see if array of indexes
			if (T.isArray(f)) {
				i = true;
				each(f, function(r) {
					if (!isIndexable(r)) {
						i = false;

						return TAFFY.EXIT;
					}
				});
				return i;
			}

			return false;
		};

		runFilters = function(r, filter) {
			// ****************************************
			// *
			// * Takes: takes a record and a collection of filters
			// * Returns: true if the record matches, false otherwise
			// ****************************************
			var match = true;

			each(filter, function(mf) {
				switch (T.typeOf(mf)) {
				case 'function':
					// run function
					if (!mf.apply(r)) {
						match = false;
						return TAFFY.EXIT;
					}
					break;
				case 'array':
					// loop array and treat like a SQL or
					match = (mf.length === 1) ? (runFilters(r, mf[0])) : (mf.length === 2) ? (runFilters(r, mf[0]) || runFilters(r, mf[1])) : (mf.length === 3) ? (runFilters(r, mf[0]) || runFilters(r, mf[1]) || runFilters(r, mf[2])) : (mf.length === 4) ? (runFilters(r, mf[0]) || runFilters(r, mf[1]) || runFilters(r, mf[2]) || runFilters(r, mf[3])) : false;
					if (mf.length > 4) {
						each(mf, function(f) {
							if (runFilters(r, f)) {
								match = true;
							}
						});
					}
					break;
				}
			});

			return match;
		};

		returnFilter = function(f) {
			// ****************************************
			// *
			// * Takes: filter object
			// * Returns: a filter function
			// * Purpose: Take a filter object and return a function that can be used to compare
			// * a TaffyDB record to see if the record matches a query
			// ****************************************  
			var nf = [];
			if (T.isString(f) && /[t][0-9]*[r][0-9]*/i.test(f)) {
				f = {
					___id: f
				};
			}
			if (T.isArray(f)) {
				// if we are working with an array
				each(f, function(r) {
					// loop the array and return a filter func for each value
					nf.push(returnFilter(r));
				});
				// now build a func to loop over the filters and return true if ANY of the filters match
				// This handles logical OR expressions
				f = function() {
					var that = this,
						match = false;
					each(nf, function(f) {
						if (runFilters(that, f)) {
							match = true;
						}
					});
					return match;
				};
				return f;

			}
			// if we are dealing with an Object
			if (T.isObject(f)) {
				if (T.isObject(f) && f.___id && f.___s) {
					f = {
						___id: f.___id
					};
				}

				// Loop over each value on the object to prep match type and match value
				eachin(f, function(v, i) {

					// default match type to IS/Equals
					if (!T.isObject(v)) {
						v = {
							'is': v
						};
					}
					// loop over each value on the value object  - if any
					eachin(v, function(mtest, s) {
						// s = match type, e.g. is, hasAll, like, etc
						var c = [],
							looper;

						// function to loop and apply filter
						looper = (s === 'hasAll') ?
						function(mtest, func) {
							func(mtest);
						} : each;

						// loop over each test
						looper(mtest, function(mtest) {

							// su = match success
							// f = match false
							var su = true,
								f = false,
								matchFunc;

							// push a function onto the filter collection to do the matching
							matchFunc = function() {

								// get the value from the record
								var
								mvalue = this[i],
									eqeq = '==',
									bangeq = '!=',
									eqeqeq = '===',
									lt = '<',
									gt = '>',
									lteq = '<=',
									gteq = '>=',
									bangeqeq = '!==',
									r;

								if ((s.indexOf('!') === 0) && s !== bangeq && s !== bangeqeq) {
									// if the filter name starts with ! as in '!is' then reverse the match logic and remove the !
									su = false;
									s = s.substring(1, s.length);
								}
								// get the match results based on the s/match type
								/*jslint eqeq : true */
								r = ((s === 'regex') ? (mtest.test(mvalue)) : (s === 'lt' || s === lt) ? (mvalue < mtest) : (s === 'gt' || s === gt) ? (mvalue > mtest) : (s === 'lte' || s === lteq) ? (mvalue <= mtest) : (s === 'gte' || s === gteq) ? (mvalue >= mtest) : (s === 'left') ? (mvalue.indexOf(mtest) === 0) : (s === 'leftnocase') ? (mvalue.toLowerCase().indexOf(mtest.toLowerCase()) === 0) : (s === 'right') ? (mvalue.substring((mvalue.length - mtest.length)) === mtest) : (s === 'rightnocase') ? (mvalue.toLowerCase().substring((mvalue.length - mtest.length)) === mtest.toLowerCase()) : (s === 'like') ? (mvalue.indexOf(mtest) >= 0) : (s === 'likenocase') ? (mvalue.toLowerCase().indexOf(mtest.toLowerCase()) >= 0) : (s === eqeqeq || s === 'is') ? (mvalue === mtest) : (s === eqeq) ? (mvalue == mtest) : (s === bangeqeq) ? (mvalue !== mtest) : (s === bangeq) ? (mvalue != mtest) : (s === 'isnocase') ? (mvalue.toLowerCase ? mvalue.toLowerCase() === mtest.toLowerCase() : mvalue === mtest) : (s === 'has') ? (T.has(mvalue, mtest)) : (s === 'hasall') ? (T.hasAll(mvalue, mtest)) : (
								s.indexOf('is') === -1 && !TAFFY.isNull(mvalue) && !TAFFY.isUndefined(mvalue) && !TAFFY.isObject(mtest) && !TAFFY.isArray(mtest)) ? (mtest === mvalue[s]) : (T[s] && T.isFunction(T[s]) && s.indexOf('is') === 0) ? T[s](mvalue) === mtest : (T[s] && T.isFunction(T[s])) ? T[s](mvalue, mtest) : (false));
								/*jslint eqeq : false */
								r = (r && !su) ? false : (!r && !su) ? true : r;

								return r;
							};
							c.push(matchFunc);

						});
						// if only one filter in the collection push it onto the filter list without the array
						if (c.length === 1) {

							nf.push(c[0]);
						} else {
							// else build a function to loop over all the filters and return true only if ALL match
							// this is a logical AND
							nf.push(function() {
								var that = this,
									match = false;
								each(c, function(f) {
									if (f.apply(that)) {
										match = true;
									}
								});
								return match;
							});
						}
					});
				});
				// finally return a single function that wraps all the other functions and will run a query
				// where all functions have to return true for a record to appear in a query result
				f = function() {
					var that = this,
						match = true;
					// faster if less than  4 functions
					match = (nf.length === 1 && !nf[0].apply(that)) ? false : (nf.length === 2 && (!nf[0].apply(that) || !nf[1].apply(that))) ? false : (nf.length === 3 && (!nf[0].apply(that) || !nf[1].apply(that) || !nf[2].apply(that))) ? false : (nf.length === 4 && (!nf[0].apply(that) || !nf[1].apply(that) || !nf[2].apply(that) || !nf[3].apply(that))) ? false : true;
					if (nf.length > 4) {
						each(nf, function(f) {
							if (!runFilters(that, f)) {
								match = false;
							}
						});
					}
					return match;
				};
				return f;
			}

			// if function
			if (T.isFunction(f)) {
				return f;
			}
		};

		orderByCol = function(ar, o) {
			// ****************************************
			// *
			// * Takes: takes an array and a sort object
			// * Returns: the array sorted
			// * Purpose: Accept filters such as "[col], [col2]" or "[col] desc" and sort on those columns
			// *
			// ****************************************
			var sortFunc = function(a, b) {
				// function to pass to the native array.sort to sort an array
				var r = 0;

				T.each(o, function(sd) {
					// loop over the sort instructions
					// get the column name
					var o, col, dir, c, d;
					o = sd.split(' ');
					col = o[0];

					// get the direction
					dir = (o.length === 1) ? "logical" : o[1];

					if (dir === 'logical') {
						// if dir is logical than grab the charnum arrays for the two values we are looking at
						c = numcharsplit(a[col]);
						d = numcharsplit(b[col]);
						// loop over the charnumarrays until one value is higher than the other
						T.each((c.length <= d.length) ? c : d, function(x, i) {
							if (c[i] < d[i]) {
								r = -1;
								return TAFFY.EXIT;
							} else if (c[i] > d[i]) {
								r = 1;
								return TAFFY.EXIT;
							}
						});
					} else if (dir === 'logicaldesc') {
						// if logicaldesc than grab the charnum arrays for the two values we are looking at
						c = numcharsplit(a[col]);
						d = numcharsplit(b[col]);
						// loop over the charnumarrays until one value is lower than the other
						T.each((c.length <= d.length) ? c : d, function(x, i) {
							if (c[i] > d[i]) {
								r = -1;
								return TAFFY.EXIT;
							} else if (c[i] < d[i]) {
								r = 1;
								return TAFFY.EXIT;
							}
						});
					} else if (dir === 'asec' && a[col] < b[col]) {
						// if asec - default - check to see which is higher
						r = -1;
						return T.EXIT;
					} else if (dir === 'asec' && a[col] > b[col]) {
						// if asec - default - check to see which is higher
						r = 1;
						return T.EXIT;
					} else if (dir === 'desc' && a[col] > b[col]) {
						// if desc check to see which is lower
						r = -1;
						return T.EXIT;

					} else if (dir === 'desc' && a[col] < b[col]) {
						// if desc check to see which is lower
						r = 1;
						return T.EXIT;

					}
					// if r is still 0 and we are doing a logical sort than look to see if one array is longer than the other
					if (r === 0 && dir === 'logical' && c.length < d.length) {
						r = -1;
					} else if (r === 0 && dir === 'logical' && c.length > d.length) {
						r = 1;
					} else if (r === 0 && dir === 'logicaldesc' && c.length > d.length) {
						r = -1;
					} else if (r === 0 && dir === 'logicaldesc' && c.length < d.length) {
						r = 1;
					}

					if (r !== 0) {
						return T.EXIT;
					}

				});
				return r;
			};
			// call the sort function and return the newly sorted array
			return (ar && ar.push) ? ar.sort(sortFunc) : ar;

		};

		// ****************************************
		// *
		// * Takes: a string containing numbers and letters and turn it into an array
		// * Returns: return an array of numbers and letters
		// * Purpose: Used for logical sorting. String Example: 12ABC results: [12,'ABC']
		// **************************************** 
		(function() {
			// creates a cache for numchar conversions
			var cache = {},
				cachcounter = 0;
			// creates the numcharsplit function
			numcharsplit = function(thing) {
				// if over 1000 items exist in the cache, clear it and start over
				if (cachcounter > cmax) {
					cache = {};
					cachcounter = 0;
				}

				// if a cache can be found for a numchar then return its array value
				return cache['_' + thing] || (function() {
					// otherwise do the conversion
					// make sure it is a string and setup so other variables
					var nthing = String(thing),
						na = [],
						rv = '_',
						rt = '',
						x, xx, c;

					// loop over the string char by char
					for (x = 0, xx = nthing.length; x < xx; x++) {
						// take the char at each location
						c = nthing.charCodeAt(x);
						// check to see if it is a valid number char and append it to the array.
						// if last char was a string push the string to the charnum array
						if ((c >= 48 && c <= 57) || c === 46) {
							if (rt !== 'n') {
								rt = 'n';
								na.push(rv.toLowerCase());
								rv = '';
							}
							rv = rv + nthing.charAt(x);
						} else {
							// check to see if it is a valid string char and append to string
							// if last char was a number push the whole number to the charnum array
							if (rt !== 's') {
								rt = 's';
								na.push(parseFloat(rv));
								rv = '';
							}
							rv = rv + nthing.charAt(x);
						}
					}
					// once done, push the last value to the charnum array and remove the first uneeded item
					na.push((rt === 'n') ? parseFloat(rv) : rv.toLowerCase());
					na.shift();
					// add to cache
					cache['_' + thing] = na;
					cachcounter++;
					// return charnum array
					return na;
				} ());
			};
		} ());

		// ****************************************
		// *
		// * Runs a query
		// **************************************** 

		run = function() {
			this.context({
				results: this.getDBI().query(this.context())
			});

		};

		API.extend('filter', function() {
			// ****************************************
			// *
			// * Takes: takes unlimited filter objects as arguments
			// * Returns: method collection
			// * Purpose: Take filters as objects and cache functions for later lookup when a query is run
			// **************************************** 
			var
			nc = TAFFY.mergeObj(this.context(), {
				run: null
			}),
				nq = [];
			each(nc.q, function(v) {
				nq.push(v);
			});
			nc.q = nq;
			// Hadnle passing of ___ID or a record on lookup.
			each(arguments, function(f) {
				nc.q.push(returnFilter(f));
				nc.filterRaw.push(f);
			});

			return this.getroot(nc);
		});

		API.extend('order', function(o) {
			// ****************************************
			// *
			// * Purpose: takes a string and creates an array of order instructions to be used with a query
			// ****************************************
			o = o.split(',');
			var x = [],
				nc;

			each(o, function(r) {
				x.push(r.replace(/^\s*/, '').replace(/\s*$/, ''));
			});

			nc = TAFFY.mergeObj(this.context(), {
				sort: null
			});
			nc.order = x;

			return this.getroot(nc);
		});

		API.extend('limit', function(n) {
			// ****************************************
			// *
			// * Purpose: takes a limit number to limit the number of rows returned by a query. Will update the results
			// * of a query
			// **************************************** 
			var nc = TAFFY.mergeObj(this.context(), {}),
				limitedresults;

			nc.limit = n;

			if (nc.run && nc.sort) {
				limitedresults = [];
				each(nc.results, function(i, x) {
					if ((x + 1) > n) {
						return TAFFY.EXIT;
					}
					limitedresults.push(i);
				});
				nc.results = limitedresults;
			}

			return this.getroot(nc);
		});

		API.extend('start', function(n) {
			// ****************************************
			// *
			// * Purpose: takes a limit number to limit the number of rows returned by a query. Will update the results
			// * of a query
			// **************************************** 
			var nc = TAFFY.mergeObj(this.context(), {}),
				limitedresults;

			nc.start = n;

			if (nc.run && nc.sort && !nc.limit) {
				limitedresults = [];
				each(nc.results, function(i, x) {
					if ((x + 1) > n) {
						limitedresults.push(i);
					}
				});
				nc.results = limitedresults;
			} else {
				nc = TAFFY.mergeObj(this.context(), {
					run: null,
					start: n
				});
			}

			return this.getroot(nc);
		});

		API.extend('update', function(arg0, arg1, arg2) {
			// ****************************************
			// *
			// * Takes: a object and passes it off DBI update method for all matched records
			// **************************************** 
			var runEvent = true,
				o = {},
				args = arguments,
				that;
			if (TAFFY.isString(arg0) && (arguments.length === 2 || arguments.length === 3)) {
				o[arg0] = arg1;
				if (arguments.length === 3) {
					runEvent = arg2;
				}
			} else {
				o = arg0;
				if (args.length === 2) {
					runEvent = arg1;
				}
			}

			that = this;
			run.call(this);
			each(this.context().results, function(r) {
				var c = o;
				if (TAFFY.isFunction(c)) {
					c = c.apply(TAFFY.mergeObj(r, {}));
				} else {
					if (T.isFunction(c)) {
						c = c(TAFFY.mergeObj(r, {}));
					}
				}
				if (TAFFY.isObject(c)) {
					that.getDBI().update(r.___id, c, runEvent);
				}
			});
			if (this.context().results.length) {
				this.context({
					run: null
				});
			}
			return this;
		});
		API.extend('remove', function(runEvent) {
			// ****************************************
			// *
			// * Purpose: removes records from the DB via the remove and removeCommit DBI methods
			// **************************************** 
			var that = this,
				c = 0;
			run.call(this);
			each(this.context().results, function(r) {
				that.getDBI().remove(r.___id);
				c++;
			});
			if (this.context().results.length) {
				this.context({
					run: null
				});
				that.getDBI().removeCommit(runEvent);
			}

			return c;
		});

		API.extend('count', function() {
			// ****************************************
			// *
			// * Returns: The length of a query result
			// **************************************** 
			run.call(this);
			return this.context().results.length;
		});

		API.extend('callback', function(f, delay) {
			// ****************************************
			// *
			// * Returns null;
			// * Runs a function on return of run.call
			// **************************************** 
			if (f) {
				var that = this;
				setTimeout(function() {
					run.call(that);
					f.call(that.getroot(that.context()));
				},
				delay || 0);
			}

			return null;
		});

		API.extend('get', function() {
			// ****************************************
			// *
			// * Returns: An array of all matching records
			// **************************************** 
			run.call(this);
			return this.context().results;
		});

		API.extend('stringify', function() {
			// ****************************************
			// *
			// * Returns: An JSON string of all matching records
			// **************************************** 
			return JSON.stringify(this.get());
		});
		API.extend('first', function() {
			// ****************************************
			// *
			// * Returns: The first matching record
			// **************************************** 
			run.call(this);
			return this.context().results[0] || false;
		});
		API.extend('last', function() {
			// ****************************************
			// *
			// * Returns: The last matching record
			// **************************************** 
			run.call(this);
			return this.context().results[this.context().results.length - 1] || false;
		});

		API.extend('sum', function() {
			// ****************************************
			// *
			// * Takes: column to sum up
			// * Returns: Sums the values of a column
			// **************************************** 
			var total = 0,
				that = this;
			run.call(that);
			each(arguments, function(c) {
				each(that.context().results, function(r) {
					total = total + r[c];
				});
			});
			return total;
		});

		API.extend('min', function(c) {
			// ****************************************
			// *
			// * Takes: column to find min
			// * Returns: the lowest value
			// **************************************** 
			var lowest = null;
			run.call(this);
			each(this.context().results, function(r) {
				if (lowest === null || r[c] < lowest) {
					lowest = r[c];
				}
			});
			return lowest;
		});

		//  Taffy innerJoin Extension (OCD edition)
		//  =======================================
		//
		//  How to Use
		//  **********
		//
		//  left_table.innerJoin( right_table, condition1 <,... conditionN> )
		//
		//  A condition can take one of 2 forms:
		//
		//    1. An ARRAY with 2 or 3 values:
		//    A column name from the left table, an optional comparison string,
		//    and column name from the right table.  The condition passes if the test
		//    indicated is true.   If the condition string is omitted, '===' is assumed.
		//    EXAMPLES: [ 'last_used_time', '>=', 'current_use_time' ], [ 'user_id','id' ]
		//
		//    2. A FUNCTION:
		//    The function receives a left table row and right table row during the
		//    cartesian join.  If the function returns true for the rows considered,
		//    the merged row is included in the result set.
		//    EXAMPLE: function (l,r){ return l.name === r.label; }
		//
		//  Conditions are considered in the order they are presented.  Therefore the best
		//  performance is realized when the least expensive and highest prune-rate
		//  conditions are placed first, since if they return false Taffy skips any
		//  further condition tests.
		//
		//  Other notes
		//  ***********
		//
		//  This code passes jslint with the exception of 2 warnings about
		//  the '==' and '!=' lines.  We can't do anything about that short of
		//  deleting the lines.
		//
		//  Credits
		//  *******
		//
		//  Heavily based upon the work of Ian Toltz.
		//  Revisions to API by Michael Mikowski.
		//  Code convention per standards in http://manning.com/mikowski
		(function() {
			var innerJoinFunction = (function() {
				var fnCompareList, fnCombineRow, fnMain;

				fnCompareList = function(left_row, right_row, arg_list) {
					var data_lt, data_rt, op_code, error;

					if (arg_list.length === 2) {
						data_lt = left_row[arg_list[0]];
						op_code = '===';
						data_rt = right_row[arg_list[1]];
					} else {
						data_lt = left_row[arg_list[0]];
						op_code = arg_list[1];
						data_rt = right_row[arg_list[2]];
					}

					/*jslint eqeq : true */
					switch (op_code) {
					case '===':
						return data_lt === data_rt;
					case '!==':
						return data_lt !== data_rt;
					case '<':
						return data_lt < data_rt;
					case '>':
						return data_lt > data_rt;
					case '<=':
						return data_lt <= data_rt;
					case '>=':
						return data_lt >= data_rt;
					case '==':
						return data_lt == data_rt;
					case '!=':
						return data_lt != data_rt;
					default:
						throw String(op_code) + ' is not supported';
					}
					// 'jslint eqeq : false'  here results in
					// "Unreachable '/*jslint' after 'return'".
					// We don't need it though, as the rule exception
					// is discarded at the end of this functional scope
				};

				fnCombineRow = function(left_row, right_row) {
					var out_map = {},
						i, prefix;

					for (i in left_row) {
						if (left_row.hasOwnProperty(i)) {
							out_map[i] = left_row[i];
						}
					}
					for (i in right_row) {
						if (right_row.hasOwnProperty(i) && i !== '___id' && i !== '___s') {
							prefix = !TAFFY.isUndefined(out_map[i]) ? 'right_' : '';
							out_map[prefix + String(i)] = right_row[i];
						}
					}
					return out_map;
				};

				fnMain = function(table) {
					var
					right_table, i, arg_list = arguments,
						arg_length = arg_list.length,
						result_list = [];

					if (typeof table.filter !== 'function') {
						if (table.TAFFY) {
							right_table = table();
						} else {
							throw 'TAFFY DB or result not supplied';
						}
					} else {
						right_table = table;
					}

					this.context({
						results: this.getDBI().query(this.context())
					});

					TAFFY.each(this.context().results, function(left_row) {
						right_table.each(function(right_row) {
							var arg_data, is_ok = true;
							CONDITION: for (i = 1; i < arg_length; i++) {
								arg_data = arg_list[i];
								if (typeof arg_data === 'function') {
									is_ok = arg_data(left_row, right_row);
								} else if (typeof arg_data === 'object' && arg_data.length) {
									is_ok = fnCompareList(left_row, right_row, arg_data);
								} else {
									is_ok = false;
								}

								if (!is_ok) {
									break CONDITION;
								} // short circuit
							}

							if (is_ok) {
								result_list.push(fnCombineRow(left_row, right_row));
							}
						});
					});
					return TAFFY(result_list)();
				};

				return fnMain;
			} ());

			API.extend('join', innerJoinFunction);
		} ());

		API.extend('max', function(c) {
			// ****************************************
			// *
			// * Takes: column to find max
			// * Returns: the highest value
			// ****************************************
			var highest = null;
			run.call(this);
			each(this.context().results, function(r) {
				if (highest === null || r[c] > highest) {
					highest = r[c];
				}
			});
			return highest;
		});

		API.extend('select', function() {
			// ****************************************
			// *
			// * Takes: columns to select values into an array
			// * Returns: array of values
			// * Note if more than one column is given an array of arrays is returned
			// **************************************** 
			var ra = [],
				args = arguments;
			run.call(this);
			if (arguments.length === 1) {

				each(this.context().results, function(r) {

					ra.push(r[args[0]]);
				});
			} else {
				each(this.context().results, function(r) {
					var row = [];
					each(args, function(c) {
						row.push(r[c]);
					});
					ra.push(row);
				});
			}
			return ra;
		});
		API.extend('distinct', function() {
			// ****************************************
			// *
			// * Takes: columns to select unique alues into an array
			// * Returns: array of values
			// * Note if more than one column is given an array of arrays is returned
			// **************************************** 
			var ra = [],
				args = arguments;
			run.call(this);
			if (arguments.length === 1) {

				each(this.context().results, function(r) {
					var v = r[args[0]],
						dup = false;
					each(ra, function(d) {
						if (v === d) {
							dup = true;
							return TAFFY.EXIT;
						}
					});
					if (!dup) {
						ra.push(v);
					}
				});
			} else {
				each(this.context().results, function(r) {
					var row = [],
						dup = false;
					each(args, function(c) {
						row.push(r[c]);
					});
					each(ra, function(d) {
						var ldup = true;
						each(args, function(c, i) {
							if (row[i] !== d[i]) {
								ldup = false;
								return TAFFY.EXIT;
							}
						});
						if (ldup) {
							dup = true;
							return TAFFY.EXIT;
						}
					});
					if (!dup) {
						ra.push(row);
					}
				});
			}
			return ra;
		});
		API.extend('supplant', function(template, returnarray) {
			// ****************************************
			// *
			// * Takes: a string template formated with key to be replaced with values from the rows, flag to determine if we want array of strings
			// * Returns: array of values or a string
			// **************************************** 
			var ra = [];
			run.call(this);
			each(this.context().results, function(r) {
				// TODO: The curly braces used to be unescaped
				ra.push(template.replace(/\{([^\{\}]*)\}/g, function(a, b) {
					var v = r[b];
					return typeof v === 'string' || typeof v === 'number' ? v : a;
				}));
			});
			return (!returnarray) ? ra.join("") : ra;
		});

		API.extend('each', function(m) {
			// ****************************************
			// *
			// * Takes: a function
			// * Purpose: loops over every matching record and applies the function
			// **************************************** 
			run.call(this);
			each(this.context().results, m);
			return this;
		});
		API.extend('map', function(m) {
			// ****************************************
			// *
			// * Takes: a function
			// * Purpose: loops over every matching record and applies the function, returing the results in an array
			// **************************************** 
			var ra = [];
			run.call(this);
			each(this.context().results, function(r) {
				ra.push(m(r));
			});
			return ra;
		});

		T = function(d) {
			// ****************************************
			// *
			// * T is the main TAFFY object
			// * Takes: an array of objects or JSON
			// * Returns a new TAFFYDB
			// **************************************** 
			var TOb = [],
				ID = {},
				RC = 1,
				settings = {
				template: false,
				onInsert: false,
				onUpdate: false,
				onRemove: false,
				onDBChange: false,
				storageName: false,
				forcePropertyCase: null,
				cacheSize: 100,
				name: ''
			},
				dm = new Date(),
				CacheCount = 0,
				CacheClear = 0,
				Cache = {},
				DBI, runIndexes, root;
			// ****************************************
			// *
			// * TOb = this database
			// * ID = collection of the record IDs and locations within the DB, used for fast lookups
			// * RC = record counter, used for creating IDs
			// * settings.template = the template to merge all new records with
			// * settings.onInsert = event given a copy of the newly inserted record
			// * settings.onUpdate = event given the original record, the changes, and the new record
			// * settings.onRemove = event given the removed record
			// * settings.forcePropertyCase = on insert force the proprty case to be lower or upper. default lower, null/undefined will leave case as is
			// * dm = the modify date of the database, used for query caching
			// **************************************** 

			runIndexes = function(indexes) {
				// ****************************************
				// *
				// * Takes: a collection of indexes
				// * Returns: collection with records matching indexed filters
				// **************************************** 
				var records = [],
					UniqueEnforce = false;

				if (indexes.length === 0) {
					return TOb;
				}

				each(indexes, function(f) {
					// Check to see if record ID
					if (T.isString(f) && /[t][0-9]*[r][0-9]*/i.test(f) && TOb[ID[f]]) {
						records.push(TOb[ID[f]]);
						UniqueEnforce = true;
					}
					// Check to see if record
					if (T.isObject(f) && f.___id && f.___s && TOb[ID[f.___id]]) {
						records.push(TOb[ID[f.___id]]);
						UniqueEnforce = true;
					}
					// Check to see if array of indexes
					if (T.isArray(f)) {
						each(f, function(r) {
							each(runIndexes(r), function(rr) {
								records.push(rr);
							});

						});
					}
				});
				if (UniqueEnforce && records.length > 1) {
					records = [];
				}

				return records;
			};

			DBI = {
				// ****************************************
				// *
				// * The DBI is the internal DataBase Interface that interacts with the data
				// **************************************** 
				dm: function(nd) {
					// ****************************************
					// *
					// * Takes: an optional new modify date
					// * Purpose: used to get and set the DB modify date
					// **************************************** 
					if (nd) {
						dm = nd;
						Cache = {};
						CacheCount = 0;
						CacheClear = 0;
					}
					if (settings.onDBChange) {
						setTimeout(function() {
							settings.onDBChange.call(TOb);
						},
						0);
					}
					if (settings.storageName) {
						setTimeout(function() {
							localStorage.setItem('taffy_' + settings.storageName, JSON.stringify(TOb));
						});
					}
					return dm;
				},
				insert: function(i, runEvent) {
					// ****************************************
					// *
					// * Takes: a new record to insert
					// * Purpose: merge the object with the template, add an ID, insert into DB, call insert event
					// **************************************** 
					var columns = [],
						records = [],
						input = protectJSON(i);
					each(input, function(v, i) {
						var nv, o;
						if (T.isArray(v) && i === 0) {
							each(v, function(av) {

								columns.push((settings.forcePropertyCase === 'lower') ? av.toLowerCase() : (settings.forcePropertyCase === 'upper') ? av.toUpperCase() : av);
							});
							return true;
						} else if (T.isArray(v)) {
							nv = {};
							each(v, function(av, ai) {
								nv[columns[ai]] = av;
							});
							v = nv;

						} else if (T.isObject(v) && settings.forcePropertyCase) {
							o = {};

							eachin(v, function(av, ai) {
								o[(settings.forcePropertyCase === 'lower') ? ai.toLowerCase() : (settings.forcePropertyCase === 'upper') ? ai.toUpperCase() : ai] = v[ai];
							});
							v = o;
						}

						RC++;
						v.___id = 'T' + String(idpad + TC).slice(-6) + 'R' + String(idpad + RC).slice(-6);
						v.___s = true;
						records.push(v.___id);
						if (settings.template) {
							v = T.mergeObj(settings.template, v);
						}
						TOb.push(v);

						ID[v.___id] = TOb.length - 1;
						if (settings.onInsert && (runEvent || TAFFY.isUndefined(runEvent))) {
							settings.onInsert.call(v);
						}
						DBI.dm(new Date());
					});
					return root(records);
				},
				sort: function(o) {
					// ****************************************
					// *
					// * Purpose: Change the sort order of the DB itself and reset the ID bucket
					// **************************************** 
					TOb = orderByCol(TOb, o.split(','));
					ID = {};
					each(TOb, function(r, i) {
						ID[r.___id] = i;
					});
					DBI.dm(new Date());
					return true;
				},
				update: function(id, changes, runEvent) {
					// ****************************************
					// *
					// * Takes: the ID of record being changed and the changes
					// * Purpose: Update a record and change some or all values, call the on update method
					// ****************************************
					var nc = {},
						or, nr, tc, hasChange;
					if (settings.forcePropertyCase) {
						eachin(changes, function(v, p) {
							nc[(settings.forcePropertyCase === 'lower') ? p.toLowerCase() : (settings.forcePropertyCase === 'upper') ? p.toUpperCase() : p] = v;
						});
						changes = nc;
					}

					or = TOb[ID[id]];
					nr = T.mergeObj(or, changes);

					tc = {};
					hasChange = false;
					eachin(nr, function(v, i) {
						if (TAFFY.isUndefined(or[i]) || or[i] !== v) {
							tc[i] = v;
							hasChange = true;
						}
					});
					if (hasChange) {
						if (settings.onUpdate && (runEvent || TAFFY.isUndefined(runEvent))) {
							settings.onUpdate.call(nr, TOb[ID[id]], tc);
						}
						TOb[ID[id]] = nr;
						DBI.dm(new Date());
					}
				},
				remove: function(id) {
					// ****************************************
					// *
					// * Takes: the ID of record to be removed
					// * Purpose: remove a record, changes its ___s value to false
					// **************************************** 
					TOb[ID[id]].___s = false;
				},
				removeCommit: function(runEvent) {
					var x;
					// ****************************************
					// *
					// * 
					// * Purpose: loop over all records and remove records with ___s = false, call onRemove event, clear ID
					// ****************************************
					for (x = TOb.length - 1; x > -1; x--) {

						if (!TOb[x].___s) {
							if (settings.onRemove && (runEvent || TAFFY.isUndefined(runEvent))) {
								settings.onRemove.call(TOb[x]);
							}
							ID[TOb[x].___id] = undefined;
							TOb.splice(x, 1);
						}
					}
					ID = {};
					each(TOb, function(r, i) {
						ID[r.___id] = i;
					});
					DBI.dm(new Date());
				},
				query: function(context) {
					// ****************************************
					// *
					// * Takes: the context object for a query and either returns a cache result or a new query result
					// **************************************** 
					var returnq, cid, results, indexed, limitq, ni;

					if (settings.cacheSize) {
						cid = '';
						each(context.filterRaw, function(r) {
							if (T.isFunction(r)) {
								cid = 'nocache';
								return TAFFY.EXIT;
							}
						});
						if (cid === '') {
							cid = JSON.stringify(T.mergeObj(context, {
								q: false,
								run: false,
								sort: false
							}));
						}
					}
					// Run a new query if there are no results or the run date has been cleared
					if (!context.results || !context.run || (context.run && DBI.dm() > context.run)) {
						results = [];

						// check Cache
						if (settings.cacheSize && Cache[cid]) {

							Cache[cid].i = CacheCount++;
							return Cache[cid].results;
						} else {
							// if no filter, return DB
							if (context.q.length === 0 && context.index.length === 0) {
								each(TOb, function(r) {
									results.push(r);
								});
								returnq = results;
							} else {
								// use indexes
								indexed = runIndexes(context.index);

								// run filters
								each(indexed, function(r) {
									// Run filter to see if record matches query
									if (context.q.length === 0 || runFilters(r, context.q)) {
										results.push(r);
									}
								});

								returnq = results;
							}
						}

					} else {
						// If query exists and run has not been cleared return the cache results
						returnq = context.results;
					}
					// If a custom order array exists and the run has been clear or the sort has been cleared
					if (context.order.length > 0 && (!context.run || !context.sort)) {
						// order the results
						returnq = orderByCol(returnq, context.order);
					}

					// If a limit on the number of results exists and it is less than the returned results, limit results
					if (returnq.length && ((context.limit && context.limit < returnq.length) || context.start)) {
						limitq = [];
						each(returnq, function(r, i) {
							if (!context.start || (context.start && (i + 1) >= context.start)) {
								if (context.limit) {
									ni = (context.start) ? (i + 1) - context.start : i;
									if (ni < context.limit) {
										limitq.push(r);
									} else if (ni > context.limit) {
										return TAFFY.EXIT;
									}
								} else {
									limitq.push(r);
								}
							}
						});
						returnq = limitq;
					}

					// update cache
					if (settings.cacheSize && cid !== 'nocache') {
						CacheClear++;

						setTimeout(function() {
							var bCounter, nc;
							if (CacheClear >= settings.cacheSize * 2) {
								CacheClear = 0;
								bCounter = CacheCount - settings.cacheSize;
								nc = {};
								eachin(function(r, k) {
									if (r.i >= bCounter) {
										nc[k] = r;
									}
								});
								Cache = nc;
							}
						},
						0);

						Cache[cid] = {
							i: CacheCount++,
							results: returnq
						};
					}
					return returnq;
				}
			};

			root = function() {
				var iAPI, context;
				// ****************************************
				// *
				// * The root function that gets returned when a new DB is created
				// * Takes: unlimited filter arguments and creates filters to be run when a query is called
				// **************************************** 
				// ****************************************
				// *
				// * iAPI is the the method collection valiable when a query has been started by calling dbname
				// * Certain methods are or are not avaliable once you have started a query such as insert -- you can only insert into root
				// ****************************************
				iAPI = TAFFY.mergeObj(TAFFY.mergeObj(API, {
					insert: undefined
				}), {
					getDBI: function() {
						return DBI;
					},
					getroot: function(c) {
						return root.call(c);
					},
					context: function(n) {
						// ****************************************
						// *
						// * The context contains all the information to manage a query including filters, limits, and sorts
						// **************************************** 
						if (n) {
							context = TAFFY.mergeObj(context, n.hasOwnProperty('results') ? TAFFY.mergeObj(n, {
								run: new Date(),
								sort: new Date()
							}) : n);
						}
						return context;
					},
					extend: undefined
				});

				context = (this && this.q) ? this : {
					limit: false,
					start: false,
					q: [],
					filterRaw: [],
					index: [],
					order: [],
					results: false,
					run: null,
					sort: null,
					settings: settings
				};
				// ****************************************
				// *
				// * Call the query method to setup a new query
				// **************************************** 
				each(arguments, function(f) {

					if (isIndexable(f)) {
						context.index.push(f);
					} else {
						context.q.push(returnFilter(f));
					}
					context.filterRaw.push(f);
				});

				return iAPI;
			};

			// ****************************************
			// *
			// * If new records have been passed on creation of the DB either as JSON or as an array/object, insert them
			// **************************************** 
			TC++;
			if (d) {
				DBI.insert(d);
			}

			root.insert = DBI.insert;

			root.merge = function(i, key, runEvent) {
				var
				search = {},
					finalSearch = [],
					obj = {};

				runEvent = runEvent || false;
				key = key || 'id';

				each(i, function(o) {
					var existingObject;
					search[key] = o[key];
					finalSearch.push(o[key]);
					existingObject = root(search).first();
					if (existingObject) {
						DBI.update(existingObject.___id, o, runEvent);
					} else {
						DBI.insert(o, runEvent);
					}
				});

				obj[key] = finalSearch;
				return root(obj);
			};

			root.TAFFY = true;
			root.sort = DBI.sort;
			// ****************************************
			// *
			// * These are the methods that can be accessed on off the root DB function. Example dbname.insert;
			// **************************************** 
			root.settings = function(n) {
				// ****************************************
				// *
				// * Getting and setting for this DB's settings/events
				// **************************************** 
				if (n) {
					settings = TAFFY.mergeObj(settings, n);
					if (n.template) {

						root().update(n.template);
					}
				}
				return settings;
			};

			// ****************************************
			// *
			// * These are the methods that can be accessed on off the root DB function. Example dbname.insert;
			// **************************************** 
			root.store = function(n) {
				// ****************************************
				// *
				// * Setup localstorage for this DB on a given name
				// * Pull data into the DB as needed
				// **************************************** 
				var r = false,
					i;
				if (localStorage) {
					if (n) {
						i = localStorage.getItem('taffy_' + n);
						if (i && i.length > 0) {
							root.insert(i);
							r = true;
						}
						if (TOb.length > 0) {
							setTimeout(function() {
								localStorage.setItem('taffy_' + settings.storageName, JSON.stringify(TOb));
							});
						}
					}
					root.settings({
						storageName: n
					});
				}
				return root;
			};

			// ****************************************
			// *
			// * Return root on DB creation and start having fun
			// **************************************** 
			return root;
		};
		// ****************************************
		// *
		// * Sets the global TAFFY object
		// **************************************** 
		TAFFY = T;

		// ****************************************
		// *
		// * Create public each method
		// *
		// ****************************************   
		T.each = each;

		// ****************************************
		// *
		// * Create public eachin method
		// *
		// ****************************************   
		T.eachin = eachin;
		// ****************************************
		// *
		// * Create public extend method
		// * Add a custom method to the API
		// *
		// ****************************************   
		T.extend = API.extend;

		// ****************************************
		// *
		// * Creates TAFFY.EXIT value that can be returned to stop an each loop
		// *
		// ****************************************  
		TAFFY.EXIT = 'TAFFYEXIT';

		// ****************************************
		// *
		// * Create public utility mergeObj method
		// * Return a new object where items from obj2
		// * have replaced or been added to the items in
		// * obj1
		// * Purpose: Used to combine objs
		// *
		// ****************************************   
		TAFFY.mergeObj = function(ob1, ob2) {
			var c = {};
			eachin(ob1, function(v, n) {
				c[n] = ob1[n];
			});
			eachin(ob2, function(v, n) {
				c[n] = ob2[n];
			});
			return c;
		};

		// ****************************************
		// *
		// * Create public utility has method
		// * Returns true if a complex object, array
		// * or taffy collection contains the material
		// * provided in the second argument
		// * Purpose: Used to comare objects
		// *
		// ****************************************
		TAFFY.has = function(var1, var2) {

			var re = true,
				n;

			if ((var1.TAFFY)) {
				re = var1(var2);
				if (re.length > 0) {
					return true;
				} else {
					return false;
				}
			} else {

				switch (T.typeOf(var1)) {
				case 'object':
					if (T.isObject(var2)) {
						eachin(var2, function(v, n) {
							if (re === true && !T.isUndefined(var1[n]) && var1.hasOwnProperty(n)) {
								re = T.has(var1[n], var2[n]);
							} else {
								re = false;
								return TAFFY.EXIT;
							}
						});
					} else if (T.isArray(var2)) {
						each(var2, function(v, n) {
							re = T.has(var1, var2[n]);
							if (re) {
								return TAFFY.EXIT;
							}
						});
					} else if (T.isString(var2)) {
						if (!TAFFY.isUndefined(var1[var2])) {
							return true;
						} else {
							return false;
						}
					}
					return re;
				case 'array':
					if (T.isObject(var2)) {
						each(var1, function(v, i) {
							re = T.has(var1[i], var2);
							if (re === true) {
								return TAFFY.EXIT;
							}
						});
					} else if (T.isArray(var2)) {
						each(var2, function(v2, i2) {
							each(var1, function(v1, i1) {
								re = T.has(var1[i1], var2[i2]);
								if (re === true) {
									return TAFFY.EXIT;
								}
							});
							if (re === true) {
								return TAFFY.EXIT;
							}
						});
					} else if (T.isString(var2) || T.isNumber(var2)) {
						for (n = 0; n < var1.length; n++) {
							re = T.has(var1[n], var2);
							if (re) {
								return true;
							}
						}
					}
					return re;
				case 'string':
					if (T.isString(var2) && var2 === var1) {
						return true;
					}
					break;
				default:
					if (T.typeOf(var1) === T.typeOf(var2) && var1 === var2) {
						return true;
					}
					break;
				}
			}
			return false;
		};

		// ****************************************
		// *
		// * Create public utility hasAll method
		// * Returns true if a complex object, array
		// * or taffy collection contains the material
		// * provided in the call - for arrays it must
		// * contain all the material in each array item
		// * Purpose: Used to comare objects
		// *
		// ****************************************
		TAFFY.hasAll = function(var1, var2) {

			var T = TAFFY,
				ar;
			if (T.isArray(var2)) {
				ar = true;
				each(var2, function(v) {
					ar = T.has(var1, v);
					if (ar === false) {
						return TAFFY.EXIT;
					}
				});
				return ar;
			} else {
				return T.has(var1, var2);
			}
		};

		// ****************************************
		// *
		// * typeOf Fixed in JavaScript as public utility
		// *
		// ****************************************
		TAFFY.typeOf = function(v) {
			var s = typeof v;
			if (s === 'object') {
				if (v) {
					if (typeof v.length === 'number' && !(v.propertyIsEnumerable('length'))) {
						s = 'array';
					}
				} else {
					s = 'null';
				}
			}
			return s;
		};

		// ****************************************
		// *
		// * Create public utility getObjectKeys method
		// * Returns an array of an objects keys
		// * Purpose: Used to get the keys for an object
		// *
		// ****************************************   
		TAFFY.getObjectKeys = function(ob) {
			var kA = [];
			eachin(ob, function(n, h) {
				kA.push(h);
			});
			kA.sort();
			return kA;
		};

		// ****************************************
		// *
		// * Create public utility isSameArray
		// * Returns an array of an objects keys
		// * Purpose: Used to get the keys for an object
		// *
		// ****************************************   
		TAFFY.isSameArray = function(ar1, ar2) {
			return (TAFFY.isArray(ar1) && TAFFY.isArray(ar2) && ar1.join(',') === ar2.join(',')) ? true : false;
		};

		// ****************************************
		// *
		// * Create public utility isSameObject method
		// * Returns true if objects contain the same
		// * material or false if they do not
		// * Purpose: Used to comare objects
		// *
		// ****************************************   
		TAFFY.isSameObject = function(ob1, ob2) {
			var T = TAFFY,
				rv = true;

			if (T.isObject(ob1) && T.isObject(ob2)) {
				if (T.isSameArray(T.getObjectKeys(ob1), T.getObjectKeys(ob2))) {
					eachin(ob1, function(v, n) {
						if (! ((T.isObject(ob1[n]) && T.isObject(ob2[n]) && T.isSameObject(ob1[n], ob2[n])) || (T.isArray(ob1[n]) && T.isArray(ob2[n]) && T.isSameArray(ob1[n], ob2[n])) || (ob1[n] === ob2[n]))) {
							rv = false;
							return TAFFY.EXIT;
						}
					});
				} else {
					rv = false;
				}
			} else {
				rv = false;
			}
			return rv;
		};

		// ****************************************
		// *
		// * Create public utility is[DataType] methods
		// * Return true if obj is datatype, false otherwise
		// * Purpose: Used to determine if arguments are of certain data type
		// *
		// * mmikowski 2012-08-06 refactored to make much less "magical":
		// *   fewer closures and passes jslint
		// *
		// ****************************************
		typeList = ['String', 'Number', 'Object', 'Array', 'Boolean', 'Null', 'Function', 'Undefined'];

		makeTest = function(thisKey) {
			return function(data) {
				return TAFFY.typeOf(data) === thisKey.toLowerCase() ? true : false;
			};
		};

		for (idx = 0; idx < typeList.length; idx++) {
			typeKey = typeList[idx];
			TAFFY['is' + typeKey] = makeTest(typeKey);
		}
	}
} ());

if (typeof(exports) === 'object') {

exports.taffy = function(dbName, settings,inData) {
		if (!dbName) {
			throw "Invalid TaffyDb file";
			return
		};
		
		var db;
		var parent = Ti.Filesystem.applicationDataDirectory;
		var taffFolder = Ti.Filesystem.getFile(parent, 'titaffydb');
		if(!taffFolder.exists()){
		  taffFolder.createDirectory();
		}
		
		var taffFolder = parent + 'titaffydb';			
		var taffyFile = Ti.Filesystem.getFile(taffFolder, dbName.toUpperCase());
		
		if (!inData){ 
			if(taffyFile.exists()){
				try{
					var contents = taffyFile.read();
					if(contents==null){
						db = TAFFY();
						return null;
					}else{
						db = TAFFY(JSON.parse(contents.text));
					}
				}catch(err){
					Ti.API.error('TaffyDb Load Error: ' + err);
					throw "Invalid TaffyDb file";
				}
			}else{
				db = TAFFY();
			}
		}else{
			db = TAFFY(inData);
		}

		db.settings(settings||null);
		db.save =  function() {
			taffyFile.write(JSON.stringify(db().get()));
		};

		if (settings && settings.autocommit) {

			var _onDBChange = settings.onDBChange || function(){};

			settings.onDBChange = function() {
				db.save();
				_onDBChange(this);
			};

			db.settings(settings);		
		}
		return db;
	}
}