ORA-01461: can bind a LONG value only for insert into a LONG column

oracle clob字段在用常規 新增或修改數據庫時 若是字符超過4000(一箇中文兩個字符) 就會報這個錯,解決辦法是採用預處理的方式,單獨對clob類型字段進行預處理存儲,以下

調用方式:

$result = doClob( 'table_name',$clob_data,'update',"id=123");

封裝公共函數:

function doClob( $table, $data, $type = 'update', $wherestr = null ,$seqname = null){
    import('Org.Util.Ociclob');
    $clog_obj= new \Think\Ociclob($table, $data);
    $clog_obj->table = $table;
    $clog_obj->data= $data;
    if( strtolower( $type ) == 'update'){
        $clog_obj->where= $wherestr;
        $flag = $clog_obj->update();
    }else if(strtolower( $type ) == 'insert' ){
        $clog_obj->seqname= strtoupper($seqname);
        $flag = $clog_obj->insert();
    }
    return $flag;
}

引入類的方式:

 

 

Ociclob類代碼

<?php
namespace Think;
class Ociclob{

    public $conn = false ;
    public $table = '' ;
    public $seqname = '' ;
    public $where = '' ;
    public $lob = '' ;
    public $data = '' ;

    function  __construct(){
        $this->conn = $this->db_connect();
        if(!empty($table)) $this->table=$table;
        if(!empty($table)&&!empty($data)){
            $this->checkfield($table,$data);
        }
    }

    //檢測字段屬性
    public function checkfield($table,$data){
        if(!empty($table)&&!empty($data)){
            $fields=$this->getFields($table);

            foreach ($data as $key=>$value){
                //檢測lob字段
                if(strtolower($fields[strtolower($key)]['type'])=='clob')  $lob[]=$key;
                //檢測PK字段並獲取SEQ
                if(strtolower($fields[strtolower($key)]['primary'])==1){
                    $this->seqname=$value;
                    $this->data[$key]=$this->getseq();//根據自動填充主鍵值
                    $pk=$key;//主鍵被設置標誌
                }
            }
            $this->lob=$lob;
            //若是沒有在DATA中的設置主鍵值，則根據SEQNAME自動填充
            if(!isset($pk)&&!empty($this->seqname)) {
                $this->data[$fields['pk']]=$this->getseq();
            }
            unset($lob);
            unset($pk);
        }

    }

    /**
    +----------------------------------------------------------
    * 鏈接ORACLE
    +----------------------------------------------------------
    */
    public function db_connect(){
        $db_pwd = C('ENCRYPT_KEY')?_decrypt(C('DB_PWD'), C('ENCRYPT_KEY')):C('DB_PWD');
        $this->conn = oci_connect(C('DB_USER'), $db_pwd, C('DB_HOST').':'.C('DB_PORT').'/'.C('DB_NAME'), C('DB_CHARSET'));
        return $this->conn;
    }

    /**
    +----------------------------------------------------------
    * 設置ORACLE字符集
    +----------------------------------------------------------
    */
    public function charset($code='UTF8'){
        $sql="ALTER DATABASE CHARACTER SET $code";
        $stmt = oci_parse($this->conn, $sql);
        oci_execute($stmt);
        oci_commit($this->conn);
        // Free resources
        oci_free_statement($stmt);
    }
    /**
    +----------------------------------------------------------
    * 添加包含有CLOB字段的記錄
    +----------------------------------------------------------
    */
    public function insert (){

        //檢測字段屬性
        if(empty($this->lob)) $this->checkfield($this->table,$this->data);
        //字段整理
        $f=strtoupper(join(',',array_keys($this->data)));
        //數據整理
        foreach ($this->data as $key=>$val){
            $f_v_arr[]=!in_array($key,$this->lob)?"'".$val."'":"EMPTY_CLOB()";
        }
        $f_v=join(',',$f_v_arr);

        //lob字段清理並賦值LOB數據到綁定變量
        for ($i=0;$i<count($this->lob);$i++){
            $lob_str.=":".$this->lob[$i]."_loc,";
        }
        $returning_str.="  RETURNING ".join(',',$this->lob)." INTO ".rtrim($lob_str,',');

        //組裝SQL
        $sql = "INSERT INTO  $this->table ($f) VALUES(".$f_v.")".$returning_str ;

        $stmt = oci_parse($this->conn, $sql);

        for ($i=0;$i<count($this->lob);$i++){
            // 建立一個「空」的OCI LOB對象綁定到定位器
            $$this->lob[$i] = oci_new_descriptor($this->conn, OCI_D_LOB);
            $lob_str=":".$this->lob[$i]."_loc";
            // 將Oracle LOB定位器綁定到PHP LOB對象
            oci_bind_by_name($stmt, $lob_str, $$this->lob[$i], -1, OCI_B_CLOB);
        }
        // 執行該語句的使用，oci_default -做爲一個事務
        oci_execute($stmt, OCI_DEFAULT)    or die ("Unable to execute query\n");
        // 保存LOB對象數據
        for ($i=0;$i<count($this->lob);$i++){
            if(!$$this->lob[$i]->save($this->data[$this->lob[$i]])){
                $result=false;
                break;
            }
        }
        if ( isset($result)&&$result==false ) {
            // 若是錯誤，則回滾事務
            oci_rollback($this->conn);
            $ret=false;
        } else {
            // 若是成功，則提交
            oci_commit($this->conn);
            $ret=true;
        }
        // 釋放資源
        oci_free_statement($stmt);
        for ($i=0;$i<count($this->lob);$i++){
            $$this->lob[$i]->free();
        }

        return $ret;
    }

    /**
    +----------------------------------------------------------
    * 更新CLOB字段的內容
    +----------------------------------------------------------
    */
    public function update(){
        //檢測字段屬性
        if(empty($this->lob)) $this->checkfield($this->table,$this->data);

        //數據整理
        foreach ($this->data as $key=>$val){
            $set_arr[]=!in_array($key,$this->lob)?strtoupper($key)."='".$val."'":$key."=EMPTY_CLOB()";
        }
        $set_str=join(',',$set_arr);

        //lob字段清理並賦值LOB數據到綁定變量

        for ($i=0;$i<count($this->lob);$i++){
            $lob_str.=":".$this->lob[$i]."_loc,";
        }

        $returning_str.=" RETURNING ".join(',',$this->lob)." INTO ".rtrim($lob_str,',');
        $where_str=strtoupper($this->where);
        //組裝SQL
        $sql = "UPDATE $this->table SET $set_str WHERE $where_str ".$returning_str;

        $stmt = oci_parse($this->conn, $sql);
        for ($i=0;$i<count($this->lob);$i++){
            // 建立一個「空」的OCI LOB對象綁定到定位器
            $$this->lob[$i] = oci_new_descriptor($this->conn, OCI_D_LOB);
            $lob_str=":".$this->lob[$i]."_loc";
            // 將Oracle LOB定位器綁定到PHP LOB對象
            oci_bind_by_name($stmt, $lob_str, $$this->lob[$i], -1, OCI_B_CLOB);
        }

        // 執行該語句的使用，oci_default -做爲一個事務
        oci_execute($stmt, OCI_DEFAULT)  or die("Unable to execute query\n");

        // 保存LOB對象數據
        for ($i=0;$i<count($this->lob);$i++){
            if(!$$this->lob[$i]->save($this->data[$this->lob[$i]])){
                $result=false;
                break;
            }
        }
        if ( isset($result)&&$result==false ) {

            OCIRollback($this->conn);
            $ret=false;

        }else $ret=true;

        // 提交事務
        oci_commit($this->conn);
        //釋放資源
        for ($i=0;$i<count($this->lob);$i++){
            $$this->lob[$i]->free();
        }
        OCIFreeStatement($stmt);

        return $ret;
    }
    public function getseq(){
        $sql="select $this->seqname.nextval from dual";

        $stmt = oci_parse($this->conn, strtoupper($sql));
        oci_execute($stmt);

        while ( $row = oci_fetch_array($stmt, OCI_ASSOC+OCI_RETURN_LOBS) ) {
            $data[]=$row;
        }
        // 釋放資源
        oci_free_statement($stmt);

        return $data['0']['NEXTVAL'];
    }

    /**
    +----------------------------------------------------------
    * 查詢包含有CLOB字段的記錄
    +----------------------------------------------------------
    */
    public function select ($sql=''){
        $sql = empty($sql)?"SELECT * FROM  $this->table  WHERE $this->where ":$sql;

        $stmt = oci_parse($this->conn, strtoupper($sql));
        oci_execute($stmt);

        while ( $row = oci_fetch_array($stmt, OCI_ASSOC+OCI_RETURN_LOBS) ) {
            $data[]=$row;
        }
        // 釋放資源
        oci_free_statement($stmt);
        return $data;
    }

     /**
    +----------------------------------------------------------
    * 查詢包含有CLOB字段的記錄
    +----------------------------------------------------------
    */
    public function row ($sql=''){
        $sql = empty($sql)?"SELECT * FROM  $this->table  WHERE $this->where ":$sql;

        $stmt = oci_parse($this->conn, strtoupper($sql));
        oci_execute($stmt);
        $row = oci_fetch_array($stmt, OCI_ASSOC+OCI_RETURN_LOBS);
        // 釋放資源
        oci_free_statement($stmt);
        return $row;
    }

    /**
     * 取得數據表的字段信息
     * @access public
     */
     public function getFields($tableName) {
          $sql="select a.column_name,data_type,decode(nullable,'Y',0,1) notnull,data_default,decode(a.column_name,b.column_name,1,0) pk "
                  ."from user_tab_columns a,(select column_name from user_constraints c,user_cons_columns col "
          ."where c.constraint_name=col.constraint_name and c.constraint_type='P'and c.table_name='".strtoupper($tableName)
          ."') b where table_name='".strtoupper($tableName)."' and a.column_name=b.column_name(+)";

        $result=  $this->select($sql);

        $info   =   array();
        if($result) {
            foreach ($result as $key => $val) {
                $info[strtolower($val['COLUMN_NAME'])] = array(
                    'name'    => strtolower($val['COLUMN_NAME']),
                    'type'    => strtolower($val['DATA_TYPE']),
                    'notnull' => $val['NOTNULL'],
                    'default' => $val['DATA_DEFAULT'],
                    'primary' => $val['PK'],
                    'autoinc' => $val['PK'],
                );
                if($val['PK']==1) $info['pk']=$val['COLUMN_NAME'];
            }
        }
        return $info;
    }



}