使用Codeigniter重写insert的方法(推荐)

table; $columns = $this->columns; } // 过滤掉不属于该表中的字段 if ( ! empty($columns)) { foreach ($params as $column => $val) { if (in_array($column,$columns)) { $row[$column] = $val; } } } // 不过滤 else { $row = $params; } // 没有插入字段，直接返回 if ( ! isset($row)) { return FALSE; } // 保证创建时间、更新时间必须设置 if ( ! isset($row['create_at']) && in_array('create_at',$columns)) { $this->load->helper('common_function'); $datetime = get_datetime(); $row['create_at'] = $datetime; $row['update_at'] = $datetime; } // 封装SQL文，过滤不安全因素 $sql = $this->db->insert_string($table,$row); // 若唯一键冲突时需要更新的列数组，则再次封装SQL文 if ( ! empty($updateColumns)) { $updateValues = ''; foreach ($updateColumns as $updateColumn) { if (isset($updateValues[0])) { $updateValues .= ','; } $updateValues .= $updateColumn . '=VALUES(' . $updateColumn . ')'; } $sql = $sql . ' ON DUPLICATE KEY UPDATE ' . $updateValues; } // SQL执行 $query = $this->db->query($sql); // SQL执行失败，抛出异常 if (FALSE === $query) { $code = $this->db->_error_number(); $msg = $this->db->_error_message(); C_log::Error($code . ':' . $msg,$this->user_id,$sql,self::STATUS_DB_LOG); throw new C_DB_Exception('',C_DB_Exception::DB_ERR_CODE); } // SQL文写入DB日志 if (LOG_UPDATE_SQL) { C_log::Info('',self::STATUS_DB_LOG); } // 取得插入ID返回 $id = $this->db->insert_id(); return $id; }