| @@ 656-662 (lines=7) @@ | ||
| 653 | $tableDef = $this->tables[$table]; |
|
| 654 | $colSql = ''; |
|
| 655 | $valSql = ''; |
|
| 656 | foreach ($tableDef['columns'] as $col) { |
|
| 657 | $comma = empty($colSql) ? '' : ', '; |
|
| 658 | if (isset($columns[$col['name']])) { |
|
| 659 | $colSql .= $comma . $col['name']; |
|
| 660 | $valSql .= $comma . $this->db->quote($columns[$col['name']]); |
|
| 661 | } |
|
| 662 | } |
|
| 663 | $sql = "INSERT INTO `{$tableDef['name']}` ({$colSql}) VALUES({$valSql})"; |
|
| 664 | $this->queue[] = $sql; |
|
| 665 | ||
| @@ 692-698 (lines=7) @@ | ||
| 689 | $where = $criteria->renderWhere(); |
|
| 690 | } |
|
| 691 | $colSql = ''; |
|
| 692 | foreach ($tableDef['columns'] as $col) { |
|
| 693 | $comma = empty($colSql) ? '' : ', '; |
|
| 694 | if (isset($columns[$col['name']])) { |
|
| 695 | $colSql .= $comma . $col['name'] . ' = ' |
|
| 696 | . $this->db->quote($columns[$col['name']]); |
|
| 697 | } |
|
| 698 | } |
|
| 699 | $sql = "UPDATE `{$tableDef['name']}` SET {$colSql} {$where}"; |
|
| 700 | $this->queue[] = $sql; |
|
| 701 | ||