testfieldtypes.pas 67 KB

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