+ if (is_array($keyCol)) {
+ foreach ($keyVals as $keyVal) {
+ $result[implode(',', $keyVal)] = null;
+ }
+ } else {
+ $result = array_fill_keys($keyVals, null);
+ }
+
+ $toFetch = array();
+
+ foreach ($keyVals as $keyVal) {
+
+ if (is_array($keyCol)) {
+ $kv = array_combine($keyCol, $keyVal);
+ } else {
+ $kv = array($keyCol => $keyVal);
+ }
+
+ $kv = array_merge($otherCols, $kv);
+
+ $i = self::multicache($cls, $kv);
+
+ if ($i !== false) {
+ if (is_array($keyCol)) {
+ $result[implode(',', $keyVal)] = $i;
+ } else {
+ $result[$keyVal] = $i;
+ }
+ } else if (!empty($keyVal)) {
+ $toFetch[] = $keyVal;
+ }
+ }
+
+ if (count($toFetch) > 0) {
+ $i = new $cls;
+ foreach ($otherCols as $otherKeyCol => $otherKeyVal) {
+ $i->$otherKeyCol = $otherKeyVal;
+ }
+ if (is_array($keyCol)) {
+ $i->whereAdd(self::_inMultiKey($i, $keyCol, $toFetch));
+ } else {
+ $i->whereAddIn($keyCol, $toFetch, $i->columnType($keyCol));
+ }
+ if ($i->find()) {
+ while ($i->fetch()) {
+ $copy = clone($i);
+ $copy->encache();
+ if (is_array($keyCol)) {
+ $vals = array();
+ foreach ($keyCol as $k) {
+ $vals[] = $i->$k;
+ }
+ $result[implode(',', $vals)] = $copy;
+ } else {
+ $result[$i->$keyCol] = $copy;
+ }
+ }
+ }
+
+ // Save state of DB misses
+
+ foreach ($toFetch as $keyVal) {
+ $r = null;
+ if (is_array($keyCol)) {
+ $r = $result[implode(',', $keyVal)];
+ } else {
+ $r = $result[$keyVal];
+ }
+ if (empty($r)) {
+ if (is_array($keyCol)) {
+ $kv = array_combine($keyCol, $keyVal);
+ } else {
+ $kv = array($keyCol => $keyVal);
+ }
+ $kv = array_merge($otherCols, $kv);
+ // save the fact that no such row exists
+ $c = self::memcache();
+ if (!empty($c)) {
+ $ck = self::multicacheKey($cls, $kv);
+ $c->set($ck, null);
+ }
+ }
+ }
+ }
+
+ return $result;
+ }
+
+ static function _inMultiKey($i, $cols, $values)
+ {
+ $types = array();
+
+ foreach ($cols as $col) {
+ $types[$col] = $i->columnType($col);
+ }
+
+ $first = true;
+
+ $query = '';
+
+ foreach ($values as $value) {
+ if ($first) {
+ $query .= '( ';
+ $first = false;
+ } else {
+ $query .= ' OR ';
+ }
+ $query .= '( ';
+ $i = 0;
+ $firstc = true;
+ foreach ($cols as $col) {
+ if (!$firstc) {
+ $query .= ' AND ';
+ } else {
+ $firstc = false;
+ }
+ switch ($types[$col]) {
+ case 'string':
+ case 'datetime':
+ $query .= sprintf("%s = %s", $col, $i->_quote($value[$i]));
+ break;
+ default:
+ $query .= sprintf("%s = %s", $col, $value[$i]);
+ break;
+ }
+ }
+ $query .= ') ';
+ }
+
+ if (!$first) {
+ $query .= ' )';
+ }
+
+ return $query;
+ }
+
+ static function pkeyColsClass($cls)
+ {
+ $i = new $cls;
+ $types = $i->keyTypes();
+ ksort($types);
+
+ $pkey = array();
+
+ foreach ($types as $key => $type) {
+ if ($type == 'K' || $type == 'N') {
+ $pkey[] = $key;
+ }
+ }
+
+ return $pkey;
+ }
+
+ static function listFindClass($cls, $keyCol, array $keyVals)
+ {
+ $i = new $cls;
+ $i->whereAddIn($keyCol, $keyVals, $i->columnType($keyCol));
+ if (!$i->find()) {
+ throw new NoResultException($i);
+ }
+
+ return $i;
+ }
+
+ static function listGetClass($cls, $keyCol, array $keyVals)
+ {
+ $pkeyMap = array_fill_keys($keyVals, array());
+ $result = array_fill_keys($keyVals, array());
+
+ $pkeyCols = static::pkeyCols();
+
+ $toFetch = array();
+ $allPkeys = array();
+
+ // We only cache keys -- not objects!
+
+ foreach ($keyVals as $keyVal) {
+ $l = self::cacheGet(sprintf("%s:list-ids:%s:%s", strtolower($cls), $keyCol, $keyVal));
+ if ($l !== false) {
+ $pkeyMap[$keyVal] = $l;
+ foreach ($l as $pkey) {
+ $allPkeys[] = $pkey;
+ }
+ } else {
+ $toFetch[] = $keyVal;
+ }
+ }
+
+ if (count($allPkeys) > 0) {
+ $keyResults = self::pivotGetClass($cls, $pkeyCols, $allPkeys);
+
+ foreach ($pkeyMap as $keyVal => $pkeyList) {
+ foreach ($pkeyList as $pkeyVal) {
+ $i = $keyResults[implode(',',$pkeyVal)];
+ if (!empty($i)) {
+ $result[$keyVal][] = $i;
+ }
+ }
+ }
+ }
+
+ if (count($toFetch) > 0) {
+ try {
+ $i = self::listFindClass($cls, $keyCol, $toFetch);
+
+ while ($i->fetch()) {
+ $copy = clone($i);
+ $copy->encache();
+ $result[$i->$keyCol][] = $copy;
+ $pkeyVal = array();
+ foreach ($pkeyCols as $pkeyCol) {
+ $pkeyVal[] = $i->$pkeyCol;
+ }
+ $pkeyMap[$i->$keyCol][] = $pkeyVal;
+ }
+ } catch (NoResultException $e) {
+ // no results found for our keyVals, so we leave them as empty arrays
+ }
+ foreach ($toFetch as $keyVal) {
+ self::cacheSet(sprintf("%s:list-ids:%s:%s", strtolower($cls), $keyCol, $keyVal),
+ $pkeyMap[$keyVal]);
+ }
+ }
+
+ return $result;
+ }
+
+ function columnType($columnName)
+ {
+ $keys = $this->table();
+ if (!array_key_exists($columnName, $keys)) {
+ throw new Exception('Unknown key column ' . $columnName . ' in ' . join(',', array_keys($keys)));
+ }
+
+ $def = $keys[$columnName];
+
+ if ($def & DB_DATAOBJECT_INT) {
+ return 'integer';
+ } else {
+ return 'string';
+ }
+ }
+
+ /**
+ * @todo FIXME: Should this return false on lookup fail to match getKV?
+ */
+ static function pkeyGetClass($cls, array $kv)
+ {
+ $i = self::multicache($cls, $kv);