| @@ 682-688 (lines=7) @@ | ||
| 679 | $tableDef = &$this->tables[$table]; |
|
| 680 | $colSql = ''; |
|
| 681 | $valSql = ''; |
|
| 682 | foreach ($tableDef['columns'] as $col) { |
|
| 683 | $comma=empty($colSql)?'':', '; |
|
| 684 | if (isset($columns[$col['name']])) { |
|
| 685 | $colSql .= $comma.$col['name']; |
|
| 686 | $valSql .= $comma.$this->db->quote($columns[$col['name']]); |
|
| 687 | } |
|
| 688 | } |
|
| 689 | $sql = "INSERT INTO `{$tableDef['name']}` ({$colSql}) VALUES({$valSql})"; |
|
| 690 | $this->queue[]=$sql; |
|
| 691 | ||
| @@ 721-727 (lines=7) @@ | ||
| 718 | $where = $criteria->renderWhere(); |
|
| 719 | } |
|
| 720 | $colSql = ''; |
|
| 721 | foreach ($tableDef['columns'] as $col) { |
|
| 722 | $comma=empty($colSql)?'':', '; |
|
| 723 | if (isset($columns[$col['name']])) { |
|
| 724 | $colSql .= $comma . $col['name'] . ' = ' |
|
| 725 | . $this->db->quote($columns[$col['name']]); |
|
| 726 | } |
|
| 727 | } |
|
| 728 | $sql = "UPDATE `{$tableDef['name']}` SET {$colSql} {$where}"; |
|
| 729 | $this->queue[]=$sql; |
|
| 730 | ||