noalyss Version-9
database.class.php
Go to the documentation of this file.
1<?php
2
3/*
4 * This file is part of NOALYSS.
5 *
6 * NOALYSS is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; either version 2 of the License, or
9 * (at your option) any later version.
10 *
11 * NOALYSS is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
15 *
16 * You should have received a copy of the GNU General Public License
17 * along with NOALYSS; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19 */
20
21// Copyright Author Dany De Bontridder danydb@aevalys.eu
22
23/**
24 * \file
25 * \brief contains the class for connecting to Noalyss
26 */
27
28/**
29 * \class Database
30 * \brief contains the class for connecting to Noalyss
31 */
33{
34 /**\brief constructor
35 * \param $p_database_id is the id of the dossier, or the modele following the
36 * p_type if = 0 then connect to the repository
37 * \param $p_type is 'DOS' (defaut) for dossier or 'MOD'
38 */
39
40 function __construct($p_database_id = 0, $p_type = 'dos')
41 {
42 if (IsNumber($p_database_id) == false || strlen($p_database_id??"") > 10)
43 die("-->Dossier invalide [$p_database_id]");
44 $noalyss_user = (defined("noalyss_user")) ? noalyss_user : phpcompta_user;
45 $password = (defined("noalyss_password")) ? noalyss_password : phpcompta_password;
46 $port = (defined("noalyss_psql_port")) ? noalyss_psql_port : phpcompta_psql_port;
47 $host = (!defined("noalyss_psql_host")) ? '127.0.0.1' : noalyss_psql_host;
48 if (defined("MULTI") && MULTI == "0") {
49 $l_dossier = dbname;
50 } else {
51
52 if ($p_database_id == 0) { /* connect to the repository */
53 $l_dossier = sprintf("%saccount_repository", strtolower(domaine));
54 } else if ($p_type == 'dos') { /* connect to a folder (dossier) */
55 $l_dossier = sprintf("%sdossier%d", strtolower(domaine), $p_database_id);
56 } else if ($p_type == 'mod') { /* connect to a template (modele) */
57 $l_dossier = sprintf("%smod%d", strtolower(domaine), $p_database_id);
58 } else if ($p_type == 'template') {
59 $l_dossier = 'template1';
60 } else {
61 throw new Exception('Connection invalide');
62 }
63 }
64
65 parent::__construct($noalyss_user, $password, $l_dossier, $host, $port);
66
67 if ($this->exist_schema('comptaproc')) {
68 $this->exec_sql('set search_path to public,comptaproc,pg_catalog;');
69 }
70 $this->exec_sql('set DateStyle to ISO, MDY;');
71
72 }
73
74 /***
75 * \brief Save a "piece justificative" , the name must be pj
76 *
77 * \param $seq jr_grpt_id
78 * \return $oid of the lob file if success
79 * null if a error occurs
80 *
81 */
83 {
84 $oid = $this->upload('pj');
85 if ($oid == false) {
86 return false;
87 }
88 // Remove old document
89 $ret = $this->exec_sql("select jr_pj from jrn where jr_grpt_id=$seq");
90 if (pg_num_rows($ret) != 0) {
91 $r = pg_fetch_array($ret, 0);
92 $old_oid = $r['jr_pj'];
93 if (strlen($old_oid??"") != 0)
94 $this->lo_unlink( $old_oid);
95 }
96 // Load new document
97 $this->exec_sql("update jrn set jr_pj=$1 , jr_pj_name=$2,
98 jr_pj_type=$3 where jr_grpt_id=$4",
99 array($oid, $_FILES['pj']['name'], $_FILES['pj']['type'], $seq));
100 return $oid;
101 }
102
103 /**
104 * \brief Get version of a database, the content of the
105 * table version
106 *
107 * \return version number
108 *
109 */
110
111 function get_version()
112 {
113 $Res = $this->get_value("select max(val) from version");
114 return $Res;
115 }
116
117 /**
118 * \brief loop to apply all the path to a folder or a template
119 * Upgrade check if the folder $p_name needs to be upgrade thanks the variable DBVERSION
120 * and run all the SQL script named upgradeX.sql from the folder noalyss/include/sql/patch
121 * until X equal DBVERSION-1
122 *
123 * \param $p_name database name
124 *
125 */
126
127 function apply_patch($p_name)
128 {
129 if (!$this->exist_table('version')) {
130 echo _('Base de donnée vide');
131 return;
132 }
133 $MaxVersion = DBVERSION - 1;
134 $succeed = "<span style=\"font-size:18px;color:green\">&#x2713;</span>";
135 echo '<ul style="list-type-style:square">';
136 for ($i = 4; $i <= $MaxVersion; $i++) {
137 $to = $i + 1;
138 if ($this->get_version() <= $i) {
139 if ($this->get_version() == 97) {
140 if ($this->exist_schema("amortissement")) {
141 $this->exec_sql('ALTER TABLE amortissement.amortissement_histo
142 ADD CONSTRAINT internal_fk FOREIGN KEY (jr_internal) REFERENCES jrn (jr_internal)
143 ON UPDATE CASCADE ON DELETE SET NULL');
144 }
145 }
146 echo "<li>Patching " . $p_name .
147 " from the version " . $this->get_version() . " to $to ";
148
149 $this->execute_script(NOALYSS_INCLUDE . '/sql/patch/upgrade' . $i . '.sql');
150 echo $succeed;
151
152 if ( DEBUGNOALYSS == 0)
153 ob_start();
154 // specific for version 4
155 if ($i == 4) {
156 $sql = "select jrn_def_id from jrn_def ";
157 $Res = $this->exec_sql($sql);
158 $Max = $this->size();
159 for ($seq = 0; $seq < $Max; $seq++) {
160 $row = pg_fetch_array($Res, $seq);
161 $sql = sprintf("create sequence s_jrn_%d", $row['jrn_def_id']);
162 $this->exec_sql($sql);
163 }
164 }
165 // specific to version 7
166 if ($i == 7) {
167 // now we use sequence instead of computing a max
168 //
169 $Res2 = $this->exec_sql('select coalesce(max(jr_grpt_id),1) as l from jrn');
170 $Max2 = pg_num_rows($Res2);
171 if ($Max2 == 1) {
172 $Row = pg_fetch_array($Res2, 0);
173 var_dump($Row);
174 $M = $Row['l'];
175 $this->exec_sql("select setval('s_grpt',$M,true)");
176 }
177 }
178 // specific to version 17
179 if ($i == 17) {
180 $this->execute_script(NOALYSS_INCLUDE . '/sql/patch/upgrade17.sql');
181 $max = $this->get_value('select last_value from s_jnt_fic_att_value');
182 $this->alter_seq('s_jnt_fic_att_value', $max + 1);
183 } // version
184 // reset sequence in the modele
185 //--
186 if ($i == 30 && $p_name == "mod") {
187 $a_seq = array('s_jrn', 's_jrn_op', 's_centralized',
188 's_stock_goods', 'c_order', 's_central');
189 foreach ($a_seq as $seq) {
190 $sql = sprintf("select setval('%s',1,false)", $seq);
191 $Res = $this->exec_sql($sql);
192 }
193 $sql = "select jrn_def_id from jrn_def ";
194 $Res = $this->exec_sql($sql);
195 $Max = pg_num_rows($Res);
196 for ($seq = 0; $seq < $Max; $seq++) {
197 $row = pg_fetch_array($Res, $seq);
198 $sql = sprintf("select setval('s_jrn_%d',1,false)", $row['jrn_def_id']);
199 $this->exec_sql($sql);
200 }
201 }
202 if ($i == 36) {
203 /* check the country and apply the path */
204 $res = $this->exec_sql("select pr_value from parameter where pr_id='MY_COUNTRY'");
205 $country = pg_fetch_result($res, 0, 0);
206 $this->execute_script(NOALYSS_INCLUDE . "/sql/patch/upgrade36." . $country . ".sql");
207 $this->exec_sql('update tmp_pcmn set pcm_type=find_pcm_type(pcm_val)');
208 }
209 if ($i == 59) {
210 $res = $this->exec_sql("select pr_value from parameter where pr_id='MY_COUNTRY'");
211 $country = pg_fetch_result($res, 0, 0);
212 if ($country == 'BE')
213 $this->exec_sql("insert into parm_code values ('SUPPLIER',440,'Poste par défaut pour les fournisseurs')");
214 if ($country == 'FR')
215 $this->exec_sql("insert into parm_code values ('SUPPLIER',400,'Poste par défaut pour les fournisseurs')");
216 }
217 if ($i == 61) {
218 $country = $this->get_value("select pr_value from parameter where pr_id='MY_COUNTRY'");
219 $this->execute_script(NOALYSS_INCLUDE . "/sql/patch/upgrade61." . $country . ".sql");
220 }
221 /**
222 * Bug in parm_code for FRANCE
223 */
224 if ($i == 141 ) {
225 $country = $this->get_value("select pr_value from parameter where pr_id='MY_COUNTRY'");
226 $this->execute_script(NOALYSS_INCLUDE . "/sql/patch/upgrade141." . $country . ".sql");
227 }
228
229 if (DEBUGNOALYSS == 0 )
230 ob_end_clean();
231
232 }
233 }
234 echo '</ul>';
235 }
236
237 /**
238 * return the name of the database with the domain name
239 * @param $p_id of the folder WITHOUT the domain name
240 * @param $p_type dos for folder mod for template
241 * @return formatted name
242 */
244 {
245 switch ($p_type) {
246 case 'dos':
247 $sys_name = sprintf("%sdossier%d", strtolower(domaine), $p_id);
248 break;
249 case 'mod':
250 $sys_name = sprintf("%smod%d", strtolower(domaine), $p_id);
251 break;
252 default:
253 echo_error(__FILE__ . " format_name invalid type " . $p_type, __LINE__);
254 throw new Exception(__FILE__ . " format_name invalid type " . $p_type . __LINE__);
255 }
256 return $sys_name;
257 }
258}
echo_error($p_log, $p_line="", $p_message="")
log error into the /tmp/noalyss_error.log it doesn't work on windows
Definition: ac_common.php:169
catch(Exception $exc) if(! $g_user->can_write_action($ag_id)) $r
$to
Definition: balance.inc.php:75
This class allow you to connect to the postgresql database, execute sql, retrieve data.
alter_seq($p_name, $min)
alter the sequence value
$sql
last SQL stmt executed
get_value($p_sql, $p_array=null)
return the value of the sql, the sql will return only one value with the value
size($p_ret=null)
return the number of rows found by the last query, or the number of rows from $p_ret
exec_sql($p_string, $p_array=null)
send a sql string to the database
lo_unlink($p_oid)
wrapper for the function pg_lo_unlink
execute_script($script)
Execute a sql script.
exist_table($p_name, $p_schema='public')
test if a table exist
contains the class for connecting to Noalyss
__construct($p_database_id=0, $p_type='dos')
constructor
format_name($p_id, $p_type)
return the name of the database with the domain name
save_receipt($seq)
get_version()
Get version of a database, the content of the table version.
apply_patch($p_name)
loop to apply all the path to a folder or a template Upgrade check if the folder $p_name needs to be ...
const DBVERSION
Definition: constant.php:31
$Res
$succeed
Definition: install.php:183
domaine
Definition: install.php:370