@@ 632-639 (lines=8) @@ | ||
629 | $tableDef = $this->tables[$table]; |
|
630 | $colSql = ''; |
|
631 | $valSql = ''; |
|
632 | foreach ($tableDef['columns'] as $col) { |
|
633 | $comma = empty($colSql) ? '' : ', '; |
|
634 | if (isset($columns[$col['name']])) { |
|
635 | $colSql .= "{$comma}`{$col['name']}`"; |
|
636 | $valSql .= $comma |
|
637 | . ($quoteValue ? $this->db->quote($columns[$col['name']]) : $columns[$col['name']]); |
|
638 | } |
|
639 | } |
|
640 | $sql = "INSERT INTO `{$tableDef['name']}` ({$colSql}) VALUES({$valSql})"; |
|
641 | $this->queue[] = $sql; |
|
642 | ||
@@ 670-676 (lines=7) @@ | ||
667 | $where = $criteria->renderWhere(); |
|
668 | } |
|
669 | $colSql = ''; |
|
670 | foreach ($tableDef['columns'] as $col) { |
|
671 | $comma = empty($colSql) ? '' : ', '; |
|
672 | if (isset($columns[$col['name']])) { |
|
673 | $colSql .= "{$comma}`{$col['name']}` = " |
|
674 | . ($quoteValue ? $this->db->quote($columns[$col['name']]) : $columns[$col['name']]); |
|
675 | } |
|
676 | } |
|
677 | $sql = "UPDATE `{$tableDef['name']}` SET {$colSql} {$where}"; |
|
678 | $this->queue[] = $sql; |
|
679 |