subChildOrm,
naturalKey;
- if (currentProp.toOne && currentProp.toOne.type) {
- subChildOrm = that.fetchOrm(nameSpace, currentProp.toOne.type);
- } else if (currentProp.toMany && currentProp.toMany.type) {
- subChildOrm = that.fetchOrm(nameSpace, currentProp.toMany.type);
- } else {
- plv8.elog(ERROR, "toOne or toMany property is missing it's 'type': " + currentProp.name);
- }
+ if ((currentProp.toOne || currentProp.toMany)) {
+ if (currentProp.toOne && currentProp.toOne.type) {
+ subChildOrm = that.fetchOrm(nameSpace, currentProp.toOne.type);
+ } else if (currentProp.toMany && currentProp.toMany.type) {
+ subChildOrm = that.fetchOrm(nameSpace, currentProp.toMany.type);
+ } else {
+ plv8.elog(ERROR, "toOne or toMany property is missing it's 'type': " + currentProp.name);
+ }
- if (pathIndex < pathParts.length - 1) {
- /* Recurse. */
- walkPath(pathParts, subChildOrm, pathIndex + 1);
- } else {
- /* This is the end of the path. */
- naturalKey = XT.Orm.naturalKey(subChildOrm);
- if (currentAttributeIsString) {
- /* add the natural key to the end of the requested attribute */
- parameter.attribute = attribute + "." + naturalKey;
+ if (pathIndex < pathParts.length - 1) {
+ /* Recurse. */
+ walkPath(pathParts, subChildOrm, pathIndex + 1);
} else {
- /* swap out the attribute in the array for the one with the prepended natural key */
- index = parameter.attribute.indexOf(attribute);
- parameter.attribute.splice(index, 1);
- parameter.attribute.splice(index, 0, attribute + "." + naturalKey);
+ /* This is the end of the path. */
+ naturalKey = XT.Orm.naturalKey(subChildOrm);
+ if (currentAttributeIsString) {
+ /* add the natural key to the end of the requested attribute */
+ parameter.attribute = attribute + "." + naturalKey;
+ } else {
+ /* swap out the attribute in the array for the one with the prepended natural key */
+ index = parameter.attribute.indexOf(attribute);
+ parameter.attribute.splice(index, 1);
+ parameter.attribute.splice(index, 0, attribute + "." + naturalKey);
+ }
}
}
}
return ret;
},
+ /**
+ * Get the current database server version.
+ * If the optional precision argument is passed, return the first prec
+ * fields of the full version number.
+ *
+ * @example
+ * var x = getPgVersion(1), // '9'
+ * xy = getPgVersion(2), // '9.1'
+ * xyz = getPgVersion(3), // '9.1.3'
+ * all = getPgVersion(); // '9.1.3'
+ *
+ * @param {Number} proc - optional precision
+ * @returns {String} X[.Y[.Z]]
+ */
+ getPgVersion: function (prec) {
+ var q = plv8.execute("select setting from pg_settings " +
+ "where name='server_version';"),
+ ret;
+ ret = q[0].setting;
+ if (typeof prec === 'number') {
+ ret = ret.split(".").slice(0,prec).join(".");
+ }
+ return ret;
+ },
+
/**
* Get the oid for a given table name.
*
lockExp,
oid,
pcheck,
+ pgver = 0 + XT.Data.getPgVersion(2),
pid = options.pid || null,
- pidSql = "select usename, procpid " +
+ pidcol = (pgver < 9.2) ? "procpid" : "pid",
+ pidSql = "select usename, {pidcol} " +
"from pg_stat_activity " +
"where datname=current_database() " +
" and usename=$1 " +
- " and procpid=$2;",
+ " and {pidcol}=$2;",
query,
selectSql = "select * " +
"from xt.lock " +
" and lock_record_id = $2;",
username = XT.username;
+ pidSql = pidSql.replace(/{pidcol}/g, pidcol);
+
/* If passed a table name, look up the oid. */
oid = typeof table === "string" ? this.getTableOid(table) : table;