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

fixed

Browse source 
git-svn-id: http://xe-core.googlecode.com/svn/sandbox@7818 201d5d3c-b55e-5fd7-737f-ddc643e51545
This commit is contained in:
ngleader 2010-11-09 01:53:30 +00:00
parent 04daa41054
commit 14d3ddc3a4
1 changed files with 57 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -237,6 +237,8 @@
**/
function getNextSequence()
{
$this->_makeSequence();
$query = sprintf ("select \"%ssequence\".\"nextval\" as \"seq\" from db_root", $this->prefix);
$result = $this->_query($query);
$output = $this->_fetch($result);
@ -244,6 +246,50 @@
return $output->seq;
}
/**
* @brief 마이그레이션시 sequence 가 없을 경우 생성
**/
function _makeSequence()
{
if($_GOBALS['XE_EXISTS_SEQUENCE']) return;
// check cubrid serial
$query = sprintf('select count(*) as "count" from "db_serial" where name=\'%ssequence\'', $this->prefix);
$result = $this->_query($query);
$output = $this->_fetch($result);
// if do not create serial
if($output->count==0)
{
$query = sprintf('select max(a.srl) as srl from
( select max(document_srl) as srl from %sdocuments
UNION
select max(comment_srl) as srl from %scomments
UNION
select max(member_srl) as srl from %smember
) as "a"',$this->prefix,$this->prefix,$this->prefix);
$result = $this->_query($query);
$output = $this->_fetch($result);
$srl = $output->srl;
if($srl<1)
{
$start = 1;
}
else
{
$start = $srl + 1000000;
}
// create sequence
$query = sprintf('create serial "%ssequence start with %s increment by 1 minvalue 1 maxvalue 10000000000000000000000000000000000000 nocycle;', $this->prefix, $start);
$this->_query($query);
}
$_GOBALS['XE_EXISTS_SEQUENCE'] = true;
}
/**
* @brief 테이블 기생성 여부 return
**/
@ -284,6 +330,11 @@
$query = sprintf ("alter class \"%s%s\" add \"%s\" ", $this->prefix, $table_name, $column_name);
if ($type == 'char' || $type == 'varchar')
{
if($size) $size = $size * 3;
}
if ($size)
{
$query .= sprintf ("%s(%s) ", $type, $size);
@ -466,6 +517,12 @@
$default = sprintf ("'%s'", $default);
}
if ($type == 'varchar' || $type == 'char')
{
if($size) $size = $size * 3;
}
$column_schema[] = sprintf ('"%s" %s%s %s %s',
$name,
$this->column_type[$type],