32 |
|
{************************************************************************} |
33 |
|
|
34 |
|
unit IBUtils; |
35 |
+ |
{$IFDEF MSWINDOWS} |
36 |
+ |
{$DEFINE WINDOWS} |
37 |
+ |
{$ENDIF} |
38 |
|
|
39 |
|
{$IFDEF FPC} |
40 |
|
{$Mode Delphi} |
41 |
|
{$codepage UTF8} |
42 |
+ |
{$define HASREQEX} |
43 |
|
{$ENDIF} |
44 |
|
|
45 |
+ |
|
46 |
|
interface |
47 |
|
|
48 |
< |
uses |
44 |
< |
{$IFDEF WINDOWS } |
45 |
< |
Windows, |
46 |
< |
{$ELSE} |
47 |
< |
unix, |
48 |
< |
{$ENDIF} |
49 |
< |
Classes, SysUtils; |
48 |
> |
uses Classes, SysUtils; |
49 |
|
|
50 |
|
const |
51 |
|
CRLF = #13 + #10; |
54 |
|
TAB = #9; |
55 |
|
NULL_TERMINATOR = #0; |
56 |
|
|
57 |
< |
sqlReservedWords: array [0..166] of string = ( |
58 |
< |
'ADD','ADMIN','ALL','ALTER','AND','ANY','AS','AT','AVG','BEGIN','BETWEEN','BIGINT','BIT_LENGTH','BLOB','BOTH', |
59 |
< |
'BY','CASE','CAST','CHAR','CHAR_LENGTH','CHARACTER','CHARACTER_LENGTH','CHECK','CLOSE','COLLATE','COLUMN', |
60 |
< |
'COMMIT','CONNECT','CONSTRAINT','COUNT','CREATE','CROSS','CURRENT','CURRENT_CONNECTION','CURRENT_DATE', |
61 |
< |
'CURRENT_ROLE','CURRENT_TIME','CURRENT_TIMESTAMP','CURRENT_TRANSACTION','CURRENT_USER','CURSOR','DATE', |
62 |
< |
'DAY','DEC','DECIMAL','DECLARE','DEFAULT','DELETE','DISCONNECT','DISTINCT','DOUBLE','DROP','ELSE','END', |
63 |
< |
'ESCAPE','EXECUTE','EXISTS','EXTERNAL','EXTRACT','FETCH','FILTER','FLOAT','FOR','FOREIGN','FROM','FULL', |
64 |
< |
'FUNCTION','GDSCODE','GLOBAL','GRANT','GROUP','HAVING','HOUR','IN','INDEX','INNER','INSENSITIVE','INSERT', |
65 |
< |
'INT','INTEGER','INTO','IS','JOIN','LEADING','LEFT','LIKE','LONG','LOWER','MAX','MAXIMUM_SEGMENT','MERGE', |
66 |
< |
'MIN','MINUTE','MONTH','NATIONAL','NATURAL','NCHAR','NO','NOT','NULL','NUMERIC','OCTET_LENGTH','OF','ON', |
67 |
< |
'ONLY','OPEN','OR','ORDER','OUTER','PARAMETER','PLAN','POSITION','POST_EVENT','PRECISION','PRIMARY', |
68 |
< |
'PROCEDURE','RDB$DB_KEY','REAL','RECORD_VERSION','RECREATE','RECURSIVE','REFERENCES','RELEASE','RETURNING_VALUES', |
69 |
< |
'RETURNS','REVOKE','RIGHT','ROLLBACK','ROW_COUNT','ROWS','SAVEPOINT','SECOND','SELECT','SENSITIVE', |
70 |
< |
'SET','SIMILAR','SMALLINT','SOME','SQLCODE','SQLSTATE','START','SUM','TABLE','THEN','TIME', |
71 |
< |
'TIMESTAMP','TO','TRAILING','TRIGGER','TRIM','UNION','UNIQUE','UPDATE','UPPER','USER','USING', |
72 |
< |
'VALUE','VALUES','VARCHAR','VARIABLE','VARYING','VIEW','WHEN','WHERE','WHILE','WITH','YEAR'); |
57 |
> |
sqlReservedWords: array [0..197] of string = ( |
58 |
> |
'ADD', |
59 |
> |
'ADMIN', |
60 |
> |
'ALL', |
61 |
> |
'ALTER', |
62 |
> |
'AND', |
63 |
> |
'ANY', |
64 |
> |
'AS', |
65 |
> |
'AT', |
66 |
> |
'AVG', |
67 |
> |
'BEGIN', |
68 |
> |
'BETWEEN', |
69 |
> |
'BIGINT', |
70 |
> |
'BIT_LENGTH', |
71 |
> |
'BLOB', |
72 |
> |
'BOOLEAN', |
73 |
> |
'BOTH', |
74 |
> |
'BY', |
75 |
> |
'CASE', |
76 |
> |
'CAST', |
77 |
> |
'CHAR', |
78 |
> |
'CHAR_LENGTH', |
79 |
> |
'CHARACTER', |
80 |
> |
'CHARACTER_LENGTH', |
81 |
> |
'CHECK', |
82 |
> |
'CLOSE', |
83 |
> |
'COLLATE', |
84 |
> |
'COLUMN', |
85 |
> |
'COMMIT', |
86 |
> |
'CONNECT', |
87 |
> |
'CONSTRAINT', |
88 |
> |
'CORR', |
89 |
> |
'COUNT', |
90 |
> |
'COVAR_POP', |
91 |
> |
'COVAR_SAMP', |
92 |
> |
'CREATE', |
93 |
> |
'CROSS', |
94 |
> |
'CURRENT', |
95 |
> |
'CURRENT_CONNECTION', |
96 |
> |
'CURRENT_DATE', |
97 |
> |
'CURRENT_ROLE', |
98 |
> |
'CURRENT_TIME', |
99 |
> |
'CURRENT_TIMESTAMP', |
100 |
> |
'CURRENT_TRANSACTION', |
101 |
> |
'CURRENT_USER', |
102 |
> |
'CURSOR', |
103 |
> |
'DATE', |
104 |
> |
'DAY', |
105 |
> |
'DEC', |
106 |
> |
'DECIMAL', |
107 |
> |
'DECLARE', |
108 |
> |
'DEFAULT', |
109 |
> |
'DELETE', |
110 |
> |
'DELETING', |
111 |
> |
'DETERMINISTIC', |
112 |
> |
'DISCONNECT', |
113 |
> |
'DISTINCT', |
114 |
> |
'DOUBLE', |
115 |
> |
'DROP', |
116 |
> |
'ELSE', |
117 |
> |
'END', |
118 |
> |
'ESCAPE', |
119 |
> |
'EXECUTE', |
120 |
> |
'EXISTS', |
121 |
> |
'EXTERNAL', |
122 |
> |
'EXTRACT', |
123 |
> |
'FALSE', |
124 |
> |
'FETCH', |
125 |
> |
'FILTER', |
126 |
> |
'FLOAT', |
127 |
> |
'FOR', |
128 |
> |
'FOREIGN', |
129 |
> |
'FROM', |
130 |
> |
'FULL', |
131 |
> |
'FUNCTION', |
132 |
> |
'GDSCODE', |
133 |
> |
'GLOBAL', |
134 |
> |
'GRANT', |
135 |
> |
'GROUP', |
136 |
> |
'HAVING', |
137 |
> |
'HOUR', |
138 |
> |
'IN', |
139 |
> |
'INDEX', |
140 |
> |
'INNER', |
141 |
> |
'INSENSITIVE', |
142 |
> |
'INSERT', |
143 |
> |
'INSERTING', |
144 |
> |
'INT', |
145 |
> |
'INTEGER', |
146 |
> |
'INTO', |
147 |
> |
'IS', |
148 |
> |
'JOIN', |
149 |
> |
'LEADING', |
150 |
> |
'LEFT', |
151 |
> |
'LIKE', |
152 |
> |
'LONG', |
153 |
> |
'LOWER', |
154 |
> |
'MAX', |
155 |
> |
'MAXIMUM_SEGMENT', |
156 |
> |
'MERGE', |
157 |
> |
'MIN', |
158 |
> |
'MINUTE', |
159 |
> |
'MONTH', |
160 |
> |
'NATIONAL', |
161 |
> |
'NATURAL', |
162 |
> |
'NCHAR', |
163 |
> |
'NO', |
164 |
> |
'NOT', |
165 |
> |
'NULL', |
166 |
> |
'NUMERIC', |
167 |
> |
'OCTET_LENGTH', |
168 |
> |
'OF', |
169 |
> |
'OFFSET', |
170 |
> |
'ON', |
171 |
> |
'ONLY', |
172 |
> |
'OPEN', |
173 |
> |
'OR', |
174 |
> |
'ORDER', |
175 |
> |
'OUTER', |
176 |
> |
'OVER', |
177 |
> |
'PARAMETER', |
178 |
> |
'PLAN', |
179 |
> |
'POSITION', |
180 |
> |
'POST_EVENT', |
181 |
> |
'PRECISION', |
182 |
> |
'PRIMARY', |
183 |
> |
'PROCEDURE', |
184 |
> |
'RDB$DB_KEY', |
185 |
> |
'RDB$RECORD_VERSION', |
186 |
> |
'REAL', |
187 |
> |
'RECORD_VERSION', |
188 |
> |
'RECREATE', |
189 |
> |
'RECURSIVE', |
190 |
> |
'REFERENCES', |
191 |
> |
'REGR_AVGX', |
192 |
> |
'REGR_AVGY', |
193 |
> |
'REGR_COUNT', |
194 |
> |
'REGR_INTERCEPT', |
195 |
> |
'REGR_R2', |
196 |
> |
'REGR_SLOPE', |
197 |
> |
'REGR_SXX', |
198 |
> |
'REGR_SXY', |
199 |
> |
'REGR_SYY', |
200 |
> |
'RELEASE', |
201 |
> |
'RETURN', |
202 |
> |
'RETURNING_VALUES', |
203 |
> |
'RETURNS', |
204 |
> |
'REVOKE', |
205 |
> |
'RIGHT', |
206 |
> |
'ROLLBACK', |
207 |
> |
'ROW', |
208 |
> |
'ROW_COUNT', |
209 |
> |
'ROWS', |
210 |
> |
'SAVEPOINT', |
211 |
> |
'SCROLL', |
212 |
> |
'SECOND', |
213 |
> |
'SELECT', |
214 |
> |
'SENSITIVE', |
215 |
> |
'SET', |
216 |
> |
'SIMILAR', |
217 |
> |
'SMALLINT', |
218 |
> |
'SOME', |
219 |
> |
'SQLCODE', |
220 |
> |
'SQLSTATE', |
221 |
> |
'SQLSTATE', |
222 |
> |
'START', |
223 |
> |
'STDDEV_POP', |
224 |
> |
'STDDEV_SAMP', |
225 |
> |
'SUM', |
226 |
> |
'TABLE', |
227 |
> |
'THEN', |
228 |
> |
'TIME', |
229 |
> |
'TIMESTAMP', |
230 |
> |
'TO', |
231 |
> |
'TRAILING', |
232 |
> |
'TRIGGER', |
233 |
> |
'TRIM', |
234 |
> |
'TRUE', |
235 |
> |
'UNION', |
236 |
> |
'UNIQUE', |
237 |
> |
'UNKNOWN', |
238 |
> |
'UPDATE', |
239 |
> |
'UPDATING', |
240 |
> |
'UPPER', |
241 |
> |
'USER', |
242 |
> |
'USING', |
243 |
> |
'VALUE', |
244 |
> |
'VALUES', |
245 |
> |
'VAR_POP', |
246 |
> |
'VAR_SAMP', |
247 |
> |
'VARCHAR', |
248 |
> |
'VARIABLE', |
249 |
> |
'VARYING', |
250 |
> |
'VIEW', |
251 |
> |
'WHEN', |
252 |
> |
'WHERE', |
253 |
> |
'WHILE', |
254 |
> |
'WITH', |
255 |
> |
'YEAR' |
256 |
> |
); |
257 |
|
|
258 |
|
function Max(n1, n2: Integer): Integer; |
259 |
|
function Min(n1, n2: Integer): Integer; |
260 |
< |
function RandomString(iLength: Integer): String; |
260 |
> |
function RandomString(iLength: Integer): AnsiString; |
261 |
|
function RandomInteger(iLow, iHigh: Integer): Integer; |
262 |
< |
function StripString(st: String; CharsToStrip: String): String; |
263 |
< |
function FormatIdentifier(Dialect: Integer; Value: String): String; |
264 |
< |
function FormatIdentifierValue(Dialect: Integer; Value: String): String; |
265 |
< |
function FormatIdentifierValueNC(Dialect: Integer; Value: String): String; |
266 |
< |
function ExtractIdentifier(Dialect: Integer; Value: String): String; |
267 |
< |
function QuoteIdentifier(Dialect: Integer; Value: String): String; |
268 |
< |
function QuoteIdentifierIfNeeded(Dialect: Integer; Value: String): String; |
269 |
< |
function Space2Underscore(s: string): string; |
262 |
> |
function StripString(st: AnsiString; CharsToStrip: AnsiString): AnsiString; |
263 |
> |
function ExtractIdentifier(Dialect: Integer; Value: AnsiString): AnsiString; |
264 |
> |
function QuoteIdentifier(Dialect: Integer; Value: AnsiString): AnsiString; |
265 |
> |
function QuoteIdentifierIfNeeded(Dialect: Integer; Value: AnsiString): AnsiString; |
266 |
> |
function Space2Underscore(s: AnsiString): AnsiString; |
267 |
> |
function SQLSafeString(const s: AnsiString): AnsiString; |
268 |
> |
function IsSQLIdentifier(Value: AnsiString): boolean; |
269 |
> |
function ExtractConnectString(const CreateSQL: AnsiString; var ConnectString: AnsiString): boolean; |
270 |
|
|
271 |
|
implementation |
272 |
|
|
273 |
+ |
{$IFDEF HASREQEX} |
274 |
+ |
uses RegExpr; |
275 |
+ |
{$ENDIF} |
276 |
+ |
|
277 |
|
function Max(n1, n2: Integer): Integer; |
278 |
|
begin |
279 |
|
if (n1 > n2) then |
290 |
|
result := n2; |
291 |
|
end; |
292 |
|
|
293 |
< |
function RandomString(iLength: Integer): String; |
293 |
> |
function RandomString(iLength: Integer): AnsiString; |
294 |
|
begin |
295 |
|
result := ''; |
296 |
|
while Length(result) < iLength do |
304 |
|
result := Trunc(Random(iHigh - iLow)) + iLow; |
305 |
|
end; |
306 |
|
|
307 |
< |
function StripString(st: String; CharsToStrip: String): String; |
307 |
> |
function StripString(st: AnsiString; CharsToStrip: AnsiString): AnsiString; |
308 |
|
var |
309 |
|
i: Integer; |
310 |
|
begin |
315 |
|
end; |
316 |
|
end; |
317 |
|
|
318 |
< |
function FormatIdentifier(Dialect: Integer; Value: String): String; |
132 |
< |
begin |
133 |
< |
Value := Trim(Value); |
134 |
< |
if Dialect = 1 then |
135 |
< |
Value := AnsiUpperCase(Value) |
136 |
< |
else |
137 |
< |
if (Value <> '') and (Value[1] = '"') then |
138 |
< |
Value := '"' + StringReplace (TrimRight(Value), '"', '""', [rfReplaceAll]) + '"' |
139 |
< |
else |
140 |
< |
Value := AnsiUpperCase(Value); |
141 |
< |
Result := Value; |
142 |
< |
end; |
318 |
> |
{Extracts SQL Identifier typically from a Dialect 3 encoding} |
319 |
|
|
320 |
< |
function FormatIdentifierValue(Dialect: Integer; Value: String): String; |
320 |
> |
function ExtractIdentifier(Dialect: Integer; Value: AnsiString): AnsiString; |
321 |
|
begin |
322 |
|
Value := Trim(Value); |
323 |
|
if Dialect = 1 then |
336 |
|
Result := Value; |
337 |
|
end; |
338 |
|
|
339 |
< |
function FormatIdentifierValueNC(Dialect: Integer; Value: String): String; |
164 |
< |
begin |
165 |
< |
Value := Trim(Value); |
166 |
< |
if Dialect = 1 then |
167 |
< |
Value := AnsiUpperCase(Value) |
168 |
< |
else |
169 |
< |
begin |
170 |
< |
if (Value <> '') and (Value[1] = '"') then |
171 |
< |
begin |
172 |
< |
Delete(Value, 1, 1); |
173 |
< |
Delete(Value, Length(Value), 1); |
174 |
< |
Value := AnsiUpperCase(StringReplace (Value, '""', '"', [rfReplaceAll])); |
175 |
< |
end |
176 |
< |
else |
177 |
< |
Value := AnsiUpperCase(Value); |
178 |
< |
end; |
179 |
< |
Result := Value; |
180 |
< |
end; |
339 |
> |
{Returns true if "w" is a Firebird SQL reserved word} |
340 |
|
|
341 |
< |
function ExtractIdentifier(Dialect: Integer; Value: String): String; |
183 |
< |
begin |
184 |
< |
Value := Trim(Value); |
185 |
< |
if Dialect = 1 then |
186 |
< |
Value := AnsiUpperCase(Value) |
187 |
< |
else |
188 |
< |
begin |
189 |
< |
if (Value <> '') and (Value[1] = '"') then |
190 |
< |
begin |
191 |
< |
Delete(Value, 1, 1); |
192 |
< |
Delete(Value, Length(Value), 1); |
193 |
< |
Value := StringReplace (Value, '""', '"', [rfReplaceAll]); |
194 |
< |
end |
195 |
< |
else |
196 |
< |
Value := AnsiUpperCase(Value); |
197 |
< |
end; |
198 |
< |
Result := Value; |
199 |
< |
end; |
200 |
< |
|
201 |
< |
function IsReservedWord(w: string): boolean; |
341 |
> |
function IsReservedWord(w: AnsiString): boolean; |
342 |
|
var i: integer; |
343 |
|
begin |
344 |
|
Result := true; |
348 |
|
Result := false; |
349 |
|
end; |
350 |
|
|
351 |
< |
function QuoteIdentifier(Dialect: Integer; Value: String): String; |
351 |
> |
{Format an SQL Identifier according to SQL Dialect} |
352 |
> |
|
353 |
> |
function QuoteIdentifier(Dialect: Integer; Value: AnsiString): AnsiString; |
354 |
|
begin |
355 |
|
if Dialect = 1 then |
356 |
|
Value := AnsiUpperCase(Trim(Value)) |
357 |
|
else |
358 |
< |
Value := '"' + Value + '"'; |
358 |
> |
Value := '"' + StringReplace (Value, '""', '"', [rfReplaceAll]) + '"'; |
359 |
|
Result := Value; |
360 |
|
end; |
361 |
|
|
362 |
< |
function QuoteIdentifierIfNeeded(Dialect: Integer; Value: String): String; |
362 |
> |
const |
363 |
> |
ValidSQLIdentifierChars = ['A'..'Z','a'..'z','0'..'9','_','$']; |
364 |
> |
|
365 |
> |
{Returns true if the value is a valid SQL Identifier - note lower case accepted} |
366 |
> |
|
367 |
> |
function IsSQLIdentifier(Value: AnsiString): boolean; |
368 |
> |
var i: integer; |
369 |
> |
begin |
370 |
> |
Result := false; |
371 |
> |
for i := 1 to Length(Value) do |
372 |
> |
if not (Value[i] in ValidSQLIdentifierChars) then Exit; |
373 |
> |
Result := true; |
374 |
> |
end; |
375 |
> |
|
376 |
> |
{Extracts the Database Connect string from a Create Database Statement} |
377 |
> |
|
378 |
> |
{$IFDEF HASREQEX} |
379 |
> |
function ExtractConnectString(const CreateSQL: AnsiString; |
380 |
> |
var ConnectString: AnsiString): boolean; |
381 |
> |
var RegexObj: TRegExpr; |
382 |
> |
begin |
383 |
> |
RegexObj := TRegExpr.Create; |
384 |
> |
try |
385 |
> |
{extact database file spec} |
386 |
> |
RegexObj.ModifierG := false; {turn off greedy matches} |
387 |
> |
RegexObj.ModifierI := true; {case insensitive match} |
388 |
> |
RegexObj.Expression := '^ *CREATE +(DATABASE|SCHEMA) +''(.*)'''; |
389 |
> |
Result := RegexObj.Exec(CreateSQL); |
390 |
> |
if Result then |
391 |
> |
ConnectString := system.copy(CreateSQL,RegexObj.MatchPos[2],RegexObj.MatchLen[2]); |
392 |
> |
finally |
393 |
> |
RegexObj.Free; |
394 |
> |
end; |
395 |
> |
end; |
396 |
> |
{$ELSE} |
397 |
> |
{cruder version of above for Delphi. Older versions lack regular expression |
398 |
> |
handling.} |
399 |
> |
function ExtractConnectString(const CreateSQL: AnsiString; |
400 |
> |
var ConnectString: AnsiString): boolean; |
401 |
> |
var i: integer; |
402 |
> |
begin |
403 |
> |
Result := false; |
404 |
> |
i := Pos('''',CreateSQL); |
405 |
> |
if i > 0 then |
406 |
> |
begin |
407 |
> |
ConnectString := CreateSQL; |
408 |
> |
delete(ConnectString,1,i); |
409 |
> |
i := Pos('''',ConnectString); |
410 |
> |
if i > 0 then |
411 |
> |
begin |
412 |
> |
delete(ConnectString,i,Length(ConnectString)-i+1); |
413 |
> |
Result := true; |
414 |
> |
end; |
415 |
> |
end; |
416 |
> |
end; |
417 |
> |
{$ENDIF} |
418 |
> |
|
419 |
> |
{Format an SQL Identifier according to SQL Dialect with encapsulation if necessary} |
420 |
> |
|
421 |
> |
function QuoteIdentifierIfNeeded(Dialect: Integer; Value: AnsiString): AnsiString; |
422 |
|
begin |
423 |
|
if (Dialect = 3) and |
424 |
< |
((AnsiUpperCase(Value) <> Value) or IsReservedWord(Value)) then |
425 |
< |
Result := '"' + Value + '"' |
424 |
> |
(IsReservedWord(Value) or not IsSQLIdentifier(Value) or (AnsiUpperCase(Value) <> Value)) then |
425 |
> |
Result := '"' + StringReplace (TrimRight(Value), '"', '""', [rfReplaceAll]) + '"' |
426 |
|
else |
427 |
|
Result := Value |
428 |
|
end; |
429 |
|
|
430 |
< |
function Space2Underscore(s: string): string; |
430 |
> |
{Replaces unknown characters in a string with underscores} |
431 |
> |
|
432 |
> |
function Space2Underscore(s: AnsiString): AnsiString; |
433 |
|
var |
434 |
|
k: integer; |
435 |
|
begin |
436 |
|
Result := s; |
437 |
|
for k := 1 to Length(s) do |
438 |
< |
if not (Result[k] in ['0'..'9','A'..'Z','_','$']) then |
438 |
> |
if not (Result[k] in ValidSQLIdentifierChars) then |
439 |
|
Result[k] := '_'; |
440 |
|
end; |
441 |
|
|
442 |
+ |
{Reformats an SQL string with single quotes duplicated.} |
443 |
+ |
|
444 |
+ |
function SQLSafeString(const s: AnsiString): AnsiString; |
445 |
+ |
begin |
446 |
+ |
Result := StringReplace(s,'''','''''',[rfReplaceAll]); |
447 |
+ |
end; |
448 |
|
|
449 |
|
end. |