fanbinit/rhymix
1
0
Fork 0
mirror of https://github.com/Lastorder-DC/rhymix.git synced 2026-01-14 00:39:57 +09:00
Code Issues Projects Releases Packages Wiki Activity

git-svn-id: http://xe-core.googlecode.com/svn/trunk@1097 201d5d3c-b55e-5fd7-737f-ddc643e51545

Browse source
This commit is contained in:
zero 2007-04-11 06:04:00 +00:00
parent 09048517e3
commit e5d2bac6db
4 changed files with 54 additions and 34 deletions
Download patch file Download diff file Expand all files Collapse all files

73
classes/db/DBCubrid.class.php
View file

@ -59,7 +59,7 @@
$this->userid = $db_info->db_userid; $this->userid = $db_info->db_userid;
$this->password = $db_info->db_password; $this->password = $db_info->db_password;
$this->database = $db_info->db_database; $this->database = $db_info->db_database;
$this->port = $db_info->port; $this->port = $db_info->db_port;
$this->prefix = $db_info->db_table_prefix; $this->prefix = $db_info->db_table_prefix;
if(!substr($this->prefix,-1)!='_') $this->prefix .= '_'; if(!substr($this->prefix,-1)!='_') $this->prefix .= '_';
} }
@ -111,7 +111,7 @@
* return\n * return\n
**/ **/
function _query($query) { function _query($query) {
if(!$this->isConnected()) return; if(!$query || !$this->isConnected()) return;
$this->query = $query; $this->query = $query;
@ -119,7 +119,7 @@
$this->setError(0,'success'); $this->setError(0,'success');
$result = cubrid_execute($this->fd, $query); $result = @cubrid_execute($this->fd, $query);
if(__DEBUG__) { if(__DEBUG__) {
$query_end = getMicroTime(); $query_end = getMicroTime();
@ -181,7 +181,7 @@
$output[] = $tmp; $output[] = $tmp;
} }
@cubrid_close_request($result); if($result) cubrid_close_request($result);
if(count($output)==1) return $output[0]; if(count($output)==1) return $output[0];
return $output; return $output;
@ -201,13 +201,13 @@
* @brief 테이블 기생성 여부 return * @brief 테이블 기생성 여부 return
**/ **/
function isTableExists($target_name) { function isTableExists($target_name) {
$query = sprintf("select * from db_attribute where class_name = '%s'", $this->prefix, $this->addQuotes($target_name)); $query = sprintf("select * from db_attribute where class_name = '%s%s'", $this->prefix, $this->addQuotes($target_name));
$result = $this->_query($query); $result = $this->_query($query);
if(cubrid_num_rows($result)>0) $output = true; if(cubrid_num_rows($result)>0) $output = true;
else $output = false; else $output = false;
@cubrid_close_request($result); if($result) cubrid_close_request($result);
return $output; return $output;
} }
@ -230,7 +230,7 @@
} }
/** /**
* @brief schema xml을 이용하여 create table query생성 * @brief schema xml을 이용하여 create class query생성
* *
* type : number, varchar, text, char, date, \n * type : number, varchar, text, char, date, \n
* opt : notnull, default, size\n * opt : notnull, default, size\n
@ -252,11 +252,20 @@
} }
if($this->isTableExists($table_name)) return; if($this->isTableExists($table_name)) return;
$table_name = $this->prefix.$table_name; $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; if(!is_array($xml_obj->table->column)) $columns[] = $xml_obj->table->column;
else $columns = $xml_obj->table->column; else $columns = $xml_obj->table->column;
$query = sprintf("alter class %s add attribute ", $table_name);
foreach($columns as $column) { foreach($columns as $column) {
$name = $column->attrs->name; $name = $column->attrs->name;
$type = $column->attrs->type; $type = $column->attrs->type;
@ -266,15 +275,22 @@
$index = $column->attrs->index; $index = $column->attrs->index;
$unique = $column->attrs->unique; $unique = $column->attrs->unique;
$default = $column->attrs->default; $default = $column->attrs->default;
$auto_increment = $column->attrs->auto_increment;
$column_schema[] = sprintf('`%s` %s%s %s %s %s', switch($this->column_type[$type]) {
case 'integer' :
$size = null;
break;
case 'text' :
$size = null;
break;
}
$column_schema[] = sprintf('"%s" %s%s %s %s',
$name, $name,
$this->column_type[$type], $this->column_type[$type],
$size?'('.$size.')':'', $size?'('.$size.')':'',
$default?"default '".$default."'":'', $default?"default '".$default."'":'',
$notnull?'not null':'', $notnull?'not null':''
$auto_increment?'auto_increment':''
); );
if($primary_key) $primary_list[] = $name; if($primary_key) $primary_list[] = $name;
@ -282,33 +298,34 @@
else if($index) $index_list[$index][] = $name; else if($index) $index_list[$index][] = $name;
} }
$query .= implode(',', $column_schema).';';
$this->_query($query);
if(count($primary_list)) { if(count($primary_list)) {
$column_schema[] = sprintf("primary key (%s)", '`'.implode($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)) { if(count($unique_list)) {
foreach($unique_list as $key => $val) { foreach($unique_list as $key => $val) {
$column_schema[] = sprintf("unique %s (%s)", $key, '`'.implode($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)) { if(count($index_list)) {
foreach($index_list as $key => $val) { foreach($index_list as $key => $val) {
$column_schema[] = sprintf("index %s (%s)", $key, '`'.implode($val,'`,`').'`'); $query = sprintf("create index %s_%s on %s (%s);", $table_name, $key, $table_name, '"'.implode('","',$val).'"');
$this->_query($query);
} }
} }
$schema = sprintf('create table `%s` (%s%s) %s;', $this->addQuotes($table_name), "\n", implode($column_schema,",\n"), "type=innodb CHARACTER SET utf8 COLLATE utf8_general_ci");
$output = $this->_query($schema);
if(!$output) return false;
} }
/** /**
* @brief 테이블 삭제 * @brief 테이블 삭제
**/ **/
function dropTable($target_name) { function dropTable($target_name) {
$query = sprintf('drop class `%s%s`;', $this->prefix, $this->addQuotes($target_name)); $query = sprintf('drop class %s%s;', $this->prefix, $this->addQuotes($target_name));
$this->_query($query); $this->_query($query);
} }
@ -340,11 +357,11 @@
foreach($column as $key => $val) { foreach($column as $key => $val) {
$key_list[] = $key; $key_list[] = $key;
if(in_array($key, $pass_quotes)) $val_list[] = $this->addQuotes($val); if(is_int($val) || in_array($key, $pass_quotes)) $val_list[] = $this->addQuotes($val);
else $val_list[] = '\''.$this->addQuotes($val).'\''; else $val_list[] = '\''.$this->addQuotes($val).'\'';
} }
$query = sprintf("insert into `%s%s` (%s) values (%s);", $this->prefix, $table, '`'.implode('`,`',$key_list).'`', implode(',', $val_list)); $query = sprintf("insert into %s%s (%s) values (%s);", $this->prefix, $table, '"'.implode('","',$key_list).'"', implode(',', $val_list));
return $this->_query($query); return $this->_query($query);
} }
@ -357,15 +374,15 @@
foreach($column as $key => $val) { foreach($column as $key => $val) {
// args에 아예 해당 key가 없으면 패스 // args에 아예 해당 key가 없으면 패스
if(!isset($args->{$key})) continue; if(!isset($args->{$key})) continue;
if(in_array($key, $pass_quotes)) $update_list[] = sprintf('`%s` = %s', $key, $this->addQuotes($val)); if(is_int($val) || in_array($key, $pass_quotes)) $update_list[] = sprintf('"%s" = %s', $key, $this->addQuotes($val));
else $update_list[] = sprintf('`%s` = \'%s\'', $key, $this->addQuotes($val)); else $update_list[] = sprintf('"%s" = \'%s\'', $key, $this->addQuotes($val));
} }
if(!count($update_list)) return; if(!count($update_list)) return;
$update_query = implode(',',$update_list); $update_query = implode(',',$update_list);
if($condition) $condition = ' where '.$condition; if($condition) $condition = ' where '.$condition;
$query = sprintf("update `%s%s` set %s %s;", $this->prefix, $table, $update_query, $condition); $query = sprintf("update %s%s set %s %s;", $this->prefix, $table, $update_query, $condition);
return $this->_query($query); return $this->_query($query);
} }
@ -378,7 +395,7 @@
if($condition) $condition = ' where '.$condition; if($condition) $condition = ' where '.$condition;
$query = sprintf("delete from `%s%s` %s;", $this->prefix, $table, $condition); $query = sprintf("delete from %s%s %s;", $this->prefix, $table, $condition);
return $this->_query($query); return $this->_query($query);
} }
@ -398,7 +415,7 @@
if(!$column) $columns = '*'; if(!$column) $columns = '*';
else { else {
foreach($invert_columns as $key => $val) { foreach($invert_columns as $key => $val) {
$column_list[] = sprintf('%s as %s',$val, $key); $column_list[] = sprintf('"%s" as "%s"',$val, $key);
} }
$columns = implode(',', $column_list); $columns = implode(',', $column_list);
} }
@ -413,7 +430,7 @@
if($navigation->index) { if($navigation->index) {
foreach($navigation->index as $index_obj) { foreach($navigation->index as $index_obj) {
$index_list[] = sprintf('%s %s', $index_obj[0], $index_obj[1]); $index_list[] = sprintf('"%s" "%s"', $index_obj[0], $index_obj[1]);
} }
if(count($index_list)) $query .= ' order by '.implode(',',$index_list); if(count($index_list)) $query .= ' order by '.implode(',',$index_list);
} }

3
index.php
View file

@ -1,4 +1,5 @@
<?php <?php
ob_start();
/** /**
* @file index.php * @file index.php
* @author zero (zero@zeroboard.com) * @author zero (zero@zeroboard.com)
@ -47,4 +48,6 @@
$oModuleHandler->init(); $oModuleHandler->init();
$oModule = &$oModuleHandler->procModule(); $oModule = &$oModuleHandler->procModule();
$oModuleHandler->displayContent($oModule); $oModuleHandler->displayContent($oModule);
debugPrint(ob_get_contents());
ob_end_flush();
?> ?>

2
modules/install/install.controller.php
View file

@ -24,7 +24,7 @@
if(Context::isInstalled()) return new Object(-1, 'msg_already_installed'); if(Context::isInstalled()) return new Object(-1, 'msg_already_installed');
// DB와 관련된 변수를 받음 // DB와 관련된 변수를 받음
$db_info = Context::gets('db_type','db_hostname','db_userid','db_password','db_database','db_table_prefix'); $db_info = Context::gets('db_type','db_port','db_hostname','db_userid','db_password','db_database','db_table_prefix');
// DB의 타입과 정보를 등록 // DB의 타입과 정보를 등록
Context::setDBInfo($db_info); Context::setDBInfo($db_info);

2
modules/module/schemas/modules.xml
View file

@ -6,7 +6,7 @@
<column name="mid" type="varchar" size="40" notnull="notnull" unique="unique_mid"/> <column name="mid" type="varchar" size="40" notnull="notnull" unique="unique_mid"/>
<column name="skin" type="varchar" size="250" /> <column name="skin" type="varchar" size="250" />
<column name="browser_title" type="varchar" size="250" notnull="notnull"/> <column name="browser_title" type="varchar" size="250" notnull="notnull"/>
<column name="description" type="text" size="250" /> <column name="description" type="text" />
<column name="is_default" type="char" size="1" notnull="notnull" default="N" /> <column name="is_default" type="char" size="1" notnull="notnull" default="N" />
<column name="menu_srl" type="number" size="11" default="0"/> <column name="menu_srl" type="number" size="11" default="0"/>
<column name="extra_vars" type="text" /> <column name="extra_vars" type="text" />