@@ -56,7 +56,7 @@ |
||
56 | 56 | sqlrcur_prepareQuery($cur, $sql); |
57 | 57 | $bindCount = 1; |
58 | 58 | foreach ($array as $key => $value) { |
59 | - $field = strval($bindCount ++); |
|
59 | + $field = strval($bindCount++); |
|
60 | 60 | sqlrcur_inputBind($cur, $field, $value); |
61 | 61 | } |
62 | 62 | $success = sqlrcur_executeQuery($cur); |
@@ -181,14 +181,14 @@ |
||
181 | 181 | $pat = "/$patDriver($patCredentials$patHost$patDatabase|$patFile)$patExtra/i"; |
182 | 182 | $parts = array(); |
183 | 183 | if (!preg_match($pat, $this->getDbConnectionString(), $parts)) { |
184 | - throw new InvalidArgumentException("Connection string " . $this->getDbConnectionString() . " is invalid! Please fix it."); |
|
184 | + throw new InvalidArgumentException("Connection string ".$this->getDbConnectionString()." is invalid! Please fix it."); |
|
185 | 185 | } |
186 | 186 | |
187 | 187 | // Set the Driver |
188 | 188 | $this->setDriver($parts ['driver']); |
189 | 189 | |
190 | 190 | if (!isset($parts['path']) && !isset($parts['host'])) { |
191 | - throw new InvalidArgumentException("Connection string " . $this->getDbConnectionString() . " is invalid! Please fix it."); |
|
191 | + throw new InvalidArgumentException("Connection string ".$this->getDbConnectionString()." is invalid! Please fix it."); |
|
192 | 192 | } |
193 | 193 | |
194 | 194 |
@@ -10,7 +10,7 @@ |
||
10 | 10 | |
11 | 11 | public function __construct(ConnectionManagement $connMngt) |
12 | 12 | { |
13 | - $strcnn = $connMngt->getDriver() . ":" . $connMngt->getServer(); |
|
13 | + $strcnn = $connMngt->getDriver().":".$connMngt->getServer(); |
|
14 | 14 | |
15 | 15 | parent::__construct($connMngt, $strcnn, [], []); |
16 | 16 | } |
@@ -12,7 +12,7 @@ |
||
12 | 12 | { |
13 | 13 | for ($i = 0, $numArgs = func_num_args(); $i < $numArgs; $i++) { |
14 | 14 | $var = func_get_arg($i); |
15 | - $sql .= ($i == 0 ? "" : "+") . $var; |
|
15 | + $sql .= ($i == 0 ? "" : "+").$var; |
|
16 | 16 | } |
17 | 17 | |
18 | 18 | return $sql; |
@@ -14,7 +14,7 @@ discard block |
||
14 | 14 | $sql = "concat("; |
15 | 15 | for ($i = 0, $numArgs = func_num_args(); $i < $numArgs; $i++) { |
16 | 16 | $var = func_get_arg($i); |
17 | - $sql .= ($i == 0 ? "" : ",") . $var; |
|
17 | + $sql .= ($i == 0 ? "" : ",").$var; |
|
18 | 18 | } |
19 | 19 | $sql .= ")"; |
20 | 20 | |
@@ -76,7 +76,7 @@ discard block |
||
76 | 76 | function sqlDate($fmt, $col = false) |
77 | 77 | { |
78 | 78 | if (!$col) $col = $this->sysTimeStamp; |
79 | - $s = 'DATE_FORMAT(' . $col . ",'"; |
|
79 | + $s = 'DATE_FORMAT('.$col.",'"; |
|
80 | 80 | $concat = false; |
81 | 81 | $len = strlen($fmt); |
82 | 82 | for ($i = 0; $i < $len; $i++) { |
@@ -137,7 +137,7 @@ discard block |
||
137 | 137 | break; |
138 | 138 | } |
139 | 139 | } |
140 | - $s.="')"; |
|
140 | + $s .= "')"; |
|
141 | 141 | if ($concat) $s = "CONCAT($s)"; |
142 | 142 | return $s; |
143 | 143 | } |
@@ -9,7 +9,7 @@ discard block |
||
9 | 9 | { |
10 | 10 | for ($i = 0, $numArgs = func_num_args(); $i < $numArgs; $i++) { |
11 | 11 | $var = func_get_arg($i); |
12 | - $sql .= ($i == 0 ? "" : " || ") . $var; |
|
12 | + $sql .= ($i == 0 ? "" : " || ").$var; |
|
13 | 13 | } |
14 | 14 | |
15 | 15 | return $sql; |
@@ -70,7 +70,7 @@ discard block |
||
70 | 70 | function sqlDate($fmt, $col = false) |
71 | 71 | { |
72 | 72 | if (!$col) $col = $this->sysTimeStamp; |
73 | - $s = 'TO_CHAR(' . $col . ",'"; |
|
73 | + $s = 'TO_CHAR('.$col.",'"; |
|
74 | 74 | |
75 | 75 | $len = strlen($fmt); |
76 | 76 | for ($i = 0; $i < $len; $i++) { |
@@ -98,7 +98,7 @@ discard block |
||
98 | 98 | break; |
99 | 99 | |
100 | 100 | case 'H': |
101 | - $s.= 'HH24'; |
|
101 | + $s .= 'HH24'; |
|
102 | 102 | break; |
103 | 103 | |
104 | 104 | case 'h': |
@@ -127,11 +127,11 @@ discard block |
||
127 | 127 | if (strpos('-/.:;, ', $ch) !== false) { |
128 | 128 | $s .= $ch; |
129 | 129 | } else { |
130 | - $s .= '"' . $ch . '"'; |
|
130 | + $s .= '"'.$ch.'"'; |
|
131 | 131 | } |
132 | 132 | } |
133 | 133 | } |
134 | - return $s . "')"; |
|
134 | + return $s."')"; |
|
135 | 135 | } |
136 | 136 | |
137 | 137 | /** |
@@ -55,8 +55,8 @@ discard block |
||
55 | 55 | if ($sql != "") { |
56 | 56 | $sql .= ", "; |
57 | 57 | } |
58 | - $sql .= " " . $this->_fieldDeliLeft . $fieldname . $this->_fieldDeliRight . " = " . $this->getValue($fieldname, |
|
59 | - $fieldvalue, $param, $decimalpoint) . " "; |
|
58 | + $sql .= " ".$this->_fieldDeliLeft.$fieldname.$this->_fieldDeliRight." = ".$this->getValue($fieldname, |
|
59 | + $fieldvalue, $param, $decimalpoint)." "; |
|
60 | 60 | } |
61 | 61 | $sql = "update $table set $sql where $filter "; |
62 | 62 | } elseif ($type == SQLType::SQL_INSERT) { |
@@ -68,7 +68,7 @@ discard block |
||
68 | 68 | $campos .= ", "; |
69 | 69 | $valores .= ", "; |
70 | 70 | } |
71 | - $campos .= $this->_fieldDeliLeft . $fieldname . $this->_fieldDeliRight; |
|
71 | + $campos .= $this->_fieldDeliLeft.$fieldname.$this->_fieldDeliRight; |
|
72 | 72 | $valores .= $this->getValue($fieldname, $fieldvalue, $param, $decimalpoint); |
73 | 73 | } |
74 | 74 | $sql = "insert into $table ($campos) values ($valores)"; |
@@ -89,7 +89,7 @@ discard block |
||
89 | 89 | */ |
90 | 90 | protected function getValue($name, $valores, &$param, $decimalpoint) |
91 | 91 | { |
92 | - $paramName = "[[" . $name . "]]"; |
|
92 | + $paramName = "[[".$name."]]"; |
|
93 | 93 | if (!is_array($valores)) { |
94 | 94 | $valores = array(SQLFieldType::TEXT, $valores); |
95 | 95 | } |
@@ -109,7 +109,7 @@ discard block |
||
109 | 109 | } elseif ($valores[0] == SQLFieldType::DATE) { |
110 | 110 | $date = ($valores[1] instanceof DateTime ? $valores[1]->format(DBBaseFunctions::YMDH) : $valores[1]); |
111 | 111 | $param[$name] = $date; |
112 | - if (($this->_db->getDbType() == 'oci8') || ( ($this->_db->getDbType() == 'dsn') && (strpos($this->_db->getDbConnectionString(), |
|
112 | + if (($this->_db->getDbType() == 'oci8') || (($this->_db->getDbType() == 'dsn') && (strpos($this->_db->getDbConnectionString(), |
|
113 | 113 | "oci8")))) { |
114 | 114 | return "TO_DATE($paramName, 'YYYY-MM-DD')"; |
115 | 115 | } else { |
@@ -139,7 +139,7 @@ discard block |
||
139 | 139 | if (strlen($sql) > 4) { |
140 | 140 | $sql .= ' and '; |
141 | 141 | } |
142 | - $sql = " $fieldName " . $relation . " " . $this->getValue($fieldName, $value, $param, $decimalpoint); |
|
142 | + $sql = " $fieldName ".$relation." ".$this->getValue($fieldName, $value, $param, $decimalpoint); |
|
143 | 143 | } |
144 | 144 | |
145 | 145 | public function setFieldDelimeters($left, $right) |
@@ -47,7 +47,7 @@ |
||
47 | 47 | $arg = str_replace("_", SQLBind::keyAdj($key), $paramSubstName); |
48 | 48 | |
49 | 49 | $count = 0; |
50 | - $sql = preg_replace("/(\[\[$key\]\]|:" . $key . "[\s\W]|:$key\$)/", $arg . ' ', $sql, -1, $count); |
|
50 | + $sql = preg_replace("/(\[\[$key\]\]|:".$key."[\s\W]|:$key\$)/", $arg.' ', $sql, -1, $count); |
|
51 | 51 | if ($count === 0) { |
52 | 52 | unset($params[$key]); |
53 | 53 | } |
@@ -26,15 +26,15 @@ discard block |
||
26 | 26 | |
27 | 27 | if (is_null($strcnn)) { |
28 | 28 | if ($this->_connectionManagement->getFilePath() != "") { |
29 | - $strcnn = $this->_connectionManagement->getDriver() . ":" . $this->_connectionManagement->getFilePath(); |
|
29 | + $strcnn = $this->_connectionManagement->getDriver().":".$this->_connectionManagement->getFilePath(); |
|
30 | 30 | } else { |
31 | - $strcnn = $this->_connectionManagement->getDriver() . ":dbname=" . $this->_connectionManagement->getDatabase(); |
|
31 | + $strcnn = $this->_connectionManagement->getDriver().":dbname=".$this->_connectionManagement->getDatabase(); |
|
32 | 32 | if ($this->_connectionManagement->getExtraParam("unixsocket") != "") { |
33 | - $strcnn .= ";unix_socket=" . $this->_connectionManagement->getExtraParam("unixsocket"); |
|
33 | + $strcnn .= ";unix_socket=".$this->_connectionManagement->getExtraParam("unixsocket"); |
|
34 | 34 | } else { |
35 | - $strcnn .= ";host=" . $this->_connectionManagement->getServer(); |
|
35 | + $strcnn .= ";host=".$this->_connectionManagement->getServer(); |
|
36 | 36 | if ($this->_connectionManagement->getPort() != "") { |
37 | - $strcnn .= ";port=" . $this->_connectionManagement->getPort(); |
|
37 | + $strcnn .= ";port=".$this->_connectionManagement->getPort(); |
|
38 | 38 | } |
39 | 39 | } |
40 | 40 | } |
@@ -42,14 +42,14 @@ discard block |
||
42 | 42 | |
43 | 43 | // Create Connection |
44 | 44 | $this->_db = new PDO($strcnn, $this->_connectionManagement->getUsername(), |
45 | - $this->_connectionManagement->getPassword(), (array) $preOptions); |
|
45 | + $this->_connectionManagement->getPassword(), (array)$preOptions); |
|
46 | 46 | $this->_connectionManagement->setDriver($this->_db->getAttribute(PDO::ATTR_DRIVER_NAME)); |
47 | 47 | |
48 | 48 | // Set Specific Attributes |
49 | 49 | $this->_db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); |
50 | 50 | $this->_db->setAttribute(PDO::ATTR_CASE, PDO::CASE_LOWER); |
51 | 51 | |
52 | - foreach ((array) $postOptions as $key => $value) { |
|
52 | + foreach ((array)$postOptions as $key => $value) { |
|
53 | 53 | $this->_db->setAttribute($key, $value); |
54 | 54 | } |
55 | 55 | } |
@@ -60,11 +60,11 @@ discard block |
||
60 | 60 | throw new \ByJG\AnyDataset\Exception\NotAvailableException("Extension 'PDO' is not loaded"); |
61 | 61 | } |
62 | 62 | |
63 | - if (!extension_loaded('pdo_' . strtolower($connMngt->getDriver()))) { |
|
64 | - throw new \ByJG\AnyDataset\Exception\NotAvailableException("Extension 'pdo_" . strtolower($connMngt->getDriver()) . "' is not loaded"); |
|
63 | + if (!extension_loaded('pdo_'.strtolower($connMngt->getDriver()))) { |
|
64 | + throw new \ByJG\AnyDataset\Exception\NotAvailableException("Extension 'pdo_".strtolower($connMngt->getDriver())."' is not loaded"); |
|
65 | 65 | } |
66 | 66 | |
67 | - $class = '\ByJG\AnyDataset\Database\Pdo' . ucfirst($connMngt->getDriver()); |
|
67 | + $class = '\ByJG\AnyDataset\Database\Pdo'.ucfirst($connMngt->getDriver()); |
|
68 | 68 | |
69 | 69 | if (!class_exists($class, true)) { |
70 | 70 | return new DBPDODriver($connMngt, null, null, null); |
@@ -90,7 +90,7 @@ discard block |
||
90 | 90 | list($sql, $array) = SQLBind::parseSQL($this->_connectionManagement, $sql, $array); |
91 | 91 | $stmt = $this->_db->prepare($sql); |
92 | 92 | foreach ($array as $key => $value) { |
93 | - $stmt->bindValue(":" . SQLBind::keyAdj($key), $value); |
|
93 | + $stmt->bindValue(":".SQLBind::keyAdj($key), $value); |
|
94 | 94 | } |
95 | 95 | } else $stmt = $this->_db->prepare($sql); |
96 | 96 |