testfieldtypes.pas 66 KB

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