Thinkphp與Oracle之間的各種問(wèn)題

public function insert($data, $options = array(), $replace = false)
{
 if (!$replace) {
 return parent::insert($data, $options, $replace);
 }
 $values = $fields = array();
 $this->model = $options['model'];
 $sql_merge = 'MERGE INTO ' . $this->parseTable($options['table']) .
 ' using (select 1 from dual) ' .
 ' ON (' . $this->parseValue($data[$options['marge_key']]) . ' is not null and ' . $this->parseValue($data[$options['marge_key']]) . ' = ' . $options['marge_key'] . ')';
 //insert
 foreach ($data as $key => $val) {
 //主鍵值為空時(shí)，不插入主鍵
 if ($this->parseKey($key) == $this->parseKey($options['marge_key'])
 && $val == null
 ) {
 } elseif (is_array($val) && 'exp' == $val[0]) {
 $fields[] = $this->parseKey($key);
 $values[] = $val[1];
 } elseif (is_scalar($val) || is_null(($val))) { // 過(guò)濾非標(biāo)量數(shù)據(jù)
 $fields[] = $this->parseKey($key);
 if (C('DB_BIND_PARAM') && 0 !== strpos($val, ':')) {
 $name = md5($key);
 $values[] = ':' . $name;
 $this->bindParam($name, $val);
 } else {
 $values[] = $this->parseValue($val);
 }
 }
 }
 $sql_insert = 'INSERT (' . implode(',', $fields) . ') VALUES (' . implode(',', $values) . ')';
 //update
 if (isset($data[$this->parseKey($options['marge_key'])])
 || $data[$this->parseKey($options['marge_key'])] == null
 ) {
 unset($data[$this->parseKey($options['marge_key'])]);
 }
 $sql_update = 'UPDATE '
 . $this->parseSet($data)
 . $this->parseWhere(!empty($options['where']) ? $options['where'] : '')
 . $this->parseOrder(!empty($options['order']) ? $options['order'] : '')
 . $this->parseLimit(!empty($options['limit']) ? $options['limit'] : '');
 $sql = $sql_merge . ' WHEN MATCHED THEN ' . $sql_update . ' WHEN NOT MATCHED THEN ' . $sql_insert;
 return $this->execute($sql, $this->parseBind(!empty($options['bind']) ? $options['bind'] : array()));
}

/**
 * 啟動(dòng)事務(wù)
 * @access public
 * @return void
 */
 public function startTrans() {
 $this->initConnect(true);
 if ( !$this->_linkID ) return false;
 //數(shù)據(jù)rollback 支持
 if ($this->transTimes == 0) {
 $this->mode = OCI_DEFAULT;
 }
 $this->transTimes++;
 return ;
}
/**
 * 用于非自動(dòng)提交狀態(tài)下面的查詢提交
 * @access public
 * @return boolen
 */
public function commit(){
 if ($this->transTimes > 0) {
 $result = oci_commit($this->_linkID);
 if(!$result){
 $this->error();
 return false;
 }
 $this->mode = OCI_COMMIT_ON_SUCCESS;//陳宣亦 2014.11.09 14:07
 $this->transTimes = 0;
 }
 return true;
}
/**
 * 事務(wù)回滾
 * @access public
 * @return boolen
 */
 public function rollback(){
 if ($this->transTimes > 0) {
 $result = oci_rollback($this->_linkID);
 if(!$result){
 $this->error();
 return false;
 }
 $this->mode = OCI_COMMIT_ON_SUCCESS;//陳宣亦 2014.11.09 14:07
 $this->transTimes = 0;
 }
 return true;
}