'numeric(20)', 'number' => 'integer', 'varchar' => 'character varying', 'char' => 'character', 'text' => 'character varying(1073741823)', 'bigtext' => 'character varying(1073741823)', 'date' => 'character varying(14)', 'float' => 'float', ); /** * @brief constructor **/ function DBCubrid() { $this->_setDBInfo(); $this->_connect(); } /** * @brief 설치 가능 여부를 return **/ function isSupported() { if(!function_exists('cubrid_connect')) return false; return true; } /** * @brief DB정보 설정 및 connect/ close **/ function _setDBInfo() { $db_info = Context::getDBInfo(); $this->hostname = $db_info->db_hostname; $this->userid = $db_info->db_userid; $this->password = $db_info->db_password; $this->database = $db_info->db_database; $this->port = $db_info->db_port; $this->prefix = $db_info->db_table_prefix; if(!substr($this->prefix,-1)!='_') $this->prefix .= '_'; } /** * @brief DB 접속 **/ function _connect() { // db 정보가 없으면 무시 if(!$this->hostname || !$this->userid || !$this->password || !$this->database || !$this->port) return; // 접속시도 $this->fd = @cubrid_connect($this->hostname, $this->port, $this->database, $this->userid, $this->password); // 접속체크 if(!$this->fd) { $this->setError(-1, 'database connect fail'); return $this->is_connected = false; } $this->is_connected = true; $this->password = md5($this->password); } /** * @brief DB접속 해제 **/ function close() { if(!$this->isConnected()) return; @cubrid_commit($this->fd); @cubrid_disconnect($this->fd); $this->transaction_started = false; } /** * @brief 쿼리에서 입력되는 문자열 변수들의 quotation 조절 **/ function addQuotes($string) { if(!$this->fd) return $string; if(version_compare(PHP_VERSION, "5.9.0", "<") && get_magic_quotes_gpc()) $string = stripslashes(str_replace("\\","\\\\",$string)); if(!is_numeric($string)) $string = str_replace("'","''",$string); return $string; } /** * @brief 트랜잭션 시작 **/ function begin() { if(!$this->isConnected() || $this->transaction_started) return; $this->transaction_started = true; } /** * @brief 롤백 **/ function rollback() { if(!$this->isConnected() || !$this->transaction_started) return; @cubrid_rollback($this->fd); $this->transaction_started = false; } /** * @brief 커밋 **/ function commit() { if(!$force && (!$this->isConnected() || !$this->transaction_started)) return; @cubrid_commit($this->fd); $this->transaction_started = false; } /** * @brief : 쿼리문의 실행 및 결과의 fetch 처리 * * query : query문 실행하고 result return\n * fetch : reutrn 된 값이 없으면 NULL\n * rows이면 array object\n * row이면 object\n * return\n **/ function _query($query) { //echo "(((".$this->backtrace().")))"; if(!$query || !$this->isConnected()) return; // 쿼리 시작을 알림 $this->actStart($query); // 쿼리 문 실행 $result = @cubrid_execute($this->fd, $query); // 오류 체크 if(cubrid_error_code()) $this->setError(cubrid_error_code(), cubrid_error_msg()); // 쿼리 실행 종료를 알림 $this->actFinish(); // 결과 리턴 return $result; } /** * @brief 결과를 fetch **/ function _fetch($result) { if(!$this->isConnected() || $this->isError() || !$result) return; while($tmp = cubrid_fetch($result, CUBRID_OBJECT)) { $output[] = $tmp; } if($result) cubrid_close_request($result); if(count($output)==1) return $output[0]; return $output; } /** * @brief 1씩 증가되는 sequence값을 return (cubrid의 auto_increment는 sequence테이블에서만 사용) **/ function getNextSequence() { $query = sprintf("select %ssequence.nextval as seq from db_root", $this->prefix); $result = $this->_query($query); $output = $this->_fetch($result); return $output->seq; } /** * @brief 테이블 기생성 여부 return **/ function isTableExists($target_name) { if($target_name == 'sequence') $query = sprintf("select * from db_serial where name = '%s%s'", $this->prefix, $target_name); else $query = sprintf("select * from db_class where class_name = '%s%s'", $this->prefix, $target_name); $result = $this->_query($query); if(cubrid_num_rows($result)>0) $output = true; else $output = false; if($result) cubrid_close_request($result); return $output; } /** * @brief 특정 테이블에 특정 column 추가 **/ function addColumn($table_name, $column_name, $type='number', $size='', $default = '', $notnull=false) { $type = $this->column_type[$type]; if(strtoupper($type)=='INTEGER') $size = ''; $query = sprintf("alter class %s%s add %s ", $this->prefix, $table_name, $column_name); if($size) $query .= sprintf(" %s(%s) ", $type, $size); else $query .= sprintf(" %s ", $type); if($default) $query .= sprintf(" default '%s' ", $default); if($notnull) $query .= " not null "; $this->_query($query); } /** * @brief 특정 테이블에 특정 column 제거 **/ function dropColumn($table_name, $column_name) { $query = sprintf("alter class %s%s drop %s ", $this->prefix, $table_name, $column_name); $this->_query($query); } /** * @brief 특정 테이블의 column의 정보를 return **/ function isColumnExists($table_name, $column_name) { $query = sprintf("select * from db_attribute where attr_name ='%s' and class_name = '%s%s'", $column_name, $this->prefix, $table_name); $result = $this->_query($query); if(cubrid_num_rows($result)>0) $output = true; else $output = false; if($result) cubrid_close_request($result); return $output; } /** * @brief 특정 테이블에 특정 인덱스 추가 * $target_columns = array(col1, col2) * $is_unique? unique : none **/ function addIndex($table_name, $index_name, $target_columns, $is_unique = false) { if(!is_array($target_columns)) $target_columns = array($target_columns); $query = sprintf("create %s index %s on %s%s (%s);", $is_unique?'unique':'', $index_name, $this->prefix, $table_name, '"'.implode('","',$target_columns).'"'); $this->_query($query); } /** * @brief 특정 테이블의 특정 인덱스 삭제 **/ function dropIndex($table_name, $index_name, $is_unique = false) { $query = sprintf("drop %s index %s on %s%s", $is_unique?'unique':'', $index_name, $this->prefix, $table_name); $this->_query($query); } /** * @brief 특정 테이블의 index 정보를 return **/ function isIndexExists($table_name, $index_name) { $query = sprintf("select * from db_index where class_name='%s%s' and index_name = '%s' ", $this->prefix, $table_name, $index_name); $result = $this->_query($query); if($this->isError()) return false; $output = $this->_fetch($result); if(!$output) return false; return true; } /** * @brief xml 을 받아서 테이블을 생성 **/ function createTableByXml($xml_doc) { return $this->_createTable($xml_doc); } /** * @brief xml 을 받아서 테이블을 생성 **/ function createTableByXmlFile($file_name) { if(!file_exists($file_name)) return; // xml 파일을 읽음 $buff = FileHandler::readFile($file_name); return $this->_createTable($buff); } /** * @brief schema xml을 이용하여 create class query생성 * * type : number, varchar, text, char, date, \n * opt : notnull, default, size\n * index : primary key, index, unique\n **/ function _createTable($xml_doc) { // xml parsing $oXml = new XmlParser(); $xml_obj = $oXml->parse($xml_doc); // 테이블 생성 schema 작성 $table_name = $xml_obj->table->attrs->name; // 만약 테이블 이름이 sequence라면 serial 생성 if($table_name == 'sequence') { $query = sprintf('create serial %s start with 1 increment by 1 minvalue 1 maxvalue 10000000000000000000000000000000000000 nocycle;', $this->prefix.$table_name); return $this->_query($query); } if($this->isTableExists($table_name)) return; $table_name = $this->prefix.$table_name; $query = sprintf('create class "%s";', $table_name); $this->_query($query); /*$query = sprintf("call change_owner('%s','%s') on class db_root;", $table_name, $this->userid); $this->_query($query); */ if(!is_array($xml_obj->table->column)) $columns[] = $xml_obj->table->column; else $columns = $xml_obj->table->column; $query = sprintf("alter class \"%s\" add attribute ", $table_name); foreach($columns as $column) { $name = $column->attrs->name; $type = $column->attrs->type; $size = $column->attrs->size; $notnull = $column->attrs->notnull; $primary_key = $column->attrs->primary_key; $index = $column->attrs->index; $unique = $column->attrs->unique; $default = $column->attrs->default; switch($this->column_type[$type]) { case 'integer' : $size = null; break; case 'text' : $size = null; break; } if($default && (!is_numeric($default) || $default[0] == "+")) $default = "'".$default."'"; $column_schema[] = sprintf('"%s" %s%s %s %s', $name, $this->column_type[$type], $size?'('.$size.')':'', $default?"default ".$default:'', $notnull?'not null':'' ); if($primary_key) $primary_list[] = $name; else if($unique) $unique_list[$unique][] = $name; else if($index) $index_list[$index][] = $name; } $query .= implode(',', $column_schema).';'; $this->_query($query); if(count($primary_list)) { $query = sprintf("alter class %s add attribute constraint \"pkey_%s\" PRIMARY KEY(%s);", $table_name, $table_name, '"'.implode('","',$primary_list).'"'); $this->_query($query); } if(count($unique_list)) { foreach($unique_list as $key => $val) { $query = sprintf("create unique index %s_%s on %s (%s);", $table_name, $key, $table_name, '"'.implode('","',$val).'"'); $this->_query($query); } } if(count($index_list)) { foreach($index_list as $key => $val) { $query = sprintf("create index \"%s_%s\" on %s (%s);", $table_name, $key, $table_name, '"'.implode('","',$val).'"'); $this->_query($query); } } } /** * @brief 조건문 작성하여 return **/ function getCondition($output) { if(!$output->conditions) return; $condition = $this->_getCondition($output->conditions,$output->column_type); if($condition) $condition = ' where '.$condition; return $condition; } function getLeftCondition($conditions,$column_type){ return $this->_getCondition($conditions,$column_type); } function _getCondition($conditions,$column_type) { $condition = ''; foreach($conditions as $val) { $sub_condition = ''; foreach($val['condition'] as $v) { if(!isset($v['value'])) continue; if($v['value'] === '') continue; if(!in_array(gettype($v['value']), array('string', 'integer'))) continue; $name = $v['column']; $operation = $v['operation']; $value = $v['value']; $type = $this->getColumnType($column_type,$name); $pipe = $v['pipe']; $value = $this->getConditionValue($name, $value, $operation, $type, $column_type); if (!$value) { $value = $v['value']; if (strpos ($value, '(')) $valuetmp = $value; elseif (strpos ($value, ".") === false) $valuetmp = $value; else $valuetmp = '"'.str_replace('.', '"."', $value).'"'; } else $valuetmp = $value; if (strpos ($name, '(') > 0) $nametmp = $name; elseif (strpos ($name, ".") === false) $nametmp = '"'.$name.'"'; else $nametmp = '"'.str_replace('.', '"."', $name).'"'; $str = $this->getConditionPart($nametmp, $valuetmp, $operation); if ($sub_condition) $sub_condition .= ' '.$pipe.' '; $sub_condition .= $str; } if($sub_condition) { if($condition && $val['pipe']) $condition .= ' '.$val['pipe'].' '; $condition .= '('.$sub_condition.')'; } } return $condition; } /** * @brief insertAct 처리 **/ function _executeInsertAct($output) { // 테이블 정리 foreach($output->tables as $key => $val) { $table_list[] = '"'.$this->prefix.$val.'"'; } // 컬럼 정리 foreach($output->columns as $key => $val) { $name = $val['name']; $value = $val['value']; if($this->getColumnType($output->column_type,$name)!='number') { $clen=strlen($value); if ($clen <= $this->cutlen) $value = "'".$this->addQuotes($value)."'"; else { $wrk=""; $off=0; while ($off<$clen) { $wlen=$clen-$off; if ($wlen>$this->cutlen) $wlen=$this->cutlen; if ($off>0) $wrk .= "+\n"; $wrk .= "'".$this->addQuotes(substr($value, $off, $wlen))."'"; $off += $wlen; } $value = $wrk; } if(!$value) $value = 'null'; } elseif(!$value || is_numeric($value)) $value = (int)$value; if(strpos($name,'.')===false) $column_list[] = '"'.$name.'"'; else $column_list[] = $name; $value_list[] = $value; } $query = sprintf("insert into %s (%s) values (%s);", implode(',',$table_list), implode(',',$column_list), implode(',', $value_list)); $result = $this->_query($query); if($result && !$this->transaction_started) @cubrid_commit($this->fd); return $result; } /** * @brief updateAct 처리 **/ function _executeUpdateAct($output) { // 테이블 정리 foreach($output->tables as $key => $val) { $table_list[] = '"'.$this->prefix.$val.'" as "'.$key.'"'; } $check_click_count = true; // 컬럼 정리 foreach($output->columns as $key => $val) { if(!isset($val['value'])) continue; $name = $val['name']; $value = $val['value']; if(substr($value,-2)!='+1') $check_click_count = false; for ($i = 0; $i < $key; $i++) { // 한문장에 같은 속성에 대한 중복 설정은 큐브리드에서는 허용치 않음 if ($output->columns[$i]['name'] == $name) break; } if ($i < $key) continue; // 중복이 발견되면 이후의 설정은 무시 if(strpos($name,'.')!==false&&strpos($value,'.')!==false) $column_list[] = $name.' = '.$value; else { if($output->column_type[$name]!='number') { $check_column = false; $clen=strlen($value); if ($clen <= $this->cutlen) $value = "'".$this->addQuotes($value)."'"; else { $wrk=""; $off=0; while ($off<$clen) { $wlen=$clen-$off; if ($wlen>$this->cutlen) $wlen=$this->cutlen; if ($off>0) $wrk .= "+\n"; $wrk .= "'".$this->addQuotes(substr($value, $off, $wlen))."'"; $off += $wlen; } $value = $wrk; } } elseif(!$value || is_numeric($value)) $value = (int)$value; $column_list[] = sprintf("\"%s\" = %s", $name, $value); } } // 조건절 정리 $condition = $this->getCondition($output); $check_click_count_condition = false; if($check_click_count){ foreach($output->conditions as $val){ if($val['pipe']=='or'){ $check_click_count_condition = false; break; } foreach($val['condition'] as $v){ if($v['operation']=='equal') $check_click_count_condition = true; else{ if($v['operation']=='in' && !strpos($v['value'],',') ) $check_click_count_condition = true; else $check_click_count_condition=false; } if($v['pipe']=='or'){ $check_click_count_condition= false; break; } } } } if($check_click_count && $check_click_count_condition && count($output->tables)==1 && count($output->conditions)>0 && count($output->groups)==0 && count($output->order)==0){ foreach($output->columns as $k => $v) $incr_columns[]= 'incr("'.$v['name'].'")'; $query = sprintf('select %s from %s %s',join(',',$incr_columns), implode(',',$table_list), $condition); }else{ $query = sprintf("update %s set %s %s", implode(',',$table_list), implode(',',$column_list), $condition); } $result = $this->_query($query); if($result && !$this->transaction_started) @cubrid_commit($this->fd); return $result; } /** * @brief deleteAct 처리 **/ function _executeDeleteAct($output) { // 테이블 정리 foreach($output->tables as $key => $val) { $table_list[] = '"'.$this->prefix.$val.'"'; } // 조건절 정리 $condition = $this->getCondition($output); $query = sprintf("delete from %s %s", implode(',',$table_list), $condition); $result = $this->_query($query); if($result && !$this->transaction_started) @cubrid_commit($this->fd); return $result; } /** * @brief selectAct 처리 * * select의 경우 특정 페이지의 목록을 가져오는 것을 편하게 하기 위해\n * navigation이라는 method를 제공 **/ function _executeSelectAct($output) { // 테이블 정리 $table_list = array(); foreach($output->tables as $key => $val) { $table_list[] = '"'.$this->prefix.$val.'" as "'.$key.'"'; } $left_join = array(); // why??? $left_tables = (array)$output->left_tables; foreach($left_tables as $key => $val) { $condition = $this->_getCondition($output->left_conditions[$key],$output->column_type); if($condition) { $left_join[] = $val.' "'.$this->prefix.$output->_tables[$key].'" "'.$key.'" on ('.$condition.')'; } } if(!$output->columns) { $columns = '*'; } else { $column_list = array(); foreach($output->columns as $key => $val) { $name = $val['name']; $click_count = '%s'; if($val['click_count'] && count($output->conditions)>0) { $click_count = 'incr(%s)'; } $alias = $val['alias'] ? sprintf('"%s"',$val['alias']) : null; if(substr($name,-1) == '*') { $column_list[] = $name; } elseif(strpos($name,'.')===false && strpos($name,'(')===false) { $name = sprintf($click_count,$name); if($alias) $column_list[] = sprintf('"%s" as %s', $name, $alias); else $column_list[] = sprintf('"%s"',$name); } else { if(strpos($name,'.')!=false) { list($prefix, $name) = explode('.',$name); $prefix = sprintf('"%s"',$prefix); $name = ($name == '*') ? $name : sprintf('"%s"',$name); $column_list[] = sprintf($click_count,sprintf('%s.%s', $prefix, $name)) . ($alias ? sprintf(' as %s',$alias) : ''); } else { $column_list[] = sprintf($click_count,$name) . ($alias ? sprintf(' as %s',$alias) : ''); } } } $columns = implode(',',$column_list); } $condition = $this->getCondition($output); if($output->list_count && $output->page) return $this->_getNavigationData($table_list, $columns, $left_join, $condition, $output); $query = sprintf("select %s from %s %s %s", $columns, implode(',',$table_list),implode(' ',$left_join), $condition); if (count ($output->groups)) { foreach ($output->groups as $key => $value) { if (strpos ($value, '.')) { $tmp = explode ('.', $value); $tmp[0] = sprintf ('"%s"', $tmp[0]); $tmp[1] = sprintf ('"%s"', $tmp[1]); $value = implode ('.', $tmp); } elseif (strpos ($value, '(')) $value = $value; else $value = sprintf ('"%s"', $value); $output->groups[$key] = $value; } $query .= sprintf(' group by %s', implode(',',$output->groups)); } // list_count를 사용할 경우 적용 if($output->list_count['value']) { $start_count = 0; $list_count = $output->list_count['value']; if ($output->order) { foreach($output->order as $key => $val) { if (strpos ($val[0], '.')) { $tmpval = explode ('.', $val[0]); $tmpval[0] = sprintf ('"%s"', $tmpval[0]); $tmpval[1] = sprintf ('"%s"', $tmpval[1]); $val[0] = implode ('.', $tmpval); } elseif (strpos ($val[0], '(')) $val[0] = $val[0]; elseif ($val[0] == 'count') $val[0] = 'count (*)'; else $val[0] = sprintf ('"%s"', $val[0]); $index_list[] = sprintf('%s %s', $val[0], $val[1]); } if(count($index_list)) $query .= ' order by '.implode(',',$index_list); $query = sprintf('%s for orderby_num() between %d and %d', $query, $start_count + 1, $list_count + $start_count); } else { if (count($output->groups)) $query = sprintf('%s having groupby_num() between %d and %d', $query, $start_count + 1, $list_count + $start_count); else { if ($condition) $query = sprintf('%s and inst_num() between %d and %d', $query, $start_count + 1, $list_count + $start_count); else $query = sprintf('%s where inst_num() between %d and %d', $query, $start_count + 1, $list_count + $start_count); } } } else { if($output->order) { foreach($output->order as $key => $val) { if (strpos ($val[0], '.')) { $tmpval = explode ('.', $val[0]); $tmpval[0] = sprintf ('"%s"', $tmpval[0]); $tmpval[1] = sprintf ('"%s"', $tmpval[1]); $val[0] = implode ('.', $tmpval); } elseif (strpos ($val[0], '(')) $val[0] = $val[0]; elseif ($val[0] == 'count') $val[0] = 'count (*)'; else $val[0] = sprintf ('"%s"', $val[0]); $index_list[] = sprintf('%s %s', $val[0], $val[1]); } if(count($index_list)) $query .= ' order by '.implode(',',$index_list); } } $result = $this->_query($query); if($this->isError()) return; $data = $this->_fetch($result); $buff = new Object(); $buff->data = $data; return $buff; } /** * @brief 현재 시점의 Stack trace를 보여줌.결과를 fetch **/ function backtrace() { $output = "