tyler.durden/pandorafms
1
0
Fork 0
mirror of https://github.com/pandorafms/pandorafms.git synced 2025-09-25 19:09:08 +02:00
Code Issues Packages Projects Releases Wiki Activity

2011-03-01 Miguel de Dios <miguel.dedios@artica.es>

Browse Source 
* include/db/postgresql.php, include/db/mysql.php, include/functions_db.php:
	separate the function "get_db_all_row_by_steps_sql", "process_sql_begin",
	"process_sql_commit" and "process_sql_rollback" into the two version for
	MySQL and PostgreSQL engine.



git-svn-id: https://svn.code.sf.net/p/pandora/code/trunk@4040 c3f86ba8-e40f-0410-aaad-9ba5e7f4b01f
This commit is contained in:
mdtrooper 2011-03-01 16:37:24 +00:00
parent 830742c25d
commit 57b3aea57d
4 changed files with 102 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pandora_console/ChangeLog
View File

@ -1,3 +1,10 @@
2011-03-01 Miguel de Dios <miguel.dedios@artica.es>
* include/db/postgresql.php, include/db/mysql.php, include/functions_db.php:
separate the function "get_db_all_row_by_steps_sql", "process_sql_begin",
"process_sql_commit" and "process_sql_rollback" into the two version for
MySQL and PostgreSQL engine.
2011-03-01 Juan Manuel Ramon <juanmanuel.ramon@artica.es> 2011-03-01 Juan Manuel Ramon <juanmanuel.ramon@artica.es>
* include/ajax/skins.ajax.php: Replaced "give_acl" function call to * include/ajax/skins.ajax.php: Replaced "give_acl" function call to

33
pandora_console/include/db/mysql.php
View File

@ -895,4 +895,37 @@ function mysql_process_sql_delete($table, $where, $where_join = 'AND') {
return process_sql ($query); return process_sql ($query);
} }
/**
* Get row by row the DB by SQL query. The first time pass the SQL query and
* rest of times pass none for iterate in table and extract row by row, and
* the end return false.
*
* @param bool $new Default true, if true start to query.
* @param resource $result The resource of mysql for access to query.
* @param string $sql
* @return mixed The row or false in error.
*/
function mysql_get_db_all_row_by_steps_sql($new = true, &$result, $sql = null) {
if ($new == true)
$result = mysql_query($sql);
return mysql_fetch_assoc($result);
}
/**
* Starts a database transaction.
*/
function mysql_process_sql_begin() {
mysql_query ('SET AUTOCOMMIT = 0');
mysql_query ('START TRANSACTION');
}
/**
* Commits a database transaction.
*/
function mysql_process_sql_commit() {
mysql_query ('COMMIT');
mysql_query ('SET AUTOCOMMIT = 0');
}
?> ?>

31
pandora_console/include/db/postgresql.php
View File

@ -914,4 +914,35 @@ function postgresql_process_sql_delete($table, $where, $where_join = 'AND') {
return process_sql ($query); return process_sql ($query);
} }
/**
* Get row by row the DB by SQL query. The first time pass the SQL query and
* rest of times pass none for iterate in table and extract row by row, and
* the end return false.
*
* @param bool $new Default true, if true start to query.
* @param resource $result The resource of mysql for access to query.
* @param string $sql
* @return mixed The row or false in error.
*/
function postgresql_get_db_all_row_by_steps_sql($new = true, &$result, $sql = null) {
if ($new == true)
$result = pg_query($sql);
return pg_fetch_assoc($result);
}
/**
* Starts a database transaction.
*/
function postgresql_process_sql_begin() {
pg_query('BEGIN TRANSACTION');
}
/**
* Commits a database transaction.
*/
function postgresql_process_sql_commit() {
pg_query('COMMIT');
}
?> ?>

40
pandora_console/include/functions_db.php
View File

@ -2301,10 +2301,16 @@ function get_db_all_rows_filter($table, $filter = array(), $fields = false, $whe
* @return mixed The row or false in error. * @return mixed The row or false in error.
*/ */
function get_db_all_row_by_steps_sql($new = true, &$result, $sql = null) { function get_db_all_row_by_steps_sql($new = true, &$result, $sql = null) {
if ($new == true) global $config;
$result = mysql_query($sql);
return mysql_fetch_assoc($result); switch ($config["dbtype"]) {
case "mysql":
return mysql_get_db_all_row_by_steps_sql($new, $result, $sql);
break;
case "postgresql":
return postgresql_get_db_all_row_by_steps_sql($new, $result, $sql);
break;
}
} }
/** /**
@ -3323,17 +3329,33 @@ function process_sql_delete($table, $where, $where_join = 'AND') {
/** /**
* Starts a database transaction. * Starts a database transaction.
*/ */
function process_sql_begin () { function process_sql_begin() {
mysql_query ('SET AUTOCOMMIT = 0'); global $config;
mysql_query ('START TRANSACTION');
switch ($config["dbtype"]) {
case "mysql":
return mysql_process_sql_begin();
break;
case "postgresql":
return postgresql_process_sql_begin();
break;
}
} }
/** /**
* Commits a database transaction. * Commits a database transaction.
*/ */
function process_sql_commit () { function process_sql_commit() {
mysql_query ('COMMIT'); global $config;
mysql_query ('SET AUTOCOMMIT = 0');
switch ($config["dbtype"]) {
case "mysql":
return mysql_process_sql_commit();
break;
case "postgresql":
return postgresql_process_sql_commit();
break;
}
} }
/** /**