X-Git-Url: https://delta.frontaccounting.com/gitweb/?a=blobdiff_plain;f=includes%2Fdb%2Fsql_functions.inc;h=66a781d25d868c21286076411c8f559df3394ff4;hb=f821f29324e963437132a3f6fa7c57fcef5c5f0e;hp=766fe545c3a61d6a9e198c953d56228ce70d3dae;hpb=da8311619dd73feae101d246a1957b972e00cbd2;p=fa-stable.git diff --git a/includes/db/sql_functions.inc b/includes/db/sql_functions.inc index 766fe545..66a781d2 100644 --- a/includes/db/sql_functions.inc +++ b/includes/db/sql_functions.inc @@ -1,20 +1,81 @@ . +***********************************************************************/ +// +// General database functions common for all modules. +// //------------------------------------------------------------------- +// Multilevel transaction control. +// +$transaction_level = 0; function begin_transaction() { - db_query("BEGIN", "could not start a transaction"); + global $transaction_level; + + if (!$transaction_level) { + db_query("BEGIN", "could not start a transaction"); + } + $transaction_level++; } function commit_transaction() { - db_query("COMMIT", "could not commit a transaction"); + global $transaction_level; + + $transaction_level--; + + if (!$transaction_level) { + db_query("COMMIT", "could not commit a transaction"); + } } +/* + This function is called on end of script execution to cancel + all aborted transactions (if any) +*/ function cancel_transaction() { - db_query("ROLLBACK", "could not cancel a transaction"); + global $transaction_level; + + if ($transaction_level) { + db_query("ROLLBACK", "could not cancel a transaction"); + } + $transaction_level = 0; +} + +//----------------------------------------------------------------------------- +// Update record activity status. +// +function update_record_status($id, $status, $table, $key) { + $sql = "UPDATE ".TB_PREF.$table." SET inactive = " + . ((int)$status)." WHERE $key=".db_escape($id); + + db_query($sql, "Can't update record status"); +} +//----------------------------------------------------------------------------- +// +// Helper for sql subquery returning running totals from delta tables like stock_moves or bank_trans +// +// $table - table name with optional WHERE clause +// $column - delta column +// $index - comma delimited list of columns for total grouping and order +// Returns running totals with respective index column +// +function running_total_sql($table, $column, $index) +{ + + return "SELECT daily.$index, daily.$column, (@total:=@total+daily.$column) total + FROM + (SELECT $index, sum($column) $column FROM $table GROUP BY $index ORDER BY $index) daily, + (SELECT @total:=0) total_var"; } -?>