欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2024-03-13 13:58:27
使用codeiginter 框架插入数据时有唯一索引键值存在解决办法 对数据进行存储的时候,会有一些唯一索引的字段已经有值了,插入数据的时候会失败我们通常解决办法是先查询...

使用codeiginter 框架插入数据时有唯一索引键值存在解决办法

对数据进行存储的时候,会有一些唯一索引的字段已经有值了,插入数据的时候会失败我们通常解决办法是先查询这个值是否存在,存在就跟新update,不存在就insert。以下是重写了codeigniter 模型中的insert方法,极大的简化了步骤!

/**
 * 插入单条记录(insert)
 *
 * @param array $params 插入字段及值数组
 * @param string $table 插入表名,未指定的场景插入主表
 * @param array $columns 插入表中所属字段名数组,若指定则按此进行过滤
 * @param array $updatecolumns 若唯一键冲突时需要更新的列数组
 * @return mixed false:没有插入的字段 int:插入记录id
 *
 * @throws \c_db_exception
 */
public function insert($params, $table = null, $columns = array(), $updatecolumns = array())
{
  // 如果未指定表名,则认为对本model层的主表进行操作
  if (empty($table)) {
    $table = $this->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('', $this->user_id, $sql, self::status_db_log);
  }
  // 取得插入id返回
  $id = $this->db->insert_id();
  return $id;
}

如果直接写sql还有一种语句

语法: insert into table values () on duplicate key update row='$row'

举个例子:

insert into it_teacher (uid,name,qq,create_at) 
values ('$userid','$name','$qq',now()) on duplicate key update name='$name',qq='$qq',phone='$phone'";

以上这篇使用codeigniter重写insert的方法(推荐)就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。