@@ 619-625 (lines=7) @@ | ||
616 | $tableDef = $this->tables[$table]; |
|
617 | $colSql = ''; |
|
618 | $valSql = ''; |
|
619 | foreach ($tableDef['columns'] as $col) { |
|
620 | $comma = empty($colSql) ? '' : ', '; |
|
621 | if (isset($columns[$col['name']])) { |
|
622 | $colSql .= $comma . $col['name']; |
|
623 | $valSql .= $comma . $this->db->quote($columns[$col['name']]); |
|
624 | } |
|
625 | } |
|
626 | $sql = "INSERT INTO `{$tableDef['name']}` ({$colSql}) VALUES({$valSql})"; |
|
627 | $this->queue[] = $sql; |
|
628 | ||
@@ 655-661 (lines=7) @@ | ||
652 | $where = $criteria->renderWhere(); |
|
653 | } |
|
654 | $colSql = ''; |
|
655 | foreach ($tableDef['columns'] as $col) { |
|
656 | $comma = empty($colSql) ? '' : ', '; |
|
657 | if (isset($columns[$col['name']])) { |
|
658 | $colSql .= $comma . $col['name'] . ' = ' |
|
659 | . $this->db->quote($columns[$col['name']]); |
|
660 | } |
|
661 | } |
|
662 | $sql = "UPDATE `{$tableDef['name']}` SET {$colSql} {$where}"; |
|
663 | $this->queue[] = $sql; |
|
664 |