testfieldtypes.pas 62 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978
  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. end;
  100. implementation
  101. uses sqldbtoolsunit,toolsunit, variants, sqldb, bufdataset, strutils, dbconst, FmtBCD;
  102. Type HackedDataset = class(TDataset);
  103. const
  104. testFloatValuesCount = 21;
  105. 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);
  106. testBCDValuesCount = 10;
  107. testBCDValues : Array[0..testBCDValuesCount-1] of currency = (-100,54.53,1.2345,123.5345,0,1,-1,0,1.42,1324.4324);
  108. testIntValuesCount = 17;
  109. 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);
  110. testDateValuesCount = 18;
  111. testDateValues : Array[0..testDateValuesCount-1] of string = (
  112. '2000-01-01',
  113. '1999-12-31',
  114. '2004-02-29',
  115. '2004-03-01',
  116. '1991-02-28',
  117. '1991-03-01',
  118. '2040-10-16',
  119. '1977-09-29',
  120. '1800-03-30',
  121. '1650-05-10',
  122. '1754-06-04',
  123. '0904-04-12',
  124. '0199-07-09',
  125. '0001-01-01',
  126. '1899-12-29',
  127. '1899-12-30',
  128. '1899-12-31',
  129. '1900-01-01'
  130. );
  131. testBytesValuesCount = 5;
  132. testVarBytesValuesCount = 8;
  133. testBytesValues : Array[0..testVarBytesValuesCount-1] of shortstring = (
  134. #1#0#1#0#1, #0#0#1#0#1, #0''''#13#0#1, '\'#0'"\'#13, #13#13#0#10#10,
  135. '', #0, #0#1#2#3#4#5#6#7#8#9
  136. );
  137. procedure TTestFieldTypes.TestpfInUpdateFlag;
  138. var ds : TCustomBufDataset;
  139. AFld1, AFld2, AFld3 : Tfield;
  140. begin
  141. ds := (DBConnector.GetNDataset(True,5) as TCustomBufDataset);
  142. with ds do
  143. begin
  144. AFld1 := TIntegerField.Create(ds);
  145. AFld1.FieldName := 'ID';
  146. AFld1.DataSet := ds;
  147. AFld1.ProviderFlags := AFld1.ProviderFlags + [pfInKey];
  148. AFld2 := TStringField.Create(ds);
  149. AFld2.FieldName := 'NAME';
  150. AFld2.DataSet := ds;
  151. AFld3 := TIntegerField.Create(ds);
  152. AFld3.FieldName := 'CALCFLD';
  153. AFld3.DataSet := ds;
  154. Afld3.FieldKind := fkCalculated;
  155. AFld3.ProviderFlags := [];
  156. Open;
  157. Edit;
  158. FieldByName('ID').AsInteger := 254;
  159. Post;
  160. ApplyUpdates;
  161. Append;
  162. FieldByName('ID').AsInteger := 255;
  163. Post;
  164. ApplyUpdates;
  165. Close;
  166. AFld1.Free;
  167. AFld2.Free;
  168. AFld3.Free;
  169. end;
  170. end;
  171. procedure TTestFieldTypes.TestScript;
  172. var Ascript : TSQLScript;
  173. begin
  174. Ascript := tsqlscript.create(nil);
  175. try
  176. with Ascript do
  177. begin
  178. DataBase := TSQLDBConnector(DBConnector).Connection;
  179. transaction := TSQLDBConnector(DBConnector).Transaction;
  180. script.clear;
  181. script.append('create table a (id int);');
  182. script.append('create table b (id int);');
  183. ExecuteScript;
  184. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  185. if SQLDbType=interbase then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  186. end;
  187. finally
  188. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('drop table a');
  189. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('drop table b');
  190. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  191. if SQLDbType=interbase then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  192. end;
  193. end;
  194. procedure TTestFieldTypes.TestInt;
  195. var
  196. i : byte;
  197. begin
  198. CreateTableWithFieldType(ftInteger,'INT');
  199. TestFieldDeclaration(ftInteger,4);
  200. for i := 0 to testIntValuesCount-1 do
  201. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + inttostr(testIntValues[i]) + ')');
  202. with TSQLDBConnector(DBConnector).Query do
  203. begin
  204. Open;
  205. for i := 0 to testIntValuesCount-1 do
  206. begin
  207. AssertEquals(testIntValues[i],fields[0].AsInteger);
  208. Next;
  209. end;
  210. close;
  211. end;
  212. end;
  213. procedure TTestFieldTypes.TestLargeRecordSize;
  214. begin
  215. 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))');
  216. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  217. if UpperCase(dbconnectorparams)='INTERBASE' then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  218. with TSQLDBConnector(DBConnector).Query do
  219. begin
  220. sql.clear;
  221. 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..............'')');
  222. ExecSQL;
  223. sql.clear;
  224. sql.append('select * from FPDEV2');
  225. open;
  226. AssertEquals('ZUBNE PASTE',FieldByName('plant').AsString);
  227. AssertEquals(EncodeDate(2005,07,01),FieldByName('sampling_datetime').AsDateTime);
  228. close;
  229. end;
  230. end;
  231. procedure TTestFieldTypes.TestNumeric;
  232. const
  233. testValuesCount = 13;
  234. 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);
  235. 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);
  236. FieldTypes: array [0..7] of TFieldType = (ftBCD, ftBCD, ftBCD, ftFmtBCD, ftLargeInt, ftFmtBCD, ftFmtBCD, ftFmtBCD);
  237. FieldSizes: array [0..7] of integer = (4,2,3,5,0,3,5,0); //scale
  238. var
  239. i,d : integer;
  240. s,s4,s9 : string;
  241. t : TFieldType;
  242. begin
  243. with TSQLDBConnector(DBConnector) do begin
  244. if SQLDbType = INTERBASE then
  245. begin
  246. //Interbase internal storage of exact numeric data types based on precision:
  247. // 1-4 (smallint), 5-9 (integer), 10-18 (int64)
  248. s := ''; //Interbase supports precision up to 18 only
  249. FieldTypes[5] := ftBCD; //ATM TIBConnection incorrectly maps NUMERIC(18,3) to ftBCD
  250. end
  251. else
  252. s := ', N19_0 NUMERIC(19,0)';
  253. 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 + ')');
  254. Transaction.CommitRetaining;
  255. with Query do
  256. begin
  257. SQL.Text := 'select * from FPDEV2';
  258. Open;
  259. for i := 0 to FieldCount-1 do
  260. begin
  261. case Fields[i].DataType of
  262. ftBCD: d := sizeof(Currency);
  263. ftFmtBCD: d := sizeof(TBCD);
  264. ftLargeInt: d := sizeof(int64);
  265. else d := 0;
  266. end;
  267. t := FieldTypes[i];
  268. if t = ftLargeInt then t := ftFmtBCD; //acceptable alternative
  269. AssertEquals(Fields[i].DataSize, d);
  270. AssertTrue(Fields[i].DataType in [FieldTypes[i], t]);
  271. AssertEquals(Fields[i].Size, FieldSizes[i]);
  272. end;
  273. Close;
  274. end;
  275. for i := 0 to testValuesCount-1 do
  276. begin
  277. s4 := CurrToStrF(testValues4[i],ffFixed,2,DBConnector.FormatSettings);
  278. s9 := CurrToStrF(testValues9[i],ffFixed,3,DBConnector.FormatSettings);
  279. 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]));
  280. end;
  281. with Query do
  282. begin
  283. Open;
  284. for i := 0 to testValuesCount-1 do
  285. begin
  286. AssertEquals(testValues4[i], Fields[1].AsCurrency);
  287. AssertEquals(testValues4[i], Fields[3].AsCurrency);
  288. AssertEquals(testValues9[i], Fields[0].AsCurrency);
  289. AssertEquals(testValues9[i], Fields[2].AsCurrency);
  290. AssertEquals(testValues9[i], Fields[5].AsCurrency);
  291. AssertEquals(testValues9[i], Fields[6].AsCurrency);
  292. Next;
  293. end;
  294. Close;
  295. end;
  296. end;
  297. end;
  298. procedure TTestFieldTypes.TestString;
  299. const
  300. testValuesCount = 19;
  301. testValues : Array[0..testValuesCount-1] of string = (
  302. '',
  303. 'a',
  304. 'ab',
  305. 'abc',
  306. 'abcd',
  307. 'abcde',
  308. 'abcdef',
  309. 'abcdefg',
  310. 'abcdefgh',
  311. 'abcdefghi',
  312. 'abcdefghij',
  313. 'lMnOpQrStU',
  314. '1234567890',
  315. '_!@#$%^&*(',
  316. ')-;:/?.<>',
  317. '~`|{}- =', // note that there's no \ (backslash) since some db's uses that as escape-character
  318. ' WRaP ',
  319. 'wRaP ',
  320. ' wRAP'
  321. );
  322. var
  323. i : byte;
  324. begin
  325. CreateTableWithFieldType(ftString,'VARCHAR(10)');
  326. TestFieldDeclaration(ftString,11);
  327. for i := 0 to testValuesCount-1 do
  328. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testValues[i] + ''')');
  329. with TSQLDBConnector(DBConnector).Query do
  330. begin
  331. Open;
  332. for i := 0 to testValuesCount-1 do
  333. begin
  334. if (SQLDbType in [mysql40,mysql41]) then
  335. AssertEquals(TrimRight(testValues[i]),fields[0].AsString) // MySQL < 5.0.3 automatically trims strings
  336. else
  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. '2040-10-16', // MySQL 4.0 doesn't support datetimes before 1970 or after 2038
  509. '1400-02-03 12:21:53',
  510. '0354-11-20 21:25:15',
  511. '1333-02-03 21:44:21',
  512. '1800-03-30',
  513. '1650-05-10',
  514. '1754-06-04',
  515. '0904-04-12',
  516. '0199-07-09',
  517. '0001-01-01',
  518. '1899-12-29',
  519. '1899-12-30',
  520. '1899-12-31',
  521. '1900-01-01',
  522. '1899-12-30 18:00:51',
  523. '1899-12-30 04:00:51',
  524. '1899-12-29 04:00:51',
  525. '1899-12-29 18:00:51',
  526. '1903-04-02 01:04:02',
  527. '1815-09-24 03:47:22',
  528. '2100-01-01 01:01:01'
  529. );
  530. var
  531. i, corrTestValueCount : byte;
  532. begin
  533. CreateTableWithFieldType(ftDateTime,FieldtypeDefinitions[ftDateTime]);
  534. TestFieldDeclaration(ftDateTime,8);
  535. if SQLDbType=mysql40 then corrTestValueCount := testValuesCount-21
  536. else corrTestValueCount := testValuesCount;
  537. for i := 0 to corrTestValueCount-1 do
  538. if SQLDbType=oracle then
  539. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (to_date (''' + testValues[i] + ''',''YYYY-MM-DD HH24:MI:SS''))')
  540. else
  541. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testValues[i] + ''')');
  542. with TSQLDBConnector(DBConnector).Query do
  543. begin
  544. Open;
  545. for i := 0 to corrTestValueCount-1 do
  546. begin
  547. if length(testValues[i]) < 12 then
  548. AssertEquals(testValues[i],FormatDateTime('yyyy/mm/dd', fields[0].AsDateTime, DBConnector.FormatSettings))
  549. else
  550. AssertEquals(testValues[i],FormatDateTime('yyyy/mm/dd hh:mm:ss', fields[0].AsDateTime, DBConnector.FormatSettings));
  551. Next;
  552. end;
  553. close;
  554. end;
  555. end;
  556. procedure TTestFieldTypes.TestFloat;
  557. const
  558. testValuesCount = 21;
  559. 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);
  560. var
  561. i : byte;
  562. begin
  563. CreateTableWithFieldType(ftFloat,'FLOAT');
  564. TestFieldDeclaration(ftFloat,sizeof(double));
  565. for i := 0 to testValuesCount-1 do
  566. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + floattostr(testValues[i],DBConnector.FormatSettings) + ')');
  567. with TSQLDBConnector(DBConnector).Query do
  568. begin
  569. Open;
  570. for i := 0 to testValuesCount-1 do
  571. begin
  572. AssertEquals(testValues[i],fields[0].AsFloat);
  573. Next;
  574. end;
  575. close;
  576. end;
  577. end;
  578. procedure TTestFieldTypes.TestNullValues;
  579. begin
  580. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (FIELD1 INT, FIELD2 INT)');
  581. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  582. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  583. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FIELD1) values (1)');
  584. with TSQLDBConnector(DBConnector).Query do
  585. begin
  586. sql.clear;
  587. sql.append('select * from FPDEV2');
  588. open;
  589. AssertEquals(1,FieldByName('FIELD1').AsInteger);
  590. AssertTrue('Null-values test failed',FieldByName('FIELD2').IsNull);
  591. close;
  592. end;
  593. end;
  594. procedure TTestFieldTypes.TestParamQuery;
  595. begin
  596. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (FIELD1 INT, FIELD2 INT, FIELD3 INT, DECOY VARCHAR(30))');
  597. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  598. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  599. with TSQLDBConnector(DBConnector).Query do
  600. begin
  601. sql.clear;
  602. sql.append('insert into FPDEV2 (field1) values (:field1)');
  603. Params.ParamByName('field1').AsInteger := 1;
  604. ExecSQL;
  605. sql.clear;
  606. sql.append('insert into FPDEV2 (field1,field2,decoy) values (:field1,:field2,''decoytest'')');
  607. Params.ParamByName('field1').AsInteger := 2;
  608. Params.ParamByName('field2').DataType := ftInteger;
  609. Params.ParamByName('field2').Value := Null;
  610. ExecSQL;
  611. sql.clear;
  612. sql.append('insert into FPDEV2 (field1,field2,field3) values (:field1,:field2,:field3)');
  613. Params.ParamByName('field1').AsInteger := 3;
  614. Params.ParamByName('field2').AsInteger := 2;
  615. Params.ParamByName('field3').AsInteger := 3;
  616. ExecSQL;
  617. sql.clear;
  618. sql.append('insert into FPDEV2 (field1,field2,field3,decoy) values (:field1,:field2,:field3,'':decoy ::test $decoy2 $$2'')');
  619. Params.ParamByName('field1').AsInteger := 4;
  620. Params.ParamByName('field2').AsInteger := 2;
  621. Params.ParamByName('field3').AsInteger := 3;
  622. ExecSQL;
  623. sql.clear;
  624. sql.append('insert into FPDEV2 (field1,field2,field3) values (:field1,:field2,:field1)');
  625. Params.ParamByName('field1').AsInteger := 5;
  626. Params.ParamByName('field2').AsInteger := 2;
  627. ExecSQL;
  628. sql.clear;
  629. sql.append('select * from FPDEV2 order by FIELD1');
  630. open;
  631. AssertEquals(1,FieldByName('FIELD1').asinteger);
  632. AssertTrue(FieldByName('FIELD2').IsNull);
  633. AssertTrue(FieldByName('FIELD3').IsNull);
  634. AssertTrue(FieldByName('DECOY').IsNull);
  635. next;
  636. AssertEquals(2,FieldByName('FIELD1').asinteger);
  637. AssertTrue(FieldByName('FIELD2').IsNull);
  638. AssertTrue(FieldByName('FIELD3').IsNull);
  639. AssertEquals('decoytest',FieldByName('DECOY').AsString);
  640. next;
  641. AssertEquals(3,FieldByName('FIELD1').asinteger);
  642. AssertEquals(2,FieldByName('FIELD2').asinteger);
  643. AssertEquals(3,FieldByName('FIELD3').asinteger);
  644. AssertTrue(FieldByName('DECOY').IsNull);
  645. next;
  646. AssertEquals(4,FieldByName('FIELD1').asinteger);
  647. AssertEquals(2,FieldByName('FIELD2').asinteger);
  648. AssertEquals(3,FieldByName('FIELD3').asinteger);
  649. AssertEquals(':decoy ::test $decoy2 $$2',FieldByName('DECOY').AsString);
  650. next;
  651. AssertEquals(5,FieldByName('FIELD1').asinteger);
  652. AssertEquals(2,FieldByName('FIELD2').asinteger);
  653. AssertEquals(5,FieldByName('FIELD3').asinteger);
  654. AssertTrue(FieldByName('DECOY').IsNull);
  655. close;
  656. end;
  657. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  658. end;
  659. procedure TTestFieldTypes.TestIntParamQuery;
  660. begin
  661. TestXXParamQuery(ftInteger,'INT',testIntValuesCount);
  662. end;
  663. procedure TTestFieldTypes.TestFmtBCDParamQuery;
  664. begin
  665. TestXXParamQuery(ftFMTBcd,FieldtypeDefinitionsConst[ftFMTBcd],testValuesCount);
  666. end;
  667. procedure TTestFieldTypes.TestTimeParamQuery;
  668. begin
  669. TestXXParamQuery(ftTime,FieldtypeDefinitionsConst[ftTime],testValuesCount);
  670. end;
  671. procedure TTestFieldTypes.TestDateTimeParamQuery;
  672. begin
  673. TestXXParamQuery(ftDateTime,FieldtypeDefinitions[ftDateTime],testValuesCount);
  674. end;
  675. procedure TTestFieldTypes.TestFloatParamQuery;
  676. begin
  677. TestXXParamQuery(ftFloat,'FLOAT',testFloatValuesCount);
  678. end;
  679. procedure TTestFieldTypes.TestBCDParamQuery;
  680. begin
  681. TestXXParamQuery(ftBCD,'NUMERIC(10,4)',testBCDValuesCount);
  682. end;
  683. procedure TTestFieldTypes.TestBytesParamQuery;
  684. begin
  685. TestXXParamQuery(ftBytes, FieldtypeDefinitions[ftBytes], testBytesValuesCount, true);
  686. end;
  687. procedure TTestFieldTypes.TestVarBytesParamQuery;
  688. begin
  689. TestXXParamQuery(ftVarBytes, FieldtypeDefinitions[ftVarBytes], testVarBytesValuesCount);
  690. end;
  691. procedure TTestFieldTypes.TestStringParamQuery;
  692. begin
  693. TestXXParamQuery(ftString,'VARCHAR(10)',testValuesCount);
  694. end;
  695. procedure TTestFieldTypes.TestFixedStringParamQuery;
  696. begin
  697. TestXXParamQuery(ftFixedChar,'CHAR(10)',testValuesCount);
  698. end;
  699. procedure TTestFieldTypes.TestDateParamQuery;
  700. begin
  701. TestXXParamQuery(ftDate,'DATE',testDateValuesCount);
  702. end;
  703. procedure TTestFieldTypes.TestXXParamQuery(ADatatype : TFieldType; ASQLTypeDecl : string; testValuescount : integer; Cross : boolean = false);
  704. var i : integer;
  705. begin
  706. if ASQLTypeDecl = '' then
  707. Ignore('Fields of the type ' + FieldTypeNames[ADatatype] + ' are not supported by this sqldb-connection type');
  708. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (ID INT, FIELD1 '+ASQLTypeDecl+')');
  709. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  710. if SQLDbType=interbase then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  711. with TSQLDBConnector(DBConnector).Query do
  712. begin
  713. PacketRecords := -1;
  714. sql.clear;
  715. sql.append('insert into FPDEV2 (ID,FIELD1) values (:id,:field1)');
  716. // There is no Param.AsFixedChar, so the datatype has to be set manually
  717. if ADatatype=ftFixedChar then
  718. Params.ParamByName('field1').DataType := ftFixedChar;
  719. for i := 0 to testValuesCount -1 do
  720. begin
  721. Params.ParamByName('id').AsInteger := i;
  722. case ADataType of
  723. ftInteger: Params.ParamByName('field1').asinteger := testIntValues[i];
  724. ftFloat : Params.ParamByName('field1').AsFloat := testFloatValues[i];
  725. ftBCD : Params.ParamByName('field1').AsCurrency:= testBCDValues[i];
  726. ftFixedChar,
  727. ftString : Params.ParamByName('field1').AsString := testValues[ADataType,i];
  728. ftTime : Params.ParamByName('field1').AsTime := TimeStringToDateTime(testTimeValues[i]);
  729. ftDate : if cross then
  730. Params.ParamByName('field1').AsString:= testDateValues[i]
  731. else
  732. Params.ParamByName('field1').AsDate := StrToDate(testDateValues[i],'yyyy/mm/dd','-');
  733. ftDateTime:Params.ParamByName('field1').AsDateTime := StrToDateTime(testValues[ADataType,i], DBConnector.FormatSettings);
  734. ftFMTBcd : Params.ParamByName('field1').AsFMTBCD := StrToBCD(testFmtBCDValues[i],DBConnector.FormatSettings);
  735. ftBytes : if cross then
  736. Params.ParamByName('field1').Value := StringToByteArray(testBytesValues[i])
  737. else
  738. Params.ParamByName('field1').AsBlob := testBytesValues[i];
  739. ftVarBytes:Params.ParamByName('field1').AsString := 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('This test does not apply to this db-engine');
  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
  1052. begin
  1053. Ignore('This test does not apply to this sqldb-connection type, since it does not support selectable stored procedures.');
  1054. Exit;
  1055. end;
  1056. Transaction.CommitRetaining;
  1057. try
  1058. Query.Open;
  1059. AssertEquals(1, Query.Fields[0].AsInteger);
  1060. Query.Next;
  1061. if not(SQLDbType in [interbase]) then
  1062. begin
  1063. AssertFalse('Eof after 1st row', Query.Eof);
  1064. AssertEquals(2, Query.Fields[0].AsInteger);
  1065. Query.Next;
  1066. end;
  1067. AssertTrue('No Eof after last row', Query.Eof);
  1068. Query.Close;
  1069. finally
  1070. Connection.ExecuteDirect('drop procedure FPDEV_PROC');
  1071. Transaction.CommitRetaining;
  1072. end;
  1073. end;
  1074. end;
  1075. procedure TTestFieldTypes.TestClearUpdateableStatus;
  1076. // Test if CanModify is correctly disabled in case of a select query without
  1077. // a from-statement.
  1078. begin
  1079. if not (SQLDbType in MySQLdbTypes) then Ignore('This test does only apply to MySQL because the used SQL-statement is MySQL only.');
  1080. with TSQLDBConnector(DBConnector) do
  1081. begin
  1082. with (GetNDataset(false,5) as TSQLQuery) do
  1083. begin
  1084. Open;
  1085. AssertEquals(True,CanModify);
  1086. Close;
  1087. SQL.Text:='select last_insert_id();';
  1088. Open;
  1089. AssertEquals(False,CanModify);
  1090. close;
  1091. end;
  1092. end;
  1093. end;
  1094. procedure TTestFieldTypes.TestReadOnlyParseSQL;
  1095. begin
  1096. with TSQLDBConnector(DBConnector) do
  1097. begin
  1098. GetFieldDataset(True);
  1099. with query do
  1100. begin
  1101. AssertFalse(ReadOnly);
  1102. AssertTrue(ParseSQL);
  1103. // If ParseSQL is false, and no update-queries are given, the query
  1104. // shouldn't be updateable after open.
  1105. ParseSQL := False;
  1106. AssertFalse(ParseSQL);
  1107. AssertFalse(ReadOnly);
  1108. SQL.Text := 'select * from FPDEV;';
  1109. open;
  1110. AssertFalse(ParseSQL);
  1111. AssertFalse(ReadOnly);
  1112. AssertFalse(CanModify);
  1113. close;
  1114. // If ParseSQL is true, the query should be updateable after open.
  1115. ReadOnly := False;
  1116. ParseSQL := True;
  1117. AssertTrue(ParseSQL);
  1118. AssertFalse(ReadOnly);
  1119. SQL.Text := 'select * from FPDEV';
  1120. open;
  1121. AssertTrue(ParseSQL);
  1122. AssertFalse(ReadOnly);
  1123. AssertTrue(CanModify);
  1124. edit;
  1125. FieldByName('ID').AsInteger:=321;
  1126. post;
  1127. Applyupdates;
  1128. close;
  1129. // If ParseSQL is true, but the supplied query isn't updateable, then
  1130. // the query shouldn't be updateable after open.
  1131. ReadOnly := False;
  1132. SQL.Text:='select ID,NAME from FPDEV where ID<5';
  1133. sql.Add('union');
  1134. sql.Add('select ID,NAME from FPDEV where ID>5');
  1135. AssertTrue(ParseSQL);
  1136. AssertFalse(ReadOnly);
  1137. open;
  1138. AssertTrue(ParseSQL);
  1139. AssertFalse(ReadOnly);
  1140. AssertFalse(CanModify);
  1141. close;
  1142. // As above, but now with an update-query, so that the query should
  1143. // be updateable again.
  1144. ReadOnly := False;
  1145. AssertTrue(ParseSQL);
  1146. AssertFalse(ReadOnly);
  1147. UpdateSQL.Text:='update FPDEV set ID=:ID where ID=:OLD_ID';
  1148. open;
  1149. AssertTrue(ParseSQL);
  1150. AssertFalse(ReadOnly);
  1151. AssertTrue(CanModify);
  1152. edit;
  1153. post;
  1154. Applyupdates;
  1155. close;
  1156. // Also if ParseSQL is False, the query should be updateable if a update-
  1157. // query is given.
  1158. ReadOnly := False;
  1159. ParseSQL := False;
  1160. AssertFalse(ParseSQL);
  1161. AssertFalse(ReadOnly);
  1162. open;
  1163. AssertFalse(ParseSQL);
  1164. AssertFalse(ReadOnly);
  1165. AssertTrue(CanModify);
  1166. edit;
  1167. FieldByName('ID').AsInteger:=1;
  1168. post;
  1169. Applyupdates;
  1170. close;
  1171. // But if ReadOnly is true, then CanModify should always be false
  1172. ReadOnly := True;
  1173. ParseSQL := False;
  1174. AssertFalse(ParseSQL);
  1175. AssertTrue(ReadOnly);
  1176. open;
  1177. AssertFalse(ParseSQL);
  1178. AssertTrue(ReadOnly);
  1179. AssertFalse(CanModify);
  1180. close;
  1181. end;
  1182. end;
  1183. end;
  1184. procedure TTestFieldTypes.TestParseJoins;
  1185. begin
  1186. with TSQLDBConnector(DBConnector) do
  1187. begin
  1188. with query do
  1189. begin
  1190. SQL.Text:='select TT.NAME from FPDEV left join FPDEV TT on TT.ID=FPDEV.ID';
  1191. Open;
  1192. close;
  1193. end;
  1194. end;
  1195. end;
  1196. procedure TTestFieldTypes.TestDoubleFieldNames;
  1197. begin
  1198. with TSQLDBConnector(DBConnector) do
  1199. begin
  1200. with query do
  1201. begin
  1202. SQL.Text:='select FPDEV.*,TT.* from FPDEV left join FPDEV TT on TT.ID=FPDEV.ID';
  1203. Open;
  1204. AssertTrue(assigned(FindField('ID')));
  1205. AssertTrue (assigned(FindField('ID_1')));
  1206. AssertTrue(assigned(FindField('NAME')));
  1207. AssertTrue(assigned(FindField('NAME_1')));
  1208. AssertEquals(1,fieldbyname('ID').AsInteger);
  1209. AssertEquals(1,fieldbyname('ID_1').AsInteger);
  1210. AssertEquals('TestName1',fieldbyname('NAME').AsString);
  1211. AssertEquals('TestName1',fieldbyname('NAME_1').AsString);
  1212. close;
  1213. end;
  1214. end;
  1215. end;
  1216. procedure TTestFieldTypes.TestParseUnion;
  1217. begin
  1218. with TSQLDBConnector(DBConnector) do
  1219. begin
  1220. with query do
  1221. begin
  1222. SQL.Text:='select NAME from FPDEV where ID<5';
  1223. sql.Add('union');
  1224. sql.Add('select NAME from FPDEV where ID>5');
  1225. Open;
  1226. close;
  1227. end;
  1228. end;
  1229. end;
  1230. procedure TTestFieldTypes.TestInsertLargeStrFields;
  1231. begin
  1232. with TSQLDBConnector(DBConnector) do
  1233. begin
  1234. Connection.ExecuteDirect('create table FPDEV2 ( ' +
  1235. ' ID INT NOT NULL , ' +
  1236. ' NAME VARCHAR(16000), ' +
  1237. ' PRIMARY KEY (ID) ' +
  1238. ') ');
  1239. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1240. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1241. query.sql.Text:='select * from FPDEV2';
  1242. Query.Open;
  1243. Query.InsertRecord([1,'test1']);
  1244. Query.ApplyUpdates;
  1245. Query.Close;
  1246. Query.Open;
  1247. AssertEquals(query.FieldByName('NAME').AsString,'test1');
  1248. query.Close;
  1249. end;
  1250. end;
  1251. procedure TTestFieldTypes.TestNumericNames;
  1252. begin
  1253. with TSQLDBConnector(DBConnector) do
  1254. begin
  1255. Connection.ExecuteDirect('create table FPDEV2 ( ' +
  1256. ' '+connection.FieldNameQuoteChars[0]+'2ID'+connection.FieldNameQuoteChars[1]+' INT NOT NULL, ' +
  1257. ' '+connection.FieldNameQuoteChars[0]+'3TEST'+connection.FieldNameQuoteChars[1]+' VARCHAR(10), ' +
  1258. ' PRIMARY KEY ('+connection.FieldNameQuoteChars[0]+'2ID'+connection.FieldNameQuoteChars[0]+') ' +
  1259. ') ');
  1260. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1261. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1262. with query do
  1263. begin
  1264. SQL.Text:='select * from FPDEV2';
  1265. Open;
  1266. Edit;
  1267. fieldbyname('2ID').AsInteger:=1;
  1268. fieldbyname('3TEST').AsString:='3test';
  1269. Post;
  1270. ApplyUpdates(0);
  1271. close;
  1272. open;
  1273. AssertEquals('3test',FieldByName('3TEST').AsString);
  1274. Edit;
  1275. fieldbyname('3TEST').AsString:='test3';
  1276. Post;
  1277. ApplyUpdates(0);
  1278. open;
  1279. AssertEquals('test3',FieldByName('3TEST').AsString);
  1280. close;
  1281. end;
  1282. end;
  1283. end;
  1284. procedure TTestFieldTypes.TestApplyUpdFieldnames;
  1285. begin
  1286. with TSQLDBConnector(DBConnector) do
  1287. begin
  1288. AssertEquals(-1,query.RowsAffected);
  1289. Connection.ExecuteDirect('create table FPDEV2 ( ' +
  1290. ' ID INT NOT NULL , ' +
  1291. ' '+Connection.FieldNameQuoteChars[0]+'NAME-TEST'+Connection.FieldNameQuoteChars[1]+' VARCHAR(250), ' +
  1292. ' PRIMARY KEY (ID) ' +
  1293. ') ');
  1294. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1295. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1296. Connection.ExecuteDirect('insert into FPDEV2(ID,'+Connection.FieldNameQuoteChars[0]+'NAME-TEST'+Connection.FieldNameQuoteChars[1]+') values (1,''test1'')');
  1297. Query.SQL.Text := 'select * from FPDEV2';
  1298. Query.Open;
  1299. AssertEquals(1,Query.FieldByName('ID').AsInteger);
  1300. AssertEquals('test1',Query.FieldByName('NAME-TEST').AsString);
  1301. Query.Edit;
  1302. Query.FieldByName('NAME-TEST').AsString:='Edited';
  1303. Query.Post;
  1304. Query.ApplyUpdates;
  1305. Query.Close;
  1306. Query.Open;
  1307. AssertEquals(1,Query.FieldByName('ID').AsInteger);
  1308. AssertEquals('Edited',Query.FieldByName('NAME-TEST').AsString);
  1309. Query.Close;
  1310. end;
  1311. end;
  1312. procedure TTestFieldTypes.TestLimitQuery;
  1313. begin
  1314. with TSQLDBConnector(DBConnector) do
  1315. begin
  1316. with query do
  1317. begin
  1318. if (sqlDBtype=interbase) then
  1319. SQL.Text:='select first 1 NAME from FPDEV where NAME=''TestName21'''
  1320. else
  1321. SQL.Text:='select NAME from FPDEV where NAME=''TestName21'' limit 1';
  1322. Open;
  1323. close;
  1324. ServerFilter:='ID=21';
  1325. ServerFiltered:=true;
  1326. open;
  1327. close;
  1328. end;
  1329. end;
  1330. end;
  1331. procedure TTestFieldTypes.TestRowsAffected;
  1332. begin
  1333. with TSQLDBConnector(DBConnector) do
  1334. begin
  1335. AssertEquals(-1,query.RowsAffected);
  1336. Connection.ExecuteDirect('create table FPDEV2 ( ' +
  1337. ' ID INT NOT NULL , ' +
  1338. ' NAME VARCHAR(250), ' +
  1339. ' PRIMARY KEY (ID) ' +
  1340. ') ');
  1341. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1342. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1343. Query.SQL.Text := 'insert into FPDEV2(ID,NAME) values (1,''test1'')';
  1344. Query.ExecSQL;
  1345. AssertEquals(1,query.RowsAffected);
  1346. Query.SQL.Text := 'insert into FPDEV2(ID,NAME) values (2,''test2'')';
  1347. Query.ExecSQL;
  1348. AssertEquals(1,query.RowsAffected);
  1349. Query.SQL.Text := 'update FPDEV2 set NAME=''NewTest''';
  1350. Query.ExecSQL;
  1351. AssertEquals(2,query.RowsAffected);
  1352. Query.SQL.Text := 'select * from FPDEV2';
  1353. Query.Open;
  1354. AssertTrue(query.RowsAffected<>0); // It should return -1 or the number of selected rows.
  1355. query.Close;
  1356. AssertTrue(query.RowsAffected<>0); // It should return -1 or the same as the last time it was called.
  1357. if (SQLDbType = sqlite3) then // sqlite doesn't count the rowsaffected if there is no where-clause
  1358. Query.SQL.Text := 'delete from FPDEV2 where 1'
  1359. else
  1360. Query.SQL.Text := 'delete from FPDEV2';
  1361. Query.ExecSQL;
  1362. AssertEquals(2,query.RowsAffected);
  1363. Query.SQL.Text := 'delete from FPDEV2';
  1364. Query.ExecSQL;
  1365. AssertEquals(0,query.RowsAffected);
  1366. end;
  1367. end;
  1368. procedure TTestFieldTypes.TestStringsReplace;
  1369. begin
  1370. AssertEquals('dit is een string',StringsReplace('dit was een string',['was'],['is'],[]));
  1371. AssertEquals('dit is een string was een string',StringsReplace('dit was een string was een string',['was'],['is'],[]));
  1372. AssertEquals('dit is een string is een string',StringsReplace('dit was een string was een string',['was'],['is'],[rfReplaceAll]));
  1373. AssertEquals('dit is een char is een char',StringsReplace('dit was een string was een string',['was','string'],['is','char'],[rfReplaceAll]));
  1374. AssertEquals('dit is een string was een string',StringsReplace('dit was een string was een string',['string','was'],['char','is'],[]));
  1375. AssertEquals('dit is een char is een strin',StringsReplace('dit was een string was een strin',['string','was'],['char','is'],[rfReplaceAll]));
  1376. AssertEquals('dit Was een char is een char',StringsReplace('dit Was een string was een string',['was','string'],['is','char'],[rfReplaceAll]));
  1377. AssertEquals('dit wAs een char is een char',StringsReplace('dit wAs een string was een string',['was','string'],['is','char'],[rfReplaceAll]));
  1378. AssertEquals('dit is een char is een char',StringsReplace('dit Was een sTring was een string',['was','string'],['is','char'],[rfReplaceAll,rfIgnoreCase]));
  1379. AssertEquals('dit is een char is een char',StringsReplace('dit wAs een STRING was een string',['was','string'],['is','char'],[rfReplaceAll,rfIgnoreCase]));
  1380. AssertEquals('dit was een si was een sa',StringsReplace('dit was een string was een straat',['straat','string'],['sa','si'],[rfReplaceAll]));
  1381. AssertEquals('dit was een si was een sa',StringsReplace('dit was een string was een straat',['string','straat'],['si','sa'],[rfReplaceAll]));
  1382. AssertEquals('dit was een sing was een saat',StringsReplace('dit was een string was een straat',['str','string'],['s','si'],[rfReplaceAll]));
  1383. AssertEquals('dit was een si was een saat',StringsReplace('dit was een string was een straat',['string','str'],['si','s'],[rfReplaceAll]));
  1384. AssertEquals('dit was een string was een string',StringsReplace('dit was een string was een string',[''],['is'],[rfReplaceAll]));
  1385. AssertEquals('dit een string een string',StringsReplace('dit was een string was een string',['was'],[''],[rfReplaceAll]));
  1386. end;
  1387. procedure TTestFieldTypes.TestCircularParams;
  1388. begin
  1389. with TSQLDBConnector(dbconnector) do
  1390. begin
  1391. Connection.ExecuteDirect('create table FPDEV2 (id1 int, id2 int,vchar varchar(10))');
  1392. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1393. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1394. Query.sql.Text := 'insert into FPDEV2 values(:id1,:id2,:vchar)';
  1395. query.params[0].asinteger := 1;
  1396. query.params[1].asinteger := 1;
  1397. query.params[2].asstring := '$1 :id2 $';
  1398. query.ExecSQL;
  1399. query.sql.text := 'select * from FPDEV2';
  1400. query.open;
  1401. AssertEquals(1,query.fields[0].asinteger);
  1402. AssertEquals(1,query.fields[1].asinteger);
  1403. AssertEquals('$1 :id2 $',query.fields[2].AsString);
  1404. query.close;
  1405. end;
  1406. end;
  1407. procedure TTestFieldTypes.Test11Params;
  1408. var i : integer;
  1409. begin
  1410. with TSQLDBConnector(dbconnector) do
  1411. begin
  1412. 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)');
  1413. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1414. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1415. Query.sql.Text := 'insert into FPDEV2 values(:id1,:id2,:id3,:id4,:id5,:id6,:id7,:id8,:id9,:id10,:id11)';
  1416. for i := 0 to 10 do
  1417. query.params[i].asinteger := 1;
  1418. query.ExecSQL;
  1419. query.sql.text := 'select * from FPDEV2';
  1420. query.open;
  1421. for i := 0 to 10 do
  1422. AssertEquals(1,query.fields[i].asinteger);
  1423. query.close;
  1424. end;
  1425. end;
  1426. procedure TTestFieldTypes.TestBug9744;
  1427. var i : integer;
  1428. begin
  1429. if SQLDbType in [interbase,postgresql] then Ignore('This test does not apply to this db-engine, since it has no double field-type');
  1430. with TSQLDBConnector(DBConnector) do
  1431. begin
  1432. try
  1433. Connection.ExecuteDirect('create table TTTOBJ ( ' +
  1434. ' ID INT NOT NULL, ' +
  1435. ' NAME VARCHAR(250), ' +
  1436. ' PRIMARY KEY (ID) ' +
  1437. ') ');
  1438. Connection.ExecuteDirect('create table TTTXY ( ' +
  1439. ' ID INT NOT NULL, ' +
  1440. ' NP INT NOT NULL, ' +
  1441. ' X DOUBLE, ' +
  1442. ' Y DOUBLE, ' +
  1443. ' PRIMARY KEY (ID,NP) ' +
  1444. ') ');
  1445. for i := 0 to 7 do
  1446. begin
  1447. connection.ExecuteDirect('insert into TTTOBJ(ID,NAME) values ('+inttostr(i)+',''A'+inttostr(i)+''')');
  1448. connection.ExecuteDirect('insert into TTTXY(ID,NP,X,Y) values ('+inttostr(i)+',1,1,1)');
  1449. connection.ExecuteDirect('insert into TTTXY(ID,NP,X,Y) values ('+inttostr(i)+',2,2,2)');
  1450. end;
  1451. 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';
  1452. query.Prepare;
  1453. query.open;
  1454. query.close;
  1455. finally
  1456. Connection.ExecuteDirect('drop table TTTXY');
  1457. Connection.ExecuteDirect('drop table TTTOBJ');
  1458. end
  1459. end;
  1460. end;
  1461. procedure TTestFieldTypes.TestCrossStringDateParam;
  1462. begin
  1463. TestXXParamQuery(ftDate,'DATE',testDateValuesCount,True);
  1464. end;
  1465. procedure TTestFieldTypes.TestGetFieldNames;
  1466. var FieldNames : TStringList;
  1467. begin
  1468. with TSQLDBConnector(DBConnector) do
  1469. begin
  1470. FieldNames := TStringList.Create;
  1471. try
  1472. if SQLDbType in MySQLdbTypes then
  1473. Connection.GetFieldNames('FPDEV',FieldNames)
  1474. else
  1475. Connection.GetFieldNames('fpDEv',FieldNames);
  1476. AssertEquals(2,FieldNames.Count);
  1477. AssertEquals('ID',UpperCase(FieldNames[0]));
  1478. AssertEquals('NAME',UpperCase(FieldNames[1]));
  1479. finally
  1480. FieldNames.Free;
  1481. end;
  1482. end;
  1483. end;
  1484. procedure TTestFieldTypes.TestGetTables;
  1485. var TableNames : TStringList;
  1486. begin
  1487. with TSQLDBConnector(DBConnector) do
  1488. begin
  1489. TableNames := TStringList.Create;
  1490. try
  1491. Connection.GetTableNames(TableNames);
  1492. AssertTrue(TableNames.Count>0);
  1493. AssertTrue(TableNames.IndexOf('FPDEV')>-1);
  1494. AssertTrue(TableNames.IndexOf('FPDEV_FIELD')>-1);
  1495. finally
  1496. TableNames.Free;
  1497. end;
  1498. end;
  1499. end;
  1500. procedure TTestFieldTypes.TestSQLFieldType(ADatatype : TFieldType; ASQLTypeDecl : string; ADataSize: integer; AGetSQLTextProc: TGetSQLTextProc; ACheckFieldValueProc: TCheckFieldValueProc);
  1501. var
  1502. i : byte;
  1503. s: string;
  1504. begin
  1505. CreateTableWithFieldType(ADatatype,ASQLTypeDecl);
  1506. TestFieldDeclaration(ADatatype,ADataSize);
  1507. for i := 0 to testValuesCount-1 do
  1508. begin
  1509. s := AGetSQLTextProc(i);
  1510. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + s + ')');
  1511. end;
  1512. with TSQLDBConnector(DBConnector).Query do
  1513. begin
  1514. Open;
  1515. for i := 0 to testValuesCount-1 do
  1516. begin
  1517. ACheckFieldValueProc(fields[0],i);
  1518. Next;
  1519. end;
  1520. close;
  1521. end;
  1522. end;
  1523. // Placed here, as long as bug 18702 is not solved
  1524. function TestSQLClob_GetSQLText(const a: integer) : string;
  1525. begin
  1526. result := QuotedStr(testStringValues[a]);
  1527. end;
  1528. procedure TTestFieldTypes.TestSQLClob;
  1529. procedure CheckFieldValue(AField:TField; a : integer);
  1530. begin
  1531. AssertEquals(testStringValues[a],AField.AsString);
  1532. end;
  1533. var datatype: string;
  1534. begin
  1535. if sqlDBType=sqlite3 then
  1536. datatype:='CLOB'
  1537. else
  1538. datatype:=FieldtypeDefinitions[ftMemo];
  1539. TestSQLFieldType(ftMemo, datatype, 0, @TestSQLClob_GetSQLText, @CheckFieldValue);
  1540. end;
  1541. // Placed here, as long as bug 18702 is not solved
  1542. function TestSQLLargeInt_GetSQLText(const a: integer) : string;
  1543. begin
  1544. result := IntToStr(testLargeIntValues[a]);
  1545. end;
  1546. procedure TTestFieldTypes.TestSQLLargeint;
  1547. procedure CheckFieldValue(AField:TField; a : integer);
  1548. begin
  1549. AssertEquals(testLargeIntValues[a],AField.AsLargeInt);
  1550. end;
  1551. var datatype: string;
  1552. begin
  1553. if sqlDBType=sqlite3 then
  1554. datatype:='LARGEINT'
  1555. else
  1556. datatype:='BIGINT';
  1557. TestSQLFieldType(ftLargeint, datatype, 8, @TestSQLLargeint_GetSQLText, @CheckFieldValue);
  1558. end;
  1559. procedure TTestFieldTypes.TestUpdateIndexDefs;
  1560. var ds : TSQLQuery;
  1561. begin
  1562. ds := DBConnector.GetNDataset(1) as TSQLQuery;
  1563. ds.Prepare;
  1564. ds.ServerIndexDefs.Update;
  1565. AssertEquals(1,ds.ServerIndexDefs.count);
  1566. AssertTrue(CompareText('ID',ds.ServerIndexDefs[0].Fields)=0);
  1567. Asserttrue(ds.ServerIndexDefs[0].Options=[ixPrimary,ixUnique]);
  1568. ds.ServerIndexDefs.Update;
  1569. AssertEquals(1,ds.ServerIndexDefs.count);
  1570. AssertTrue(CompareText('ID',ds.ServerIndexDefs[0].Fields)=0);
  1571. Asserttrue(ds.ServerIndexDefs[0].Options=[ixPrimary,ixUnique]);
  1572. end;
  1573. procedure TTestFieldTypes.TestMultipleFieldPKIndexDefs;
  1574. var ds : TSQLQuery;
  1575. begin
  1576. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (' +
  1577. ' ID1 INT NOT NULL, ' +
  1578. ' ID2 INT NOT NULL, ' +
  1579. ' NAME VARCHAR(50), ' +
  1580. ' PRIMARY KEY (ID1, ID2) ' +
  1581. ') ');
  1582. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1583. if SQLDbType=interbase then TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1584. ds := TSQLDBConnector(DBConnector).Query;
  1585. ds.sql.Text:='select * from FPDEV2';
  1586. ds.Prepare;
  1587. ds.ServerIndexDefs.Update;
  1588. AssertEquals(1,ds.ServerIndexDefs.count);
  1589. AssertTrue(SameText('ID1;ID2',ds.ServerIndexDefs[0].Fields));
  1590. Asserttrue(ds.ServerIndexDefs[0].Options=[ixPrimary,ixUnique]);
  1591. end;
  1592. procedure TTestFieldTypes.TestSetBlobAsMemoParam;
  1593. begin
  1594. TestSetBlobAsParam(0);
  1595. end;
  1596. procedure TTestFieldTypes.TestSetBlobAsBlobParam;
  1597. begin
  1598. TestSetBlobAsParam(2);
  1599. end;
  1600. procedure TTestFieldTypes.TestTemporaryTable;
  1601. begin
  1602. if SQLDbType=interbase then Ignore('This test does not apply to Interbase/Firebird, since it doesn''t support temporary tables');
  1603. with TSQLDBConnector(DBConnector).Query do
  1604. begin
  1605. SQL.Clear;
  1606. SQL.Add('CREATE TEMPORARY TABLE TEMP1 (id int)');
  1607. ExecSQL;
  1608. SQL.Text := 'INSERT INTO TEMP1(id) values (5)';
  1609. ExecSQL;
  1610. SQL.Text := 'SELECT * FROM TEMP1';
  1611. Open;
  1612. AssertEquals(5,fields[0].AsInteger);
  1613. Close;
  1614. end;
  1615. end;
  1616. procedure TTestFieldTypes.TestGetIndexDefs;
  1617. var ds : TSQLQuery;
  1618. inddefs : TIndexDefs;
  1619. begin
  1620. ds := DBConnector.GetNDataset(1) as TSQLQuery;
  1621. ds.Open;
  1622. AssertEquals(1,ds.ServerIndexDefs.count);
  1623. inddefs := HackedDataset(ds).GetIndexDefs(ds.ServerIndexDefs,[ixPrimary]);
  1624. AssertEquals(1,inddefs.count);
  1625. AssertTrue(CompareText('ID',inddefs[0].Fields)=0);
  1626. Asserttrue(inddefs[0].Options=[ixPrimary,ixUnique]);
  1627. inddefs.Free;
  1628. inddefs := HackedDataset(ds).GetIndexDefs(ds.ServerIndexDefs,[ixPrimary,ixUnique]);
  1629. AssertEquals(1,inddefs.count);
  1630. AssertTrue(CompareText('ID',inddefs[0].Fields)=0);
  1631. Asserttrue(inddefs[0].Options=[ixPrimary,ixUnique]);
  1632. inddefs.Free;
  1633. inddefs := HackedDataset(ds).GetIndexDefs(ds.ServerIndexDefs,[ixDescending]);
  1634. AssertEquals(0,inddefs.count);
  1635. inddefs.Free;
  1636. end;
  1637. procedure TTestFieldTypes.TestDblQuoteEscComments;
  1638. begin
  1639. with TSQLDBConnector(DBConnector).Query do
  1640. begin
  1641. SQL.Clear;
  1642. SQL.Add('select * from FPDEV where name=''test '''' and :ThisIsNotAParameter ''');
  1643. open;
  1644. close;
  1645. end;
  1646. end;
  1647. procedure TTestFieldTypes.TestParametersAndDates;
  1648. // See bug 7205
  1649. var ADateStr : String;
  1650. begin
  1651. if not(SQLDbType in [postgresql,odbc,oracle]) then
  1652. Ignore('This test does not apply to this sqldb-connection type, since it doesn''t use semicolons for casts');
  1653. with TSQLDBConnector(DBConnector).Query do
  1654. begin
  1655. SQL.Clear;
  1656. sql.add('select now()::date as current_date where 1=1');
  1657. open;
  1658. first;
  1659. ADateStr:=fields[0].asstring; // return the correct date
  1660. // writeln(fields[0].asstring);
  1661. close;
  1662. sql.clear;
  1663. sql.add('select now()::date as current_date where cast(1 as integer) = :PARAM1');
  1664. params.parambyname('PARAM1').asinteger:= 1;
  1665. open;
  1666. first;
  1667. AssertEquals(ADateStr,fields[0].asstring); // return invalid date
  1668. // writeln(fields[0].asstring);
  1669. close;
  1670. end
  1671. end;
  1672. procedure TTestFieldTypes.TestExceptOnsecClose;
  1673. var passed : boolean;
  1674. begin
  1675. with TSQLDBConnector(DBConnector).Query do
  1676. begin
  1677. SQL.Clear;
  1678. SQL.Add('select * from FPDEV');
  1679. Open;
  1680. close;
  1681. SQL.Clear;
  1682. SQL.Add('select blaise from FPDEV');
  1683. passed := false;
  1684. try
  1685. open;
  1686. except
  1687. on E: Exception do
  1688. passed := (E.ClassType.InheritsFrom(EDatabaseError))
  1689. end;
  1690. AssertTrue(passed);
  1691. Close;
  1692. end;
  1693. end;
  1694. procedure TTestFieldTypes.TestErrorOnEmptyStatement;
  1695. var PassException : boolean;
  1696. begin
  1697. PassException:=False;
  1698. with TSQLDBConnector(DBConnector).Query do
  1699. begin
  1700. sql.Text := '';
  1701. try
  1702. Open;
  1703. except
  1704. on E:EDatabaseError do
  1705. if Pos(SErrNoStatement,E.Message) > 0 then
  1706. PassException := True;
  1707. end;
  1708. AssertTrue(PassException);
  1709. end;
  1710. end;
  1711. initialization
  1712. if uppercase(dbconnectorname)='SQL' then RegisterTest(TTestFieldTypes);
  1713. end.