Subversion Repositories oidplus

Rev

Rev 1086 | Rev 1130 | Go to most recent revision | Show entire file | Regard whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 1086 Rev 1116
Line 23... Line 23...
23 
\defined('INSIDE_OIDPLUS') or die;
 23 
\defined('INSIDE_OIDPLUS') or die;
24 
// phpcs:enable PSR1.Files.SideEffects
 24 
// phpcs:enable PSR1.Files.SideEffects
25 
 
 25 
 
26 
class OIDplusSqlSlangPluginMySQL extends OIDplusSqlSlangPlugin {
 26 
class OIDplusSqlSlangPluginMySQL extends OIDplusSqlSlangPlugin {
27 
 
 27 
 
- 
 
 28 
        /**
- 
 
 29 
         * @return string
- 
 
 30 
         */
28 
        public static function id(): string {
 31 
        public static function id(): string {
29 
                return 'mysql';
 32 
                return 'mysql';
30 
        }
 33 
        }
31 
 
 34 
 
- 
 
 35 
        /**
- 
 
 36 
         * @param string $fieldname
- 
 
 37 
         * @param string $order
- 
 
 38 
         * @return string
- 
 
 39 
         * @throws OIDplusException
- 
 
 40 
         */
32 
        public function natOrder($fieldname, $order='asc'): string {
 41 
        public function natOrder(string $fieldname, string $order='asc'): string {
33 
 
 42 
 
34 
                $order = strtolower($order);
 43 
                $order = strtolower($order);
35 
                if (($order != 'asc') && ($order != 'desc')) {
 44 
                if (($order != 'asc') && ($order != 'desc')) {
36 
                        throw new OIDplusException(_L('Invalid order "%1" (needs to be "asc" or "desc")',$order));
 45 
                        throw new OIDplusException(_L('Invalid order "%1" (needs to be "asc" or "desc")',$order));
37 
                }
 46 
                }
Line 56... Line 65...
56 
 
 65 
 
57 
                return implode(', ', $out);
 66 
                return implode(', ', $out);
58 
 
 67 
 
59 
        }
 68 
        }
60 
 
 69 
 
- 
 
 70 
        /**
- 
 
 71 
         * @return string
- 
 
 72 
         */
61 
        public function sqlDate(): string {
 73 
        public function sqlDate(): string {
62 
                return 'now()';
 74 
                return 'now()';
63 
        }
 75 
        }
64 
 
 76 
 
- 
 
 77 
        /**
- 
 
 78 
         * @param OIDplusDatabaseConnection $db
- 
 
 79 
         * @return bool
- 
 
 80 
         */
65 
        public function detect(OIDplusDatabaseConnection $db): bool {
 81 
        public function detect(OIDplusDatabaseConnection $db): bool {
66 
                try {
 82 
                try {
67 
                        $vers = $db->query("select version() as dbms_version")->fetch_object()->dbms_version;
 83 
                        $vers = $db->query("select version() as dbms_version")->fetch_object()->dbms_version;
68 
                        $vers = strtolower($vers);
 84 
                        $vers = strtolower($vers);
69 
                        return (strpos($vers, 'mysql') !== false) || (strpos($vers, 'mariadb') !== false);
 85 
                        return (strpos($vers, 'mysql') !== false) || (strpos($vers, 'mariadb') !== false);
70 
                } catch (\Exception $e) {
 86 
                } catch (\Exception $e) {
71 
                        return false;
 87 
                        return false;
72 
                }
 88 
                }
73 
        }
 89 
        }
74 
 
 90 
 
- 
 
 91 
        /**
- 
 
 92 
         * @param OIDplusDatabaseConnection $db
- 
 
 93 
         * @return int
- 
 
 94 
         * @throws OIDplusException
- 
 
 95 
         */
75 
        public function insert_id(OIDplusDatabaseConnection $db): int {
 96 
        public function insert_id(OIDplusDatabaseConnection $db): int {
76 
                $res = $db->query("SELECT LAST_INSERT_ID() AS ID");
 97 
                $res = $db->query("SELECT LAST_INSERT_ID() AS ID");
77 
                $row = $res->fetch_array();
 98 
                $row = $res->fetch_array();
78 
                return (int)$row['ID'];
 99 
                return (int)$row['ID'];
79 
        }
 100 
        }
80 
 
 101 
 
- 
 
 102 
        /**
- 
 
 103 
         * @param string $cont
- 
 
 104 
         * @param string $table
- 
 
 105 
         * @param string $prefix
- 
 
 106 
         * @return string
81 
 
 107 
         */
82 
        public function setupSetTablePrefix($cont, $table, $prefix): string {
 108 
        public function setupSetTablePrefix(string $cont, string $table, string $prefix): string {
83 
                $cont = str_replace('`'.$table.'`', '`'.$prefix.$table.'`', $cont);
 109 
                $cont = str_replace('`'.$table.'`', '`'.$prefix.$table.'`', $cont);
84 
                return $cont;
 110 
                return $cont;
85 
        }
 111 
        }
86 
 
 112 
 
- 
 
 113 
        /**
- 
 
 114 
         * @param string $database
- 
 
 115 
         * @return string
- 
 
 116 
         */
87 
        public function setupCreateDbIfNotExists($database): string {
 117 
        public function setupCreateDbIfNotExists(string $database): string {
88 
                return "CREATE DATABASE IF NOT EXISTS `$database`;\n\n";
 118 
                return "CREATE DATABASE IF NOT EXISTS `$database`;\n\n";
89 
        }
 119 
        }
90 
 
 120 
 
- 
 
 121 
        /**
- 
 
 122 
         * @param string $database
- 
 
 123 
         * @return string
- 
 
 124 
         */
91 
        public function setupUseDatabase($database): string {
 125 
        public function setupUseDatabase(string $database): string {
92 
                return "USE `$database`;\n\n";
 126 
                return "USE `$database`;\n\n";
93 
        }
 127 
        }
94 
 
 128 
 
- 
 
 129 
        /**
- 
 
 130 
         * @param string $expr1
- 
 
 131 
         * @param string $expr2
- 
 
 132 
         * @return string
- 
 
 133 
         */
95 
        public function isNullFunction($expr1, $expr2): string {
 134 
        public function isNullFunction(string $expr1, string $expr2): string {
96 
                return "ifnull($expr1, $expr2)";
 135 
                return "ifnull($expr1, $expr2)";
97 
        }
 136 
        }
98 
 
 137 
 
- 
 
 138 
        /**
- 
 
 139 
         * @param string $sql
- 
 
 140 
         * @return string
- 
 
 141 
         */
99 
        public function filterQuery($sql): string {
 142 
        public function filterQuery(string $sql): string {
100 
                return $sql;
 143 
                return $sql;
101 
        }
 144 
        }
102 
 
 145 
 
- 
 
 146 
        /**
- 
 
 147 
         * @param bool $bool
- 
 
 148 
         * @return string
- 
 
 149 
         */
103 
        public function getSQLBool($bool): string {
 150 
        public function getSQLBool(bool $bool): string {
104 
                return $bool ? '1' : '0';
 151 
                return $bool ? '1' : '0';
105 
        }
 152 
        }
106 
 
 153 
 
- 
 
 154 
        /**
- 
 
 155 
         * @param string $str
- 
 
 156 
         * @return string
- 
 
 157 
         */
107 
        public function escapeString($str): string {
 158 
        public function escapeString(string $str): string {
108 
                return str_replace("'", "''", $str);
 159 
                return str_replace("'", "''", $str);
109 
        }
 160 
        }
110 
}
 161 
}