makary/phpbb
1
0
Fork 0
mirror of https://github.com/phpbb/phpbb.git synced 2025-06-10 05:18:52 +00:00
Code Issues Projects Releases Packages Wiki Activity

A few corrections inc. DB2 compatibility

Browse source 
git-svn-id: file:///svn/phpbb/trunk@66 89ea8834-ac86-4346-8a33-228a782c2dd0
This commit is contained in:
Paul S. Owen 2001-02-26 01:00:57 +00:00
parent 83b6163b4b
commit cb964c96c7
1 changed files with 64 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

87
phpBB/db/odbc.php
View file

@ -41,25 +41,36 @@ class sql_db
function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency = true) function sql_db($sqlserver, $sqluser, $sqlpassword, $database, $persistency = true)
{ {
$this->persistency = $persistency; if(eregi("^([[:alnum:]]+):([[:alnum:]]+)$", $sqlserver, $db_type))
$this->user = $sqluser; {
$this->password = $sqlpassword; $this->persistency = $persistency;
$this->server = $sqlserver; $this->user = $sqluser;
$this->dbname = $database; $this->password = $sqlpassword;
$this->dbname = $database;
if($this->user || $this->password) $this->server = $db_type[2];
{ $db_type = strtoupper($db_type[1]);
// $this->server = "DSN=".$this->server;
switch($db_type)
{
case 'MSACCESS':
$this->db_type = "msaccess";
break;
case 'MSSQL':
$this->db_type = "mssql";
break;
case 'DB2':
$this->db_type = "db2";
break;
default:
$this->db_type = "";
}
} }
if($this->user) else
{ {
$this->dsn .= ";UID=".$this->user; return false;
} }
if($this->password)
{
$this->dsn .= ";PWD=".$this->password;
}
if($this->persistency) if($this->persistency)
{ {
$this->db_connect_id = odbc_pconnect($this->server, "", ""); $this->db_connect_id = odbc_pconnect($this->server, "", "");
@ -71,6 +82,10 @@ class sql_db
if($this->db_connect_id) if($this->db_connect_id)
{ {
if($this->db_type == "db2")
{
@odbc_autocommit($this->db_connect_id, off);
}
return $this->db_connect_id; return $this->db_connect_id;
} }
else else
@ -133,7 +148,12 @@ class sql_db
$num_rows = $limits[2]; $num_rows = $limits[2];
} }
$this->query_result = @odbc_exec($this->db_connect_id, $query); if($this->db_type == "db2")
{
$query .= " FETCH FIRST ".($row_offset+$num_rows)." ROWS ONLY OPTIMIZE FOR ".($row_offset+$num_rows)." ROWS";
}
$this->query_result = odbc_exec($this->db_connect_id, $query);
$query_limit_offset = $row_offset; $query_limit_offset = $row_offset;
$this->result_numrows[$this->query_result] = $num_rows; $this->result_numrows[$this->query_result] = $num_rows;
@ -157,11 +177,12 @@ class sql_db
$i = $row_offset + 1; $i = $row_offset + 1;
$k = 0; $k = 0;
while(odbc_fetch_row($result_id, $i) && $k < $this->result_numrows[$result_id]) while(@odbc_fetch_row($result_id, $i) && $k < $this->result_numrows[$result_id])
{ {
for($j = 1; $j < count($this->result_field_names[$result_id])+1; $j++) for($j = 1; $j < count($this->result_field_names[$result_id])+1; $j++)
{ {
$this->result_rowset[$result_id][$k][$this->result_field_names[$result_id][$j-1]] = odbc_result($result_id, $j); $this->result_rowset[$result_id][$k][$this->result_field_names[$result_id][$j-1]] = @odbc_result($result_id, $j);
} }
$i++; $i++;
$k++; $k++;
@ -173,18 +194,38 @@ class sql_db
} }
else else
{ {
$this->query_result = odbc_exec($this->db_connect_id, $query); $this->query_result = @odbc_exec($this->db_connect_id, $query);
if($this->query_result) if($this->query_result)
{ {
// This works for MSSQL, MS Access ... no idea about other DBs ... switch($this->db_type)
$id_result = odbc_exec($this->db_connect_id, "SELECT @@IDENTITY AS last_id"); {
case 'msaccess':
$sql_id = "SELECT @@IDENTITY";
break;
case 'mssql':
$sql_id = "SELECT @@IDENTITY";
break;
case 'db2':
$sql_id = "VALUES(IDENTITY_VAL_LOCAL())";
break;
default:
$sql_id = "";
}
$id_result = @odbc_exec($this->db_connect_id, $sql_id);
if($id_result) if($id_result)
{ {
@odbc_fetch_row($id_result); $row_result = @odbc_fetch_row($id_result);
$this->next_id[$this->query_result] = odbc_result($id_result, 1); if($row_result)
{
$this->next_id[$this->query_result] = odbc_result($id_result, 1);
}
} }
} }
if($this->db_type == "db2")
{
odbc_commit($this->db_connect_id);
}
$this->query_limit_offset[$this->query_result] = 0; $this->query_limit_offset[$this->query_result] = 0;
$this->result_numrows[$this->query_result] = 0; $this->result_numrows[$this->query_result] = 0;