testfieldtypes.pas 64 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064
  1. unit TestFieldTypes;
  2. {$mode objfpc}{$H+}
  3. {$modeswitch nestedprocvars}
  4. interface
  5. uses
  6. Classes, SysUtils, fpcunit, testutils, testregistry,
  7. db;
  8. type
  9. TParamProc = procedure(AParam:TParam; i : integer);
  10. TFieldProc = procedure(AField:TField; i : integer);
  11. TGetSQLTextProc = function(const i: integer) : string; { is nested;}
  12. TCheckFieldValueProc = procedure(AField:TField; i : integer) is nested;
  13. { TTestFieldTypes }
  14. TTestFieldTypes= class(TTestCase)
  15. private
  16. procedure CreateTableWithFieldType(ADatatype : TFieldType; ASQLTypeDecl : string);
  17. procedure TestFieldDeclaration(ADatatype: TFieldType; ADataSize: integer);
  18. procedure TestSQLFieldType(ADatatype: TFieldType; ASQLTypeDecl: string;
  19. ADataSize: integer; AGetSQLTextProc: TGetSQLTextProc;
  20. ACheckFieldValueProc: TCheckFieldValueProc);
  21. procedure TestXXParamQuery(ADatatype : TFieldType; ASQLTypeDecl : string; testValuescount : integer; Cross : boolean = false);
  22. procedure TestSetBlobAsParam(asWhat : integer);
  23. protected
  24. procedure SetUp; override;
  25. procedure TearDown; override;
  26. procedure RunTest; override;
  27. published
  28. procedure TestEmptyUpdateQuery; // bug 13654
  29. procedure TestParseJoins; // bug 10148
  30. procedure TestDoubleFieldNames; // bug 8457
  31. procedure TestParseUnion; // bug 8442
  32. procedure TestInsertLargeStrFields; // bug 9600
  33. procedure TestNumericNames; // Bug9661
  34. procedure TestApplyUpdFieldnames; // Bug 12275;
  35. procedure TestLimitQuery; // bug 15456
  36. procedure Test11Params;
  37. procedure TestRowsAffected; // bug 9758
  38. procedure TestLocateNull;
  39. procedure TestLocateOnMoreRecords;
  40. procedure TestStringsReplace;
  41. procedure TestCircularParams;
  42. procedure TestBug9744;
  43. procedure TestCrossStringDateParam;
  44. procedure TestGetFieldNames;
  45. procedure TestUpdateIndexDefs;
  46. procedure TestMultipleFieldPKIndexDefs;
  47. procedure TestSetBlobAsMemoParam;
  48. procedure TestSetBlobAsBlobParam;
  49. procedure TestSetBlobAsStringParam;
  50. procedure TestNonNullableParams;
  51. procedure TestGetIndexDefs;
  52. procedure TestDblQuoteEscComments;
  53. procedure TestpfInUpdateFlag; // bug 7565
  54. procedure TestInt;
  55. procedure TestScript;
  56. procedure TestInsertReturningQuery;
  57. procedure TestOpenStoredProc;
  58. procedure TestTemporaryTable;
  59. procedure TestRefresh;
  60. procedure TestParametersAndDates;
  61. procedure TestExceptOnsecClose;
  62. procedure TestErrorOnEmptyStatement;
  63. procedure TestBlob;
  64. procedure TestChangeBlob;
  65. procedure TestBlobGetText;
  66. procedure TestBlobSize;
  67. procedure TestLargeRecordSize;
  68. procedure TestNumeric;
  69. procedure TestFloat;
  70. procedure TestDateTime; // bug 6925
  71. procedure TestString;
  72. procedure TestUnlVarChar;
  73. procedure TestDate;
  74. procedure TestNullValues;
  75. procedure TestParamQuery;
  76. procedure TestStringParamQuery;
  77. procedure TestFixedStringParamQuery;
  78. procedure TestDateParamQuery;
  79. procedure TestIntParamQuery;
  80. procedure TestTimeParamQuery;
  81. procedure TestDateTimeParamQuery;
  82. procedure TestFmtBCDParamQuery;
  83. procedure TestFloatParamQuery;
  84. procedure TestBCDParamQuery;
  85. procedure TestBytesParamQuery;
  86. procedure TestVarBytesParamQuery;
  87. procedure TestAggregates;
  88. procedure TestStringLargerThen8192;
  89. procedure TestQueryAfterReconnect; // bug 16438
  90. // SchemaType tests
  91. procedure TestTableNames;
  92. procedure TestFieldNames;
  93. procedure TestClearUpdateableStatus;
  94. procedure TestReadOnlyParseSQL; // bug 9254
  95. procedure TestGetTables;
  96. // Test SQL-field type recognition
  97. procedure TestSQLClob;
  98. procedure TestSQLLargeint;
  99. procedure TestSQLInterval;
  100. procedure TestSQLIdentity;
  101. end;
  102. implementation
  103. uses sqldbtoolsunit,toolsunit, variants, sqldb, bufdataset, strutils, dbconst, FmtBCD;
  104. Type HackedDataset = class(TDataset);
  105. const
  106. testFloatValuesCount = 21;
  107. testFloatValues : Array[0..testFloatValuesCount-1] of double = (-maxSmallint-1,-maxSmallint,-256,-255,-128,-127,-1,0,1,127,128,255,256,maxSmallint,maxSmallint+1,0.123456,-0.123456,4.35,12.434E7,9.876e-5,123.45678);
  108. testBCDValuesCount = 10;
  109. testBCDValues : Array[0..testBCDValuesCount-1] of currency = (-100,54.53,1.2345,123.5345,0,1,-1,0,1.42,1324.4324);
  110. testIntValuesCount = 17;
  111. testIntValues : Array[0..testIntValuesCount-1] of integer = (-maxInt,-maxSmallint-1,-maxSmallint,-256,-255,-128,-127,-1,0,1,127,128,255,256,maxSmallint,maxSmallint+1,MaxInt);
  112. testDateValuesCount = 18;
  113. testDateValues : Array[0..testDateValuesCount-1] of string = (
  114. '2000-01-01',
  115. '1999-12-31',
  116. '2004-02-29',
  117. '2004-03-01',
  118. '1991-02-28',
  119. '1991-03-01',
  120. '2040-10-16',
  121. '1977-09-29',
  122. '1899-12-29',
  123. '1899-12-30',
  124. '1899-12-31',
  125. '1900-01-01',
  126. '1800-03-30',
  127. '1754-06-04',
  128. '1650-05-10',
  129. '0904-04-12',
  130. '0199-07-09',
  131. '0001-01-01'
  132. );
  133. testBytesValuesCount = 5;
  134. testVarBytesValuesCount = 8;
  135. testBytesValues : Array[0..testVarBytesValuesCount-1] of shortstring = (
  136. #1#0#1#0#1, #0#0#1#0#1, #0''''#13#0#1, '\'#0'"\'#13, #13#13#0#10#10,
  137. '', #0, #0#1#2#3#4#5#6#7#8#9
  138. );
  139. STestNotApplicable = 'This test does not apply to this sqldb-connection type';
  140. procedure TTestFieldTypes.TestpfInUpdateFlag;
  141. var ds : TCustomBufDataset;
  142. AFld1, AFld2, AFld3 : Tfield;
  143. begin
  144. ds := (DBConnector.GetNDataset(True,5) as TCustomBufDataset);
  145. with ds do
  146. begin
  147. AFld1 := TIntegerField.Create(ds);
  148. AFld1.FieldName := 'ID';
  149. AFld1.DataSet := ds;
  150. AFld1.ProviderFlags := AFld1.ProviderFlags + [pfInKey];
  151. AFld2 := TStringField.Create(ds);
  152. AFld2.FieldName := 'NAME';
  153. AFld2.DataSet := ds;
  154. AFld3 := TIntegerField.Create(ds);
  155. AFld3.FieldName := 'CALCFLD';
  156. AFld3.DataSet := ds;
  157. Afld3.FieldKind := fkCalculated;
  158. AFld3.ProviderFlags := [];
  159. Open;
  160. Edit;
  161. FieldByName('ID').AsInteger := 254;
  162. Post;
  163. ApplyUpdates;
  164. Append;
  165. FieldByName('ID').AsInteger := 255;
  166. Post;
  167. ApplyUpdates;
  168. Close;
  169. AFld1.Free;
  170. AFld2.Free;
  171. AFld3.Free;
  172. end;
  173. end;
  174. procedure TTestFieldTypes.TestScript;
  175. var Ascript : TSQLScript;
  176. begin
  177. Ascript := tsqlscript.create(nil);
  178. try
  179. with Ascript do
  180. begin
  181. DataBase := TSQLDBConnector(DBConnector).Connection;
  182. transaction := TSQLDBConnector(DBConnector).Transaction;
  183. script.clear;
  184. script.append('create table a (id int);');
  185. script.append('create table b (id int);');
  186. ExecuteScript;
  187. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  188. if SQLDbType=interbase then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  189. end;
  190. finally
  191. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('drop table a');
  192. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('drop table b');
  193. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  194. if SQLDbType=interbase then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  195. end;
  196. end;
  197. procedure TTestFieldTypes.TestInt;
  198. var
  199. i : byte;
  200. begin
  201. CreateTableWithFieldType(ftInteger,'INT');
  202. TestFieldDeclaration(ftInteger,4);
  203. for i := 0 to testIntValuesCount-1 do
  204. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + inttostr(testIntValues[i]) + ')');
  205. with TSQLDBConnector(DBConnector).Query do
  206. begin
  207. Open;
  208. for i := 0 to testIntValuesCount-1 do
  209. begin
  210. AssertEquals(testIntValues[i],fields[0].AsInteger);
  211. Next;
  212. end;
  213. close;
  214. end;
  215. end;
  216. procedure TTestFieldTypes.TestLargeRecordSize;
  217. begin
  218. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (plant varchar(8192),sampling_type varchar(8192),area varchar(8192), area_description varchar(8192), batch varchar(8192), sampling_datetime timestamp, status varchar(8192), batch_commentary varchar(8192))');
  219. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  220. if UpperCase(dbconnectorparams)='INTERBASE' then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  221. with TSQLDBConnector(DBConnector).Query do
  222. begin
  223. sql.clear;
  224. sql.append('insert into FPDEV2 (plant,sampling_type,batch,sampling_datetime,status,batch_commentary) values (''ZUBNE PASTE'',''OTISCI POVR￿INA'',''000037756'',''2005-07-01'',''NE ODGOVARA'',''Ovdje se upisuje komentar o kontrolnom broju..............'')');
  225. ExecSQL;
  226. sql.clear;
  227. sql.append('select * from FPDEV2');
  228. open;
  229. AssertEquals('ZUBNE PASTE',FieldByName('plant').AsString);
  230. AssertEquals(EncodeDate(2005,07,01),FieldByName('sampling_datetime').AsDateTime);
  231. close;
  232. end;
  233. end;
  234. procedure TTestFieldTypes.TestNumeric;
  235. const
  236. testValuesCount = 13;
  237. testValues4 : Array[0..testValuesCount-1] of currency = (-99.99,-12.34,-10.2,-10,-0.5,-0.01,0,0.01,0.5,10,10.2,12.34,99.99);
  238. testValues9 : Array[0..testValuesCount-1] of currency = (-123456.789,-10000,-1875.25,-10,-0.5,-0.001,0,0.001,0.5,10,1875.25,10000,123456.789);
  239. FieldTypes: array [0..7] of TFieldType = (ftBCD, ftBCD, ftBCD, ftFmtBCD, ftLargeInt, ftFmtBCD, ftFmtBCD, ftFmtBCD);
  240. FieldSizes: array [0..7] of integer = (4,2,3,5,0,3,5,0); //scale
  241. var
  242. i,d : integer;
  243. s,s4,s9 : string;
  244. t : TFieldType;
  245. begin
  246. with TSQLDBConnector(DBConnector) do begin
  247. if SQLDbType = INTERBASE then
  248. begin
  249. //Interbase internal storage of exact numeric data types based on precision:
  250. // 1-4 (smallint), 5-9 (integer), 10-18 (int64)
  251. s := ''; //Interbase supports precision up to 18 only
  252. FieldTypes[5] := ftBCD; //ATM TIBConnection incorrectly maps NUMERIC(18,3) to ftBCD
  253. end
  254. else
  255. s := ', N19_0 NUMERIC(19,0)';
  256. Connection.ExecuteDirect('create table FPDEV2 (FT NUMERIC(18,4), N4_2 NUMERIC(4,2), N9_3 NUMERIC(9,3), N9_5 NUMERIC(9,5), N18_0 NUMERIC(18,0), N18_3 NUMERIC(18,3), N18_5 NUMERIC(18,5)' + s + ')');
  257. Transaction.CommitRetaining;
  258. with Query do
  259. begin
  260. SQL.Text := 'select * from FPDEV2';
  261. Open;
  262. for i := 0 to FieldCount-1 do
  263. begin
  264. case Fields[i].DataType of
  265. ftBCD: d := sizeof(Currency);
  266. ftFmtBCD: d := sizeof(TBCD);
  267. ftLargeInt: d := sizeof(int64);
  268. else d := 0;
  269. end;
  270. t := FieldTypes[i];
  271. if t = ftLargeInt then t := ftFmtBCD; //acceptable alternative
  272. AssertEquals(Fields[i].DataSize, d);
  273. AssertTrue(Fields[i].DataType in [FieldTypes[i], t]);
  274. AssertEquals(Fields[i].Size, FieldSizes[i]);
  275. end;
  276. Close;
  277. end;
  278. for i := 0 to testValuesCount-1 do
  279. begin
  280. s4 := CurrToStrF(testValues4[i],ffFixed,2,DBConnector.FormatSettings);
  281. s9 := CurrToStrF(testValues9[i],ffFixed,3,DBConnector.FormatSettings);
  282. Connection.ExecuteDirect(format('insert into FPDEV2 (N4_2,N9_5,FT,N9_3,N18_3,N18_5) values (%s,%s,%s,%s,%s,%s)', [s4,s4,s9,s9,s9,s9]));
  283. end;
  284. with Query do
  285. begin
  286. Open;
  287. for i := 0 to testValuesCount-1 do
  288. begin
  289. AssertEquals(testValues4[i], Fields[1].AsCurrency);
  290. AssertEquals(testValues4[i], Fields[3].AsCurrency);
  291. AssertEquals(testValues9[i], Fields[0].AsCurrency);
  292. AssertEquals(testValues9[i], Fields[2].AsCurrency);
  293. AssertEquals(testValues9[i], Fields[5].AsCurrency);
  294. AssertEquals(testValues9[i], Fields[6].AsCurrency);
  295. Next;
  296. end;
  297. Close;
  298. end;
  299. end;
  300. end;
  301. procedure TTestFieldTypes.TestString;
  302. const
  303. testValuesCount = 19;
  304. testValues : Array[0..testValuesCount-1] of string = (
  305. '',
  306. 'a',
  307. 'ab',
  308. 'abc',
  309. 'abcd',
  310. 'abcde',
  311. 'abcdef',
  312. 'abcdefg',
  313. 'abcdefgh',
  314. 'abcdefghi',
  315. 'abcdefghij',
  316. 'lMnOpQrStU',
  317. '1234567890',
  318. '_!@#$%^&*(',
  319. ')-;:/?.<>',
  320. '~`|{}- =', // note that there's no \ (backslash) since some db's uses that as escape-character
  321. ' WRaP ',
  322. 'wRaP ',
  323. ' wRAP'
  324. );
  325. var
  326. i : byte;
  327. begin
  328. CreateTableWithFieldType(ftString,'VARCHAR(10)');
  329. TestFieldDeclaration(ftString,11);
  330. for i := 0 to testValuesCount-1 do
  331. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testValues[i] + ''')');
  332. with TSQLDBConnector(DBConnector).Query do
  333. begin
  334. Open;
  335. for i := 0 to testValuesCount-1 do
  336. begin
  337. AssertEquals(testValues[i], Fields[0].AsString);
  338. Next;
  339. end;
  340. close;
  341. end;
  342. end;
  343. procedure TTestFieldTypes.TestUnlVarChar;
  344. const
  345. testValuesCount = 21;
  346. testValues : Array[0..testValuesCount-1] of string = (
  347. '',
  348. 'a',
  349. 'ab',
  350. 'abc',
  351. 'abcd',
  352. 'abcde',
  353. 'abcdef',
  354. 'abcdefg',
  355. 'abcdefgh',
  356. 'abcdefghi',
  357. 'abcdefghij',
  358. 'lMnOpQrStU',
  359. '1234567890',
  360. '_!@#$%^&*(',
  361. ')-;:/?.<>',
  362. '~`|{}- =',
  363. ' WRaP ',
  364. 'wRaP ',
  365. ' wRAP',
  366. '0123456789',
  367. 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?' + 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?'
  368. + 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?' + 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?'
  369. );
  370. var
  371. i : byte;
  372. begin
  373. if SQLDbType<>postgresql then Ignore('This test does only apply to Postgres, since others don''t support varchars without length given');
  374. CreateTableWithFieldType(ftString,'VARCHAR');
  375. TestFieldDeclaration(ftString,dsMaxStringSize+1);
  376. for i := 0 to testValuesCount-1 do
  377. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testValues[i] + ''')');
  378. with TSQLDBConnector(DBConnector).Query do
  379. begin
  380. Open;
  381. for i := 0 to testValuesCount-1 do
  382. begin
  383. AssertEquals(testValues[i],fields[0].AsString);
  384. Next;
  385. end;
  386. close;
  387. end;
  388. end;
  389. procedure TTestFieldTypes.TestDate;
  390. var
  391. i : byte;
  392. begin
  393. CreateTableWithFieldType(ftDate,'DATE');
  394. TestFieldDeclaration(ftDate,8);
  395. for i := 0 to testDateValuesCount-1 do
  396. if SQLDbType=oracle then
  397. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (to_date (''' + testDateValues[i] + ''',''YYYY-MM-DD''))')
  398. else
  399. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testDateValues[i] + ''')');
  400. // TSQLDBConnector(DBConnector).Transaction.CommitRetaining; // For debug-purposes
  401. with TSQLDBConnector(DBConnector).Query do
  402. begin
  403. Open;
  404. for i := 0 to testDateValuesCount-1 do
  405. begin
  406. AssertEquals(testDateValues[i],FormatDateTime('yyyy/mm/dd', fields[0].AsDateTime, DBConnector.FormatSettings));
  407. Next;
  408. end;
  409. close;
  410. end;
  411. end;
  412. procedure TTestFieldTypes.TestChangeBlob;
  413. var s : string;
  414. begin
  415. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (ID int,FT '+FieldtypeDefinitions[ftblob]+')');
  416. TSQLDBConnector(DBConnector).Transaction.CommitRetaining; // For interbase
  417. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (ID,FT) values (1,''Test deze blob'')');
  418. with TSQLDBConnector(DBConnector).Query do
  419. begin
  420. sql.clear;
  421. sql.add('select * from FPDEV2');
  422. Open;
  423. fields[1].ProviderFlags := [pfInUpdate]; // blob niet in de where
  424. UpdateMode := upWhereAll;
  425. AssertEquals('Test deze blob',fields[1].AsString);
  426. edit;
  427. // Dat werkt niet lekker, omdat de stream vernield wordt...
  428. // fields[0].asstring := 'Deze blob is gewijzigd!';
  429. With Createblobstream(fields[1],bmwrite) do
  430. begin
  431. s := 'Deze blob is gewijzigd!';
  432. WriteBuffer(Pointer(s)^,Length(s));
  433. post;
  434. free;
  435. end;
  436. AssertEquals('Deze blob is gewijzigd!',fields[1].AsString);
  437. ApplyUpdates(0);
  438. TSQLDBConnector(DBConnector).Transaction.CommitRetaining; // For debug-purposes
  439. close;
  440. open;
  441. AssertEquals('Deze blob is gewijzigd!',fields[1].AsString);
  442. close;
  443. end;
  444. end;
  445. procedure TTestFieldTypes.TestBlobGetText;
  446. begin
  447. CreateTableWithFieldType(ftBlob,FieldtypeDefinitions[ftBlob]);
  448. TestFieldDeclaration(ftBlob,0);
  449. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''Test deze blob'')');
  450. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (Null)');
  451. // TSQLDBConnector(DBConnector).Transaction.CommitRetaining; // For debug-purposes
  452. with TSQLDBConnector(DBConnector).Query do
  453. begin
  454. Open;
  455. AssertFalse(fields[0].IsNull);
  456. AssertEquals('(BLOB)',fields[0].DisplayText);
  457. AssertEquals('Test deze blob',fields[0].AsString);
  458. Next;
  459. AssertTrue(fields[0].IsNull);
  460. AssertEquals('(blob)',fields[0].Text);
  461. AssertEquals('',fields[0].AsString);
  462. close;
  463. end;
  464. end;
  465. procedure TTestFieldTypes.TestBlobSize;
  466. begin
  467. CreateTableWithFieldType(ftBlob,FieldtypeDefinitions[ftBlob]);
  468. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''Test deze blob'')');
  469. with TSQLDBConnector(DBConnector).Query do
  470. begin
  471. sql.text := 'select * from FPDEV2';
  472. Open;
  473. AssertEquals(14,TBlobField(fields[0]).BlobSize);
  474. close;
  475. end;
  476. end;
  477. procedure TTestFieldTypes.TestSetBlobAsStringParam;
  478. begin
  479. TestSetBlobAsParam(1);
  480. end;
  481. procedure TTestFieldTypes.TestBlob;
  482. begin
  483. CreateTableWithFieldType(ftBlob,FieldtypeDefinitions[ftBlob]);
  484. TestFieldDeclaration(ftBlob,0);
  485. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''Test deze blob'')');
  486. // TSQLDBConnector(DBConnector).Transaction.CommitRetaining; // For debug-purposes
  487. with TSQLDBConnector(DBConnector).Query do
  488. begin
  489. Open;
  490. AssertEquals('Test deze blob',fields[0].AsString);
  491. close;
  492. end;
  493. end;
  494. procedure TTestFieldTypes.TestDateTime;
  495. const
  496. testValuesCount = 31;
  497. testValues : Array[0..testValuesCount-1] of string = (
  498. '2000-01-01',
  499. '1999-12-31',
  500. '2004-02-29',
  501. '2004-03-01',
  502. '1991-02-28',
  503. '1991-03-01',
  504. '1977-09-29',
  505. '2000-01-01 10:00:00',
  506. '2000-01-01 23:59:59',
  507. '1994-03-06 11:54:30',
  508. '1754-06-04', // MySQL 4.0 doesn't support datetimes before 1970 or after 2038
  509. '1899-12-29',
  510. '1899-12-30',
  511. '1899-12-31',
  512. '1900-01-01',
  513. '1899-12-30 18:00:51',
  514. '1899-12-30 04:00:51',
  515. '1899-12-29 04:00:51',
  516. '1899-12-29 18:00:51',
  517. '1903-04-02 01:04:02',
  518. '1815-09-24 03:47:22',
  519. '2040-10-16',
  520. '2100-01-01 01:01:01',
  521. '1400-02-03 12:21:53', // MS SQL 2005 doesn't support datetimes before 1753
  522. '0354-11-20 21:25:15',
  523. '1333-02-03 21:44:21',
  524. '1800-03-30',
  525. '1650-05-10',
  526. '0904-04-12',
  527. '0199-07-09',
  528. '0001-01-01'
  529. );
  530. var
  531. i : byte;
  532. begin
  533. CreateTableWithFieldType(ftDateTime,FieldtypeDefinitions[ftDateTime]);
  534. TestFieldDeclaration(ftDateTime,8);
  535. for i := 0 to testValuesCount-1 do
  536. if SQLDbType=oracle then
  537. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (to_date (''' + testValues[i] + ''',''YYYY-MM-DD HH24:MI:SS''))')
  538. else
  539. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testValues[i] + ''')');
  540. with TSQLDBConnector(DBConnector).Query do
  541. begin
  542. Open;
  543. for i := 0 to testValuesCount-1 do
  544. begin
  545. if length(testValues[i]) < 12 then
  546. AssertEquals(testValues[i],FormatDateTime('yyyy/mm/dd', fields[0].AsDateTime, DBConnector.FormatSettings))
  547. else
  548. AssertEquals(testValues[i],FormatDateTime('yyyy/mm/dd hh:mm:ss', fields[0].AsDateTime, DBConnector.FormatSettings));
  549. Next;
  550. end;
  551. close;
  552. end;
  553. end;
  554. procedure TTestFieldTypes.TestFloat;
  555. const
  556. testValuesCount = 21;
  557. testValues : Array[0..testValuesCount-1] of double = (-maxSmallint-1,-maxSmallint,-256,-255,-128,-127,-1,0,1,127,128,255,256,maxSmallint,maxSmallint+1,0.123456,-0.123456,4.35,12.434E7,9.876e-5,123.45678);
  558. var
  559. i : byte;
  560. begin
  561. CreateTableWithFieldType(ftFloat,'FLOAT');
  562. TestFieldDeclaration(ftFloat,sizeof(double));
  563. for i := 0 to testValuesCount-1 do
  564. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + floattostr(testValues[i],DBConnector.FormatSettings) + ')');
  565. with TSQLDBConnector(DBConnector).Query do
  566. begin
  567. Open;
  568. for i := 0 to testValuesCount-1 do
  569. begin
  570. AssertEquals(testValues[i],fields[0].AsFloat);
  571. Next;
  572. end;
  573. close;
  574. end;
  575. end;
  576. procedure TTestFieldTypes.TestNullValues;
  577. begin
  578. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (FIELD1 INT, FIELD2 INT)');
  579. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  580. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  581. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FIELD1) values (1)');
  582. with TSQLDBConnector(DBConnector).Query do
  583. begin
  584. sql.clear;
  585. sql.append('select * from FPDEV2');
  586. open;
  587. AssertEquals(1,FieldByName('FIELD1').AsInteger);
  588. AssertTrue('Null-values test failed',FieldByName('FIELD2').IsNull);
  589. close;
  590. end;
  591. end;
  592. procedure TTestFieldTypes.TestParamQuery;
  593. begin
  594. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (FIELD1 INT, FIELD2 INT, FIELD3 INT, DECOY VARCHAR(30))');
  595. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  596. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  597. with TSQLDBConnector(DBConnector).Query do
  598. begin
  599. sql.clear;
  600. sql.append('insert into FPDEV2 (field1) values (:field1)');
  601. Params.ParamByName('field1').AsInteger := 1;
  602. ExecSQL;
  603. sql.clear;
  604. sql.append('insert into FPDEV2 (field1,field2,decoy) values (:field1,:field2,''decoytest'')');
  605. Params.ParamByName('field1').AsInteger := 2;
  606. Params.ParamByName('field2').DataType := ftInteger;
  607. Params.ParamByName('field2').Value := Null;
  608. ExecSQL;
  609. sql.clear;
  610. sql.append('insert into FPDEV2 (field1,field2,field3) values (:field1,:field2,:field3)');
  611. Params.ParamByName('field1').AsInteger := 3;
  612. Params.ParamByName('field2').AsInteger := 2;
  613. Params.ParamByName('field3').AsInteger := 3;
  614. ExecSQL;
  615. sql.clear;
  616. sql.append('insert into FPDEV2 (field1,field2,field3,decoy) values (:field1,:field2,:field3,'':decoy ::test $decoy2 $$2'')');
  617. Params.ParamByName('field1').AsInteger := 4;
  618. Params.ParamByName('field2').AsInteger := 2;
  619. Params.ParamByName('field3').AsInteger := 3;
  620. ExecSQL;
  621. sql.clear;
  622. sql.append('insert into FPDEV2 (field1,field2,field3) values (:field1,:field2,:field1)');
  623. Params.ParamByName('field1').AsInteger := 5;
  624. Params.ParamByName('field2').AsInteger := 2;
  625. ExecSQL;
  626. sql.clear;
  627. sql.append('select * from FPDEV2 order by FIELD1');
  628. open;
  629. AssertEquals(1,FieldByName('FIELD1').asinteger);
  630. AssertTrue(FieldByName('FIELD2').IsNull);
  631. AssertTrue(FieldByName('FIELD3').IsNull);
  632. AssertTrue(FieldByName('DECOY').IsNull);
  633. next;
  634. AssertEquals(2,FieldByName('FIELD1').asinteger);
  635. AssertTrue(FieldByName('FIELD2').IsNull);
  636. AssertTrue(FieldByName('FIELD3').IsNull);
  637. AssertEquals('decoytest',FieldByName('DECOY').AsString);
  638. next;
  639. AssertEquals(3,FieldByName('FIELD1').asinteger);
  640. AssertEquals(2,FieldByName('FIELD2').asinteger);
  641. AssertEquals(3,FieldByName('FIELD3').asinteger);
  642. AssertTrue(FieldByName('DECOY').IsNull);
  643. next;
  644. AssertEquals(4,FieldByName('FIELD1').asinteger);
  645. AssertEquals(2,FieldByName('FIELD2').asinteger);
  646. AssertEquals(3,FieldByName('FIELD3').asinteger);
  647. AssertEquals(':decoy ::test $decoy2 $$2',FieldByName('DECOY').AsString);
  648. next;
  649. AssertEquals(5,FieldByName('FIELD1').asinteger);
  650. AssertEquals(2,FieldByName('FIELD2').asinteger);
  651. AssertEquals(5,FieldByName('FIELD3').asinteger);
  652. AssertTrue(FieldByName('DECOY').IsNull);
  653. close;
  654. end;
  655. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  656. end;
  657. procedure TTestFieldTypes.TestIntParamQuery;
  658. begin
  659. TestXXParamQuery(ftInteger,'INT',testIntValuesCount);
  660. end;
  661. procedure TTestFieldTypes.TestFmtBCDParamQuery;
  662. begin
  663. TestXXParamQuery(ftFMTBcd,FieldtypeDefinitionsConst[ftFMTBcd],testValuesCount);
  664. end;
  665. procedure TTestFieldTypes.TestDateParamQuery;
  666. begin
  667. TestXXParamQuery(ftDate,FieldtypeDefinitions[ftDate],testDateValuesCount);
  668. end;
  669. procedure TTestFieldTypes.TestTimeParamQuery;
  670. begin
  671. TestXXParamQuery(ftTime,FieldtypeDefinitions[ftTime],testValuesCount);
  672. end;
  673. procedure TTestFieldTypes.TestDateTimeParamQuery;
  674. begin
  675. TestXXParamQuery(ftDateTime,FieldtypeDefinitions[ftDateTime],testValuesCount);
  676. end;
  677. procedure TTestFieldTypes.TestFloatParamQuery;
  678. begin
  679. TestXXParamQuery(ftFloat,FieldtypeDefinitions[ftFloat],testFloatValuesCount);
  680. end;
  681. procedure TTestFieldTypes.TestBCDParamQuery;
  682. begin
  683. TestXXParamQuery(ftBCD,'NUMERIC(10,4)',testBCDValuesCount);
  684. end;
  685. procedure TTestFieldTypes.TestBytesParamQuery;
  686. begin
  687. TestXXParamQuery(ftBytes, FieldtypeDefinitions[ftBytes], testBytesValuesCount, true);
  688. end;
  689. procedure TTestFieldTypes.TestVarBytesParamQuery;
  690. begin
  691. TestXXParamQuery(ftVarBytes, FieldtypeDefinitions[ftVarBytes], testVarBytesValuesCount, SQLDbType<>mssql);
  692. end;
  693. procedure TTestFieldTypes.TestStringParamQuery;
  694. begin
  695. TestXXParamQuery(ftString,'VARCHAR(10)',testValuesCount);
  696. end;
  697. procedure TTestFieldTypes.TestFixedStringParamQuery;
  698. begin
  699. TestXXParamQuery(ftFixedChar,'CHAR(10)',testValuesCount);
  700. end;
  701. procedure TTestFieldTypes.TestXXParamQuery(ADatatype : TFieldType; ASQLTypeDecl : string; testValuescount : integer; Cross : boolean = false);
  702. var i : integer;
  703. begin
  704. if ASQLTypeDecl = '' then
  705. Ignore('Fields of the type ' + FieldTypeNames[ADatatype] + ' are not supported by this sqldb-connection type');
  706. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (ID INT, FIELD1 '+ASQLTypeDecl+')');
  707. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  708. if SQLDbType=interbase then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  709. with TSQLDBConnector(DBConnector).Query do
  710. begin
  711. sql.clear;
  712. sql.append('insert into FPDEV2 (ID,FIELD1) values (:id,:field1)');
  713. // There is no Param.AsFixedChar, so the datatype has to be set manually
  714. if ADatatype=ftFixedChar then
  715. Params.ParamByName('field1').DataType := ftFixedChar;
  716. for i := 0 to testValuesCount -1 do
  717. begin
  718. Params.ParamByName('id').AsInteger := i;
  719. case ADataType of
  720. ftInteger: Params.ParamByName('field1').asinteger := testIntValues[i];
  721. ftFloat : Params.ParamByName('field1').AsFloat := testFloatValues[i];
  722. ftBCD : Params.ParamByName('field1').AsCurrency:= testBCDValues[i];
  723. ftFixedChar,
  724. ftString : Params.ParamByName('field1').AsString := testValues[ADataType,i];
  725. ftTime : Params.ParamByName('field1').AsTime := TimeStringToDateTime(testTimeValues[i]);
  726. ftDate : if cross then
  727. Params.ParamByName('field1').AsString:= testDateValues[i]
  728. else
  729. Params.ParamByName('field1').AsDate := StrToDate(testDateValues[i],'yyyy/mm/dd','-');
  730. ftDateTime:Params.ParamByName('field1').AsDateTime := StrToDateTime(testValues[ADataType,i], DBConnector.FormatSettings);
  731. ftFMTBcd : Params.ParamByName('field1').AsFMTBCD := StrToBCD(testFmtBCDValues[i],DBConnector.FormatSettings);
  732. ftBytes : if cross then
  733. Params.ParamByName('field1').Value := StringToByteArray(testBytesValues[i])
  734. else
  735. Params.ParamByName('field1').AsBlob := testBytesValues[i];
  736. ftVarBytes:if cross then
  737. Params.ParamByName('field1').AsString := testBytesValues[i]
  738. else
  739. Params.ParamByName('field1').AsBlob := testBytesValues[i];
  740. else
  741. AssertTrue('no test for paramtype available',False);
  742. end;
  743. ExecSQL;
  744. end;
  745. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  746. sql.clear;
  747. sql.append('select * from FPDEV2 order by ID');
  748. open;
  749. for i := 0 to testValuesCount -1 do
  750. begin
  751. AssertEquals(i,FieldByName('ID').AsInteger);
  752. case ADataType of
  753. ftInteger: AssertEquals(testIntValues[i],FieldByName('FIELD1').AsInteger);
  754. ftFloat : AssertEquals(testFloatValues[i],FieldByName('FIELD1').AsFloat);
  755. ftBCD : AssertEquals(testBCDValues[i],FieldByName('FIELD1').AsCurrency);
  756. ftFixedChar : AssertEquals(PadRight(testStringValues[i],10),FieldByName('FIELD1').AsString);
  757. ftString : AssertEquals(testStringValues[i],FieldByName('FIELD1').AsString);
  758. ftTime : AssertEquals(testTimeValues[i],DateTimeToTimeString(FieldByName('FIELD1').AsDateTime));
  759. ftDate : AssertEquals(testDateValues[i],DateTimeToStr(FieldByName('FIELD1').AsDateTime, DBConnector.FormatSettings));
  760. ftDateTime : AssertEquals(testValues[ADataType,i], DateTimeToStr(FieldByName('FIELD1').AsDateTime, DBConnector.FormatSettings));
  761. ftFMTBcd : AssertEquals(testFmtBCDValues[i], BCDToStr(FieldByName('FIELD1').AsBCD, DBConnector.FormatSettings));
  762. ftVarBytes,
  763. ftBytes : AssertEquals(testBytesValues[i], shortstring(FieldByName('FIELD1').AsString));
  764. else
  765. AssertTrue('no test for paramtype available',False);
  766. end;
  767. Next;
  768. end;
  769. close;
  770. end;
  771. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  772. end;
  773. procedure TTestFieldTypes.TestSetBlobAsParam(asWhat: integer);
  774. var
  775. ASQL : TSQLQuery;
  776. begin
  777. CreateTableWithFieldType(ftBlob,FieldtypeDefinitions[ftBlob]);
  778. TestFieldDeclaration(ftBlob,0);
  779. ASQL := DBConnector.GetNDataset(True,1) as tsqlquery;
  780. with ASql do
  781. begin
  782. sql.Text := 'insert into FPDEV2 (FT) values (:BlobParam)';
  783. case asWhat of
  784. 0: Params.ParamByName('blobParam').AsMemo := 'Test deze BLob';
  785. 1: Params.ParamByName('blobParam').AsString := 'Test deze BLob';
  786. 2: Params.ParamByName('blobParam').AsBlob := 'Test deze BLob';
  787. end;
  788. ExecSQL;
  789. end;
  790. with TSQLDBConnector(DBConnector).Query do
  791. begin
  792. Open;
  793. if not eof then
  794. AssertEquals('Test deze BLob',fields[0].AsString);
  795. close;
  796. end;
  797. end;
  798. procedure TTestFieldTypes.TestAggregates;
  799. begin
  800. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (FIELD1 INT, FIELD2 INT)');
  801. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  802. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  803. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 values (1,1)');
  804. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 values (2,3)');
  805. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 values (3,4)');
  806. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 values (4,4)');
  807. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  808. with TSQLDBConnector(DBConnector).Query do
  809. begin
  810. sql.clear;
  811. sql.append('select count(*) from FPDEV2');
  812. open;
  813. AssertEquals(4,Fields[0].AsInteger);
  814. close;
  815. sql.clear;
  816. sql.append('select sum(FIELD1) from FPDEV2');
  817. open;
  818. AssertEquals(10,Fields[0].AsInteger);
  819. close;
  820. sql.clear;
  821. sql.append('select avg(FIELD2) from FPDEV2');
  822. open;
  823. AssertEquals(3,Fields[0].AsInteger);
  824. close;
  825. end;
  826. end;
  827. procedure TTestFieldTypes.CreateTableWithFieldType(ADatatype: TFieldType;
  828. ASQLTypeDecl: string);
  829. begin
  830. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (FT ' +ASQLTypeDecl+ ')');
  831. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  832. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  833. end;
  834. procedure TTestFieldTypes.TestFieldDeclaration(ADatatype: TFieldType;
  835. ADataSize: integer);
  836. begin
  837. with TSQLDBConnector(DBConnector).Query do
  838. begin
  839. SQL.Clear;
  840. SQL.Add('select * from FPDEV2');
  841. Open;
  842. AssertEquals(1,FieldCount);
  843. AssertTrue(CompareText('FT',fields[0].FieldName)=0);
  844. AssertEquals(ADataSize,fields[0].DataSize);
  845. AssertTrue(ADatatype=fields[0].DataType);
  846. Close;
  847. end;
  848. end;
  849. procedure TTestFieldTypes.SetUp;
  850. begin
  851. InitialiseDBConnector;
  852. end;
  853. procedure TTestFieldTypes.TearDown;
  854. begin
  855. if assigned(DBConnector) then
  856. TSQLDBConnector(DBConnector).Transaction.Rollback;
  857. FreeDBConnector;
  858. end;
  859. procedure TTestFieldTypes.RunTest;
  860. begin
  861. // if (SQLDbType in TSQLDBTypes) then
  862. inherited RunTest;
  863. end;
  864. procedure TTestFieldTypes.TestQueryAfterReconnect;
  865. var DS: TDataset;
  866. begin
  867. ds := DBConnector.GetNDataset(true,5);
  868. with ds do
  869. begin
  870. open;
  871. close;
  872. TSQLDBConnector(DBConnector).Connection.Close;
  873. TSQLDBConnector(DBConnector).Connection.Open;
  874. open;
  875. close;
  876. end;
  877. end;
  878. procedure TTestFieldTypes.TestLocateNull;
  879. var DS: TCustomBufDataset;
  880. begin
  881. ds := TSQLDBConnector(DBConnector).GetNDataset(true,5) as TCustomBufDataset;
  882. with ds do
  883. begin
  884. open;
  885. edit;
  886. fieldbyname('name').Clear;
  887. post;
  888. next;
  889. AssertFalse(Locate('name',VarArrayOf(['TestName1']),[]));
  890. AssertTrue(Locate('name',VarArrayOf([Null]),[]));
  891. AssertEquals(1,fieldbyname('ID').AsInteger);
  892. end;
  893. end;
  894. procedure TTestFieldTypes.TestLocateOnMoreRecords;
  895. var DS: TCustomBufDataset;
  896. begin
  897. with TSQLDBConnector(DBConnector) do
  898. begin
  899. ds := GetNDataset(true,30) as TCustomBufDataset;
  900. with query do
  901. begin
  902. SQL.Text:='update FPDEV set NAME = null where ID<11;';
  903. ExecSQL;
  904. SQL.Text:='update FPDEV set NAME = null where (ID>11) and (ID<23);';
  905. ExecSQL;
  906. end;
  907. with ds do
  908. begin
  909. Open;
  910. // Must be exactly 11 to trigger bug/test
  911. AssertTrue(Locate('name',VarArrayOf(['TestName11']),[]));
  912. AssertEquals(11,fieldbyname('ID').AsInteger);
  913. // Must be exactly 23 to trigger bug/test
  914. AssertTrue(Locate('name',VarArrayOf(['TestName23']),[]));
  915. AssertEquals(23,fieldbyname('ID').AsInteger);
  916. end;
  917. end;
  918. end;
  919. procedure TTestFieldTypes.TestRefresh;
  920. var ADataset: TDataset;
  921. i: integer;
  922. AFldID, AFldName: TField;
  923. begin
  924. ADataset := TSQLDBConnector(DBConnector).GetNDataset(true,5);
  925. Adataset.Open;
  926. AFldId:=Adataset.Fields[0];
  927. AFldName:=Adataset.Fields[1];
  928. for i := 1 to 5 do
  929. begin
  930. AssertEquals(i,AFldID.asinteger);
  931. AssertEquals('TestName'+inttostr(i),AFldName.asstring);
  932. ADataset.Next;
  933. end;
  934. ADataset.Next;
  935. AssertTrue(ADataset.EOF);
  936. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('update FPDEV set NAME=''test'' where ID=2');
  937. ADataset.Refresh;
  938. ADataset.First;
  939. for i := 1 to 5 do
  940. begin
  941. AssertEquals(i,AFldID.AsInteger);
  942. if i = 2 then
  943. AssertEquals('test',AFldName.AsString)
  944. else
  945. AssertEquals('TestName'+inttostr(i),AFldName.AsString);
  946. ADataset.Next;
  947. end;
  948. ADataset.Next;
  949. AssertTrue(ADataset.EOF);
  950. end;
  951. procedure TTestFieldTypes.TestEmptyUpdateQuery;
  952. begin
  953. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('update FPDEV set name=''nothing'' where (1=0)');
  954. end;
  955. procedure TTestFieldTypes.TestNonNullableParams;
  956. var ASQLQuery : TSQLQuery;
  957. Passed: Boolean;
  958. begin
  959. // Check for an exception when a null value is stored into a non-nullable
  960. // field using a parameter
  961. // There was a bug in IBConnection so that in this case the last used value
  962. // for the parameter was used.
  963. // To make sure that any changes are cancelled in the case the test fails
  964. TSQLDBConnector(DBConnector).GetNDataset(true,5);
  965. ASQLQuery := TSQLDBConnector(DBConnector).Query;
  966. ASQLQuery.SQL.text := 'update fpdev set ID=:ID1 where id = :ID2';
  967. ASQLQuery.Params[0].Clear;
  968. ASQLQuery.Params[1].AsInteger := 1;
  969. AssertTrue(ASQLQuery.Params[0].IsNull);
  970. Passed:=False;
  971. try
  972. @ASQLQuery.ExecSQL;
  973. except
  974. on E: Exception do
  975. if E.ClassType.InheritsFrom(EDatabaseError) then
  976. Passed := true;
  977. end;
  978. AssertTrue(Passed);
  979. end;
  980. procedure TTestFieldTypes.TestStringLargerThen8192;
  981. var
  982. s : string;
  983. i : integer;
  984. begin
  985. CreateTableWithFieldType(ftString,'VARCHAR(9000)');
  986. TestFieldDeclaration(ftString,9001);
  987. setlength(s,9000);
  988. for i := 1 to 9000 do
  989. s[i]:=chr((i mod 10)+ord('a'));
  990. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + s + ''')');
  991. with TSQLDBConnector(DBConnector).Query do
  992. begin
  993. Open;
  994. AssertEquals(s,fields[0].AsString);
  995. close;
  996. end;
  997. end;
  998. procedure TTestFieldTypes.TestTableNames;
  999. var TableList : TStringList;
  1000. i : integer;
  1001. begin
  1002. TableList := TStringList.Create;
  1003. try
  1004. TSQLDBConnector(DBConnector).Connection.GetTableNames(TableList);
  1005. AssertTrue(TableList.Find('fpdev',i));
  1006. finally
  1007. TableList.Free;
  1008. end;
  1009. end;
  1010. procedure TTestFieldTypes.TestFieldNames;
  1011. var FieldList : TStringList;
  1012. i : integer;
  1013. begin
  1014. FieldList := TStringList.Create;
  1015. try
  1016. TSQLDBConnector(DBConnector).Connection.GetFieldNames('fpdev',FieldList);
  1017. AssertTrue(FieldList.Find('id',i));
  1018. finally
  1019. FieldList.Free;
  1020. end;
  1021. end;
  1022. procedure TTestFieldTypes.TestInsertReturningQuery;
  1023. begin
  1024. if not(SQLDbType in [postgresql,interbase,oracle]) then Ignore(STestNotApplicable);
  1025. with TSQLDBConnector(DBConnector) do
  1026. begin
  1027. // This only works with databases that supports 'insert into .. returning'
  1028. // for example: PostgreSQL, Oracle, Firebird version 2.0 and up
  1029. CreateTableWithFieldType(ftInteger,'int');
  1030. Query.SQL.Text:='insert into FPDEV2 values(154) returning FT';
  1031. Query.Open;
  1032. AssertTrue(CompareText('FT',Query.Fields[0].FieldName)=0);
  1033. AssertEquals(154,Query.fields[0].AsInteger);
  1034. Query.Close;
  1035. end;
  1036. end;
  1037. procedure TTestFieldTypes.TestOpenStoredProc;
  1038. begin
  1039. with TSQLDBConnector(DBConnector) do
  1040. begin
  1041. if SQLDbType in MySQLdbTypes then
  1042. begin
  1043. Connection.ExecuteDirect('create procedure FPDEV_PROC() select 1 union select 2;');
  1044. Query.SQL.Text:='call FPDEV_PROC';
  1045. end
  1046. else if SQLDbType = interbase then
  1047. begin
  1048. Connection.ExecuteDirect('create procedure FPDEV_PROC returns (r integer) as begin r=1; end');
  1049. Query.SQL.Text:='execute procedure FPDEV_PROC';
  1050. end
  1051. else if SQLDbType = mssql then
  1052. begin
  1053. Connection.ExecuteDirect('create procedure FPDEV_PROC as select 1 union select 2;');
  1054. Query.SQL.Text:='execute FPDEV_PROC';
  1055. end
  1056. else
  1057. begin
  1058. Ignore('This test does not apply to this sqldb-connection type, since it does not support selectable stored procedures.');
  1059. Exit;
  1060. end;
  1061. Transaction.CommitRetaining;
  1062. try
  1063. Query.Open;
  1064. AssertEquals(1, Query.Fields[0].AsInteger);
  1065. Query.Next;
  1066. if not(SQLDbType in [interbase]) then
  1067. begin
  1068. AssertFalse('Eof after 1st row', Query.Eof);
  1069. AssertEquals(2, Query.Fields[0].AsInteger);
  1070. Query.Next;
  1071. end;
  1072. AssertTrue('No Eof after last row', Query.Eof);
  1073. Query.Close;
  1074. finally
  1075. Connection.ExecuteDirect('drop procedure FPDEV_PROC');
  1076. Transaction.CommitRetaining;
  1077. end;
  1078. end;
  1079. end;
  1080. procedure TTestFieldTypes.TestClearUpdateableStatus;
  1081. // Test if CanModify is correctly disabled in case of a select query without
  1082. // a from-statement.
  1083. begin
  1084. if not (SQLDbType in MySQLdbTypes) then Ignore('This test does only apply to MySQL because the used SQL-statement is MySQL only.');
  1085. with TSQLDBConnector(DBConnector) do
  1086. begin
  1087. with (GetNDataset(false,5) as TSQLQuery) do
  1088. begin
  1089. Open;
  1090. AssertEquals(True,CanModify);
  1091. Close;
  1092. SQL.Text:='select last_insert_id();';
  1093. Open;
  1094. AssertEquals(False,CanModify);
  1095. close;
  1096. end;
  1097. end;
  1098. end;
  1099. procedure TTestFieldTypes.TestReadOnlyParseSQL;
  1100. begin
  1101. with TSQLDBConnector(DBConnector) do
  1102. begin
  1103. GetFieldDataset(True);
  1104. with query do
  1105. begin
  1106. AssertFalse(ReadOnly);
  1107. AssertTrue(ParseSQL);
  1108. // If ParseSQL is false, and no update-queries are given, the query
  1109. // shouldn't be updateable after open.
  1110. ParseSQL := False;
  1111. AssertFalse(ParseSQL);
  1112. AssertFalse(ReadOnly);
  1113. SQL.Text := 'select * from FPDEV;';
  1114. open;
  1115. AssertFalse(ParseSQL);
  1116. AssertFalse(ReadOnly);
  1117. AssertFalse(CanModify);
  1118. close;
  1119. // If ParseSQL is true, the query should be updateable after open.
  1120. ReadOnly := False;
  1121. ParseSQL := True;
  1122. AssertTrue(ParseSQL);
  1123. AssertFalse(ReadOnly);
  1124. SQL.Text := 'select * from FPDEV';
  1125. open;
  1126. AssertTrue(ParseSQL);
  1127. AssertFalse(ReadOnly);
  1128. AssertTrue(CanModify);
  1129. edit;
  1130. FieldByName('ID').AsInteger:=321;
  1131. post;
  1132. Applyupdates;
  1133. close;
  1134. // If ParseSQL is true, but the supplied query isn't updateable, then
  1135. // the query shouldn't be updateable after open.
  1136. ReadOnly := False;
  1137. SQL.Text:='select ID,NAME from FPDEV where ID<5';
  1138. sql.Add('union');
  1139. sql.Add('select ID,NAME from FPDEV where ID>5');
  1140. AssertTrue(ParseSQL);
  1141. AssertFalse(ReadOnly);
  1142. open;
  1143. AssertTrue(ParseSQL);
  1144. AssertFalse(ReadOnly);
  1145. AssertFalse(CanModify);
  1146. close;
  1147. // As above, but now with an update-query, so that the query should
  1148. // be updateable again.
  1149. ReadOnly := False;
  1150. AssertTrue(ParseSQL);
  1151. AssertFalse(ReadOnly);
  1152. UpdateSQL.Text:='update FPDEV set ID=:ID where ID=:OLD_ID';
  1153. open;
  1154. AssertTrue(ParseSQL);
  1155. AssertFalse(ReadOnly);
  1156. AssertTrue(CanModify);
  1157. edit;
  1158. post;
  1159. Applyupdates;
  1160. close;
  1161. // Also if ParseSQL is False, the query should be updateable if a update-
  1162. // query is given.
  1163. ReadOnly := False;
  1164. ParseSQL := False;
  1165. AssertFalse(ParseSQL);
  1166. AssertFalse(ReadOnly);
  1167. open;
  1168. AssertFalse(ParseSQL);
  1169. AssertFalse(ReadOnly);
  1170. AssertTrue(CanModify);
  1171. edit;
  1172. FieldByName('ID').AsInteger:=1;
  1173. post;
  1174. Applyupdates;
  1175. close;
  1176. // But if ReadOnly is true, then CanModify should always be false
  1177. ReadOnly := True;
  1178. ParseSQL := False;
  1179. AssertFalse(ParseSQL);
  1180. AssertTrue(ReadOnly);
  1181. open;
  1182. AssertFalse(ParseSQL);
  1183. AssertTrue(ReadOnly);
  1184. AssertFalse(CanModify);
  1185. close;
  1186. end;
  1187. end;
  1188. end;
  1189. procedure TTestFieldTypes.TestParseJoins;
  1190. begin
  1191. with TSQLDBConnector(DBConnector) do
  1192. begin
  1193. with query do
  1194. begin
  1195. SQL.Text:='select TT.NAME from FPDEV left join FPDEV TT on TT.ID=FPDEV.ID';
  1196. Open;
  1197. close;
  1198. end;
  1199. end;
  1200. end;
  1201. procedure TTestFieldTypes.TestDoubleFieldNames;
  1202. begin
  1203. with TSQLDBConnector(DBConnector) do
  1204. begin
  1205. with query do
  1206. begin
  1207. SQL.Text:='select FPDEV.*,TT.* from FPDEV left join FPDEV TT on TT.ID=FPDEV.ID';
  1208. Open;
  1209. AssertTrue(assigned(FindField('ID')));
  1210. AssertTrue (assigned(FindField('ID_1')));
  1211. AssertTrue(assigned(FindField('NAME')));
  1212. AssertTrue(assigned(FindField('NAME_1')));
  1213. AssertEquals(1,fieldbyname('ID').AsInteger);
  1214. AssertEquals(1,fieldbyname('ID_1').AsInteger);
  1215. AssertEquals('TestName1',fieldbyname('NAME').AsString);
  1216. AssertEquals('TestName1',fieldbyname('NAME_1').AsString);
  1217. close;
  1218. end;
  1219. end;
  1220. end;
  1221. procedure TTestFieldTypes.TestParseUnion;
  1222. begin
  1223. with TSQLDBConnector(DBConnector) do
  1224. begin
  1225. with query do
  1226. begin
  1227. SQL.Text:='select NAME from FPDEV where ID<5';
  1228. sql.Add('union');
  1229. sql.Add('select NAME from FPDEV where ID>5');
  1230. Open;
  1231. close;
  1232. end;
  1233. end;
  1234. end;
  1235. procedure TTestFieldTypes.TestInsertLargeStrFields;
  1236. begin
  1237. with TSQLDBConnector(DBConnector) do
  1238. begin
  1239. Connection.ExecuteDirect('create table FPDEV2 ( ' +
  1240. ' ID INT NOT NULL , ' +
  1241. ' NAME VARCHAR(16000), ' +
  1242. ' PRIMARY KEY (ID) ' +
  1243. ') ');
  1244. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1245. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1246. query.sql.Text:='select * from FPDEV2';
  1247. Query.Open;
  1248. Query.InsertRecord([1,'test1']);
  1249. Query.ApplyUpdates;
  1250. Query.Close;
  1251. Query.Open;
  1252. AssertEquals(query.FieldByName('NAME').AsString,'test1');
  1253. query.Close;
  1254. end;
  1255. end;
  1256. procedure TTestFieldTypes.TestNumericNames;
  1257. begin
  1258. with TSQLDBConnector(DBConnector) do
  1259. begin
  1260. Connection.ExecuteDirect('create table FPDEV2 ( ' +
  1261. ' '+connection.FieldNameQuoteChars[0]+'2ID'+connection.FieldNameQuoteChars[1]+' INT NOT NULL, ' +
  1262. ' '+connection.FieldNameQuoteChars[0]+'3TEST'+connection.FieldNameQuoteChars[1]+' VARCHAR(10), ' +
  1263. ' PRIMARY KEY ('+connection.FieldNameQuoteChars[0]+'2ID'+connection.FieldNameQuoteChars[0]+') ' +
  1264. ') ');
  1265. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1266. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1267. with query do
  1268. begin
  1269. SQL.Text:='select * from FPDEV2';
  1270. Open;
  1271. Edit;
  1272. fieldbyname('2ID').AsInteger:=1;
  1273. fieldbyname('3TEST').AsString:='3test';
  1274. Post;
  1275. ApplyUpdates(0);
  1276. close;
  1277. open;
  1278. AssertEquals('3test',FieldByName('3TEST').AsString);
  1279. Edit;
  1280. fieldbyname('3TEST').AsString:='test3';
  1281. Post;
  1282. ApplyUpdates(0);
  1283. open;
  1284. AssertEquals('test3',FieldByName('3TEST').AsString);
  1285. close;
  1286. end;
  1287. end;
  1288. end;
  1289. procedure TTestFieldTypes.TestApplyUpdFieldnames;
  1290. begin
  1291. with TSQLDBConnector(DBConnector) do
  1292. begin
  1293. AssertEquals(-1,query.RowsAffected);
  1294. Connection.ExecuteDirect('create table FPDEV2 ( ' +
  1295. ' ID INT NOT NULL , ' +
  1296. ' '+Connection.FieldNameQuoteChars[0]+'NAME-TEST'+Connection.FieldNameQuoteChars[1]+' VARCHAR(250), ' +
  1297. ' PRIMARY KEY (ID) ' +
  1298. ') ');
  1299. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1300. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1301. Connection.ExecuteDirect('insert into FPDEV2(ID,'+Connection.FieldNameQuoteChars[0]+'NAME-TEST'+Connection.FieldNameQuoteChars[1]+') values (1,''test1'')');
  1302. Query.SQL.Text := 'select * from FPDEV2';
  1303. Query.Open;
  1304. AssertEquals(1,Query.FieldByName('ID').AsInteger);
  1305. AssertEquals('test1',Query.FieldByName('NAME-TEST').AsString);
  1306. Query.Edit;
  1307. Query.FieldByName('NAME-TEST').AsString:='Edited';
  1308. Query.Post;
  1309. Query.ApplyUpdates;
  1310. Query.Close;
  1311. Query.Open;
  1312. AssertEquals(1,Query.FieldByName('ID').AsInteger);
  1313. AssertEquals('Edited',Query.FieldByName('NAME-TEST').AsString);
  1314. Query.Close;
  1315. end;
  1316. end;
  1317. procedure TTestFieldTypes.TestLimitQuery;
  1318. begin
  1319. with TSQLDBConnector(DBConnector) do
  1320. begin
  1321. with query do
  1322. begin
  1323. case sqlDBtype of
  1324. interbase : SQL.Text:='select first 1 NAME from FPDEV where NAME=''TestName21''';
  1325. mssql : SQL.Text:='select top 1 NAME from FPDEV where NAME=''TestName21''';
  1326. else SQL.Text:='select NAME from FPDEV where NAME=''TestName21'' limit 1';
  1327. end;
  1328. Open;
  1329. close;
  1330. ServerFilter:='ID=21';
  1331. ServerFiltered:=true;
  1332. open;
  1333. close;
  1334. end;
  1335. end;
  1336. end;
  1337. procedure TTestFieldTypes.TestRowsAffected;
  1338. begin
  1339. with TSQLDBConnector(DBConnector) do
  1340. begin
  1341. AssertEquals(-1,query.RowsAffected);
  1342. Connection.ExecuteDirect('create table FPDEV2 ( ' +
  1343. ' ID INT NOT NULL , ' +
  1344. ' NAME VARCHAR(250), ' +
  1345. ' PRIMARY KEY (ID) ' +
  1346. ') ');
  1347. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1348. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1349. Query.SQL.Text := 'insert into FPDEV2(ID,NAME) values (1,''test1'')';
  1350. Query.ExecSQL;
  1351. AssertEquals(1,query.RowsAffected);
  1352. Query.SQL.Text := 'insert into FPDEV2(ID,NAME) values (2,''test2'')';
  1353. Query.ExecSQL;
  1354. AssertEquals(1,query.RowsAffected);
  1355. Query.SQL.Text := 'update FPDEV2 set NAME=''NewTest''';
  1356. Query.ExecSQL;
  1357. AssertEquals(2,query.RowsAffected);
  1358. Query.SQL.Text := 'select * from FPDEV2';
  1359. Query.Open;
  1360. AssertTrue(query.RowsAffected<>0); // It should return -1 or the number of selected rows.
  1361. query.Close;
  1362. AssertTrue(query.RowsAffected<>0); // It should return -1 or the same as the last time it was called.
  1363. if (SQLDbType = sqlite3) then // sqlite doesn't count the rowsaffected if there is no where-clause
  1364. Query.SQL.Text := 'delete from FPDEV2 where 1'
  1365. else
  1366. Query.SQL.Text := 'delete from FPDEV2';
  1367. Query.ExecSQL;
  1368. AssertEquals(2,query.RowsAffected);
  1369. Query.SQL.Text := 'delete from FPDEV2';
  1370. Query.ExecSQL;
  1371. AssertEquals(0,query.RowsAffected);
  1372. end;
  1373. end;
  1374. procedure TTestFieldTypes.TestStringsReplace;
  1375. begin
  1376. AssertEquals('dit is een string',StringsReplace('dit was een string',['was'],['is'],[]));
  1377. AssertEquals('dit is een string was een string',StringsReplace('dit was een string was een string',['was'],['is'],[]));
  1378. AssertEquals('dit is een string is een string',StringsReplace('dit was een string was een string',['was'],['is'],[rfReplaceAll]));
  1379. AssertEquals('dit is een char is een char',StringsReplace('dit was een string was een string',['was','string'],['is','char'],[rfReplaceAll]));
  1380. AssertEquals('dit is een string was een string',StringsReplace('dit was een string was een string',['string','was'],['char','is'],[]));
  1381. AssertEquals('dit is een char is een strin',StringsReplace('dit was een string was een strin',['string','was'],['char','is'],[rfReplaceAll]));
  1382. AssertEquals('dit Was een char is een char',StringsReplace('dit Was een string was een string',['was','string'],['is','char'],[rfReplaceAll]));
  1383. AssertEquals('dit wAs een char is een char',StringsReplace('dit wAs een string was een string',['was','string'],['is','char'],[rfReplaceAll]));
  1384. AssertEquals('dit is een char is een char',StringsReplace('dit Was een sTring was een string',['was','string'],['is','char'],[rfReplaceAll,rfIgnoreCase]));
  1385. AssertEquals('dit is een char is een char',StringsReplace('dit wAs een STRING was een string',['was','string'],['is','char'],[rfReplaceAll,rfIgnoreCase]));
  1386. AssertEquals('dit was een si was een sa',StringsReplace('dit was een string was een straat',['straat','string'],['sa','si'],[rfReplaceAll]));
  1387. AssertEquals('dit was een si was een sa',StringsReplace('dit was een string was een straat',['string','straat'],['si','sa'],[rfReplaceAll]));
  1388. AssertEquals('dit was een sing was een saat',StringsReplace('dit was een string was een straat',['str','string'],['s','si'],[rfReplaceAll]));
  1389. AssertEquals('dit was een si was een saat',StringsReplace('dit was een string was een straat',['string','str'],['si','s'],[rfReplaceAll]));
  1390. AssertEquals('dit was een string was een string',StringsReplace('dit was een string was een string',[''],['is'],[rfReplaceAll]));
  1391. AssertEquals('dit een string een string',StringsReplace('dit was een string was een string',['was'],[''],[rfReplaceAll]));
  1392. end;
  1393. procedure TTestFieldTypes.TestCircularParams;
  1394. begin
  1395. with TSQLDBConnector(dbconnector) do
  1396. begin
  1397. Connection.ExecuteDirect('create table FPDEV2 (id1 int, id2 int,vchar varchar(10))');
  1398. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1399. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1400. Query.sql.Text := 'insert into FPDEV2 values(:id1,:id2,:vchar)';
  1401. query.params[0].asinteger := 1;
  1402. query.params[1].asinteger := 1;
  1403. query.params[2].asstring := '$1 :id2 $';
  1404. query.ExecSQL;
  1405. query.sql.text := 'select * from FPDEV2';
  1406. query.open;
  1407. AssertEquals(1,query.fields[0].asinteger);
  1408. AssertEquals(1,query.fields[1].asinteger);
  1409. AssertEquals('$1 :id2 $',query.fields[2].AsString);
  1410. query.close;
  1411. end;
  1412. end;
  1413. procedure TTestFieldTypes.Test11Params;
  1414. var i : integer;
  1415. begin
  1416. with TSQLDBConnector(dbconnector) do
  1417. begin
  1418. Connection.ExecuteDirect('create table FPDEV2 (id1 int, id2 int, id3 int, id4 int,id5 int,id6 int,id7 int,id8 int, id9 int, id10 int, id11 int)');
  1419. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1420. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1421. Query.sql.Text := 'insert into FPDEV2 values(:id1,:id2,:id3,:id4,:id5,:id6,:id7,:id8,:id9,:id10,:id11)';
  1422. for i := 0 to 10 do
  1423. query.params[i].asinteger := 1;
  1424. query.ExecSQL;
  1425. query.sql.text := 'select * from FPDEV2';
  1426. query.open;
  1427. for i := 0 to 10 do
  1428. AssertEquals(1,query.fields[i].asinteger);
  1429. query.close;
  1430. end;
  1431. end;
  1432. procedure TTestFieldTypes.TestBug9744;
  1433. var i : integer;
  1434. begin
  1435. if SQLDbType in [interbase,postgresql,mssql] then Ignore('This test does not apply to this db-engine, since it has no double field-type');
  1436. with TSQLDBConnector(DBConnector) do
  1437. begin
  1438. try
  1439. Connection.ExecuteDirect('create table TTTOBJ ( ' +
  1440. ' ID INT NOT NULL, ' +
  1441. ' NAME VARCHAR(250), ' +
  1442. ' PRIMARY KEY (ID) ' +
  1443. ') ');
  1444. Connection.ExecuteDirect('create table TTTXY ( ' +
  1445. ' ID INT NOT NULL, ' +
  1446. ' NP INT NOT NULL, ' +
  1447. ' X DOUBLE, ' +
  1448. ' Y DOUBLE, ' +
  1449. ' PRIMARY KEY (ID,NP) ' +
  1450. ') ');
  1451. for i := 0 to 7 do
  1452. begin
  1453. connection.ExecuteDirect('insert into TTTOBJ(ID,NAME) values ('+inttostr(i)+',''A'+inttostr(i)+''')');
  1454. connection.ExecuteDirect('insert into TTTXY(ID,NP,X,Y) values ('+inttostr(i)+',1,1,1)');
  1455. connection.ExecuteDirect('insert into TTTXY(ID,NP,X,Y) values ('+inttostr(i)+',2,2,2)');
  1456. end;
  1457. Query.SQL.Text := 'select OBJ.ID, OBJ.NAME, count(XY.NP) as NPF from TTTOBJ as OBJ, TTTXY as XY where (OBJ.ID=XY.ID) group by OBJ.ID';
  1458. query.Prepare;
  1459. query.open;
  1460. query.close;
  1461. finally
  1462. Connection.ExecuteDirect('drop table TTTXY');
  1463. Connection.ExecuteDirect('drop table TTTOBJ');
  1464. end
  1465. end;
  1466. end;
  1467. procedure TTestFieldTypes.TestCrossStringDateParam;
  1468. begin
  1469. TestXXParamQuery(ftDate,'DATE',testDateValuesCount,True);
  1470. end;
  1471. procedure TTestFieldTypes.TestGetFieldNames;
  1472. var FieldNames : TStringList;
  1473. begin
  1474. with TSQLDBConnector(DBConnector) do
  1475. begin
  1476. FieldNames := TStringList.Create;
  1477. try
  1478. if SQLDbType in MySQLdbTypes then
  1479. Connection.GetFieldNames('FPDEV',FieldNames)
  1480. else
  1481. Connection.GetFieldNames('fpDEv',FieldNames);
  1482. AssertEquals(2,FieldNames.Count);
  1483. AssertEquals('ID',UpperCase(FieldNames[0]));
  1484. AssertEquals('NAME',UpperCase(FieldNames[1]));
  1485. finally
  1486. FieldNames.Free;
  1487. end;
  1488. end;
  1489. end;
  1490. procedure TTestFieldTypes.TestGetTables;
  1491. var TableNames : TStringList;
  1492. begin
  1493. with TSQLDBConnector(DBConnector) do
  1494. begin
  1495. TableNames := TStringList.Create;
  1496. try
  1497. Connection.GetTableNames(TableNames);
  1498. AssertTrue(TableNames.Count>0);
  1499. AssertTrue(TableNames.IndexOf('FPDEV')>-1);
  1500. AssertTrue(TableNames.IndexOf('FPDEV_FIELD')>-1);
  1501. finally
  1502. TableNames.Free;
  1503. end;
  1504. end;
  1505. end;
  1506. procedure TTestFieldTypes.TestSQLFieldType(ADatatype : TFieldType; ASQLTypeDecl : string; ADataSize: integer; AGetSQLTextProc: TGetSQLTextProc; ACheckFieldValueProc: TCheckFieldValueProc);
  1507. var
  1508. i : byte;
  1509. s: string;
  1510. begin
  1511. CreateTableWithFieldType(ADatatype,ASQLTypeDecl);
  1512. TestFieldDeclaration(ADatatype,ADataSize);
  1513. for i := 0 to testValuesCount-1 do
  1514. begin
  1515. s := AGetSQLTextProc(i);
  1516. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + s + ')');
  1517. end;
  1518. with TSQLDBConnector(DBConnector).Query do
  1519. begin
  1520. Open;
  1521. for i := 0 to testValuesCount-1 do
  1522. begin
  1523. ACheckFieldValueProc(fields[0],i);
  1524. Next;
  1525. end;
  1526. close;
  1527. end;
  1528. end;
  1529. // Placed here, as long as bug 18702 is not solved
  1530. function TestSQLClob_GetSQLText(const a: integer) : string;
  1531. begin
  1532. result := QuotedStr(testStringValues[a]);
  1533. end;
  1534. procedure TTestFieldTypes.TestSQLClob;
  1535. procedure CheckFieldValue(AField:TField; a : integer);
  1536. begin
  1537. AssertEquals(testStringValues[a],AField.AsString);
  1538. end;
  1539. var datatype: string;
  1540. begin
  1541. if sqlDBType=sqlite3 then
  1542. datatype:='CLOB'
  1543. else
  1544. datatype:=FieldtypeDefinitions[ftMemo];
  1545. TestSQLFieldType(ftMemo, datatype, 0, @TestSQLClob_GetSQLText, @CheckFieldValue);
  1546. end;
  1547. // Placed here, as long as bug 18702 is not solved
  1548. function TestSQLLargeInt_GetSQLText(const a: integer) : string;
  1549. begin
  1550. result := IntToStr(testLargeIntValues[a]);
  1551. end;
  1552. procedure TTestFieldTypes.TestSQLLargeint;
  1553. procedure CheckFieldValue(AField:TField; a : integer);
  1554. begin
  1555. AssertEquals(testLargeIntValues[a],AField.AsLargeInt);
  1556. end;
  1557. var datatype: string;
  1558. begin
  1559. if sqlDBType=sqlite3 then
  1560. datatype:='LARGEINT'
  1561. else
  1562. datatype:='BIGINT';
  1563. TestSQLFieldType(ftLargeint, datatype, 8, @TestSQLLargeint_GetSQLText, @CheckFieldValue);
  1564. end;
  1565. var testIntervalValuesCount: integer;
  1566. const testIntervalValues: array[0..4] of shortstring = ('00:00:00.000','00:00:01.000','23:59:59.000','838:59:59.000','1000:00:00.000');
  1567. // Placed here, as long as bug 18702 is not solved
  1568. function TestSQLInterval_GetSQLText(const a: integer) : string;
  1569. begin
  1570. if a < testIntervalValuesCount then
  1571. Result := QuotedStr(testIntervalValues[a])
  1572. else
  1573. Result := 'NULL'
  1574. end;
  1575. procedure TTestFieldTypes.TestSQLInterval;
  1576. procedure CheckFieldValue(AField: TField; a: integer);
  1577. begin
  1578. if a < testIntervalValuesCount then
  1579. AssertEquals(testIntervalValues[a], DateTimeToTimeString(AField.AsDateTime))
  1580. else
  1581. AssertTrue(AField.IsNull);
  1582. end;
  1583. var datatype: string;
  1584. begin
  1585. if sqlDBType = postgresql then
  1586. begin
  1587. datatype:='INTERVAL';
  1588. testIntervalValuesCount := 5;
  1589. end
  1590. else
  1591. begin
  1592. datatype:=FieldtypeDefinitions[ftTime];
  1593. if datatype = '' then
  1594. Ignore(STestNotApplicable);
  1595. if sqlDBType = sqlite3 then
  1596. testIntervalValuesCount := 5
  1597. else if sqlDBType in MySQLdbTypes then
  1598. testIntervalValuesCount := 4
  1599. else
  1600. testIntervalValuesCount := 3;
  1601. end;
  1602. TestSQLFieldType(ftTime, datatype, sizeof(TDateTime), @TestSQLInterval_GetSQLText, @CheckFieldValue);
  1603. end;
  1604. procedure TTestFieldTypes.TestSQLIdentity;
  1605. var datatype, values: string;
  1606. fieldtype: TFieldType;
  1607. i: integer;
  1608. begin
  1609. if sqlDBType in MySQLdbTypes then
  1610. begin
  1611. datatype:='INT AUTO_INCREMENT PRIMARY KEY';
  1612. values:='VALUES(DEFAULT)';
  1613. fieldtype:=ftAutoInc;
  1614. end
  1615. else if sqlDBType = sqlite3 then
  1616. begin
  1617. datatype:='INTEGER PRIMARY KEY';
  1618. values:='DEFAULT VALUES';
  1619. fieldtype:=ftInteger;
  1620. end
  1621. else if sqlDBType = mssql then
  1622. begin
  1623. datatype:='INTEGER IDENTITY';
  1624. values:='DEFAULT VALUES';
  1625. fieldtype:=ftAutoInc;
  1626. end
  1627. else
  1628. Ignore(STestNotApplicable);
  1629. CreateTableWithFieldType(fieldtype, datatype);
  1630. TestFieldDeclaration(fieldtype, sizeof(longint));
  1631. for i := 1 to 3 do
  1632. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 '+values);
  1633. with TSQLDBConnector(DBConnector).Query do
  1634. begin
  1635. Open;
  1636. AssertTrue(Locate('FT',1,[])); // bug 17624
  1637. for i := 1 to 3 do
  1638. begin
  1639. AssertEquals(Fields[0].AsInteger, i);
  1640. Next;
  1641. end;
  1642. Close;
  1643. end;
  1644. end;
  1645. procedure TTestFieldTypes.TestUpdateIndexDefs;
  1646. var ds : TSQLQuery;
  1647. begin
  1648. ds := DBConnector.GetNDataset(1) as TSQLQuery;
  1649. ds.Prepare;
  1650. ds.ServerIndexDefs.Update;
  1651. AssertEquals(1,ds.ServerIndexDefs.count);
  1652. AssertTrue(CompareText('ID',ds.ServerIndexDefs[0].Fields)=0);
  1653. Asserttrue(ds.ServerIndexDefs[0].Options=[ixPrimary,ixUnique]);
  1654. ds.ServerIndexDefs.Update;
  1655. AssertEquals(1,ds.ServerIndexDefs.count);
  1656. AssertTrue(CompareText('ID',ds.ServerIndexDefs[0].Fields)=0);
  1657. Asserttrue(ds.ServerIndexDefs[0].Options=[ixPrimary,ixUnique]);
  1658. end;
  1659. procedure TTestFieldTypes.TestMultipleFieldPKIndexDefs;
  1660. var ds : TSQLQuery;
  1661. begin
  1662. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (' +
  1663. ' ID1 INT NOT NULL, ' +
  1664. ' ID2 INT NOT NULL, ' +
  1665. ' NAME VARCHAR(50), ' +
  1666. ' PRIMARY KEY (ID1, ID2) ' +
  1667. ') ');
  1668. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1669. if SQLDbType=interbase then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1670. ds := TSQLDBConnector(DBConnector).Query;
  1671. ds.sql.Text:='select * from FPDEV2';
  1672. ds.Prepare;
  1673. ds.ServerIndexDefs.Update;
  1674. AssertEquals(1,ds.ServerIndexDefs.count);
  1675. AssertTrue(SameText('ID1;ID2',ds.ServerIndexDefs[0].Fields));
  1676. Asserttrue(ds.ServerIndexDefs[0].Options=[ixPrimary,ixUnique]);
  1677. end;
  1678. procedure TTestFieldTypes.TestSetBlobAsMemoParam;
  1679. begin
  1680. TestSetBlobAsParam(0);
  1681. end;
  1682. procedure TTestFieldTypes.TestSetBlobAsBlobParam;
  1683. begin
  1684. TestSetBlobAsParam(2);
  1685. end;
  1686. procedure TTestFieldTypes.TestTemporaryTable;
  1687. begin
  1688. if SQLDbType in [interbase,mssql] then Ignore('This test does not apply to this sqldb-connection type, since it doesn''t support temporary tables');
  1689. with TSQLDBConnector(DBConnector).Query do
  1690. begin
  1691. SQL.Clear;
  1692. SQL.Add('CREATE TEMPORARY TABLE TEMP1 (id int)');
  1693. ExecSQL;
  1694. SQL.Text := 'INSERT INTO TEMP1(id) values (5)';
  1695. ExecSQL;
  1696. SQL.Text := 'SELECT * FROM TEMP1';
  1697. Open;
  1698. AssertEquals(5,fields[0].AsInteger);
  1699. Close;
  1700. end;
  1701. end;
  1702. procedure TTestFieldTypes.TestGetIndexDefs;
  1703. var ds : TSQLQuery;
  1704. inddefs : TIndexDefs;
  1705. begin
  1706. ds := DBConnector.GetNDataset(1) as TSQLQuery;
  1707. ds.Open;
  1708. AssertEquals(1,ds.ServerIndexDefs.count);
  1709. inddefs := HackedDataset(ds).GetIndexDefs(ds.ServerIndexDefs,[ixPrimary]);
  1710. AssertEquals(1,inddefs.count);
  1711. AssertTrue(CompareText('ID',inddefs[0].Fields)=0);
  1712. Asserttrue(inddefs[0].Options=[ixPrimary,ixUnique]);
  1713. inddefs.Free;
  1714. inddefs := HackedDataset(ds).GetIndexDefs(ds.ServerIndexDefs,[ixPrimary,ixUnique]);
  1715. AssertEquals(1,inddefs.count);
  1716. AssertTrue(CompareText('ID',inddefs[0].Fields)=0);
  1717. Asserttrue(inddefs[0].Options=[ixPrimary,ixUnique]);
  1718. inddefs.Free;
  1719. inddefs := HackedDataset(ds).GetIndexDefs(ds.ServerIndexDefs,[ixDescending]);
  1720. AssertEquals(0,inddefs.count);
  1721. inddefs.Free;
  1722. end;
  1723. procedure TTestFieldTypes.TestDblQuoteEscComments;
  1724. begin
  1725. with TSQLDBConnector(DBConnector).Query do
  1726. begin
  1727. SQL.Clear;
  1728. SQL.Add('select * from FPDEV where name=''test '''' and :ThisIsNotAParameter ''');
  1729. open;
  1730. close;
  1731. end;
  1732. end;
  1733. procedure TTestFieldTypes.TestParametersAndDates;
  1734. // See bug 7205
  1735. var ADateStr : String;
  1736. begin
  1737. if not(SQLDbType in [postgresql,odbc,oracle]) then
  1738. Ignore('This test does not apply to this sqldb-connection type, since it doesn''t use semicolons for casts');
  1739. with TSQLDBConnector(DBConnector).Query do
  1740. begin
  1741. SQL.Clear;
  1742. sql.add('select now()::date as current_date where 1=1');
  1743. open;
  1744. first;
  1745. ADateStr:=fields[0].asstring; // return the correct date
  1746. // writeln(fields[0].asstring);
  1747. close;
  1748. sql.clear;
  1749. sql.add('select now()::date as current_date where cast(1 as integer) = :PARAM1');
  1750. params.parambyname('PARAM1').asinteger:= 1;
  1751. open;
  1752. first;
  1753. AssertEquals(ADateStr,fields[0].asstring); // return invalid date
  1754. // writeln(fields[0].asstring);
  1755. close;
  1756. end
  1757. end;
  1758. procedure TTestFieldTypes.TestExceptOnsecClose;
  1759. var passed : boolean;
  1760. begin
  1761. with TSQLDBConnector(DBConnector).Query do
  1762. begin
  1763. SQL.Clear;
  1764. SQL.Add('select * from FPDEV');
  1765. Open;
  1766. close;
  1767. SQL.Clear;
  1768. SQL.Add('select blaise from FPDEV');
  1769. passed := false;
  1770. try
  1771. open;
  1772. except
  1773. on E: Exception do
  1774. passed := (E.ClassType.InheritsFrom(EDatabaseError))
  1775. end;
  1776. AssertTrue(passed);
  1777. Close;
  1778. end;
  1779. end;
  1780. procedure TTestFieldTypes.TestErrorOnEmptyStatement;
  1781. var PassException : boolean;
  1782. begin
  1783. PassException:=False;
  1784. with TSQLDBConnector(DBConnector).Query do
  1785. begin
  1786. sql.Text := '';
  1787. try
  1788. Open;
  1789. except
  1790. on E:EDatabaseError do
  1791. if Pos(SErrNoStatement,E.Message) > 0 then
  1792. PassException := True;
  1793. end;
  1794. AssertTrue(PassException);
  1795. end;
  1796. end;
  1797. initialization
  1798. if uppercase(dbconnectorname)='SQL' then RegisterTest(TTestFieldTypes);
  1799. end.