testfieldtypes.pas 78 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498
  1. unit TestFieldTypes;
  2. {$mode objfpc}{$H+}
  3. {$modeswitch nestedprocvars}
  4. interface
  5. uses
  6. Classes, SysUtils, fpcunit, 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;
  22. ParamValuesCount : integer); overload;
  23. procedure TestXXParamQuery(ADataType : TFieldType; ASQLTypeDecl : string;
  24. ParamValuesCount : integer; const ParamValues: array of string; Cross : boolean = False); overload;
  25. procedure TestSetBlobAsParam(asWhat : integer);
  26. protected
  27. procedure SetUp; override;
  28. procedure TearDown; override;
  29. procedure RunTest; override;
  30. published
  31. // Fields (field recognition):
  32. procedure TestInt;
  33. procedure TestTinyint;
  34. procedure TestNumeric;
  35. procedure TestFloat;
  36. procedure TestDate;
  37. procedure TestDateTime; // bug 6925
  38. procedure TestString;
  39. procedure TestUnlVarChar;
  40. procedure TestBlob;
  41. procedure TestChangeBlob;
  42. procedure TestBlobGetText;
  43. procedure TestBlobSize;
  44. procedure TestSQLClob;
  45. procedure TestSQLLargeint;
  46. procedure TestSQLInterval;
  47. procedure TestSQLIdentity;
  48. procedure TestSQLReal;
  49. procedure TestSQLUUID;
  50. procedure TestStringLargerThen8192;
  51. procedure TestInsertLargeStrFields; // bug 9600
  52. procedure TestLargeRecordSize;
  53. procedure TestNullValues;
  54. procedure TestAggregates;
  55. procedure TestBug9744;
  56. // Field names:
  57. procedure TestDoubleFieldNames; // bug 8457
  58. procedure TestNumericFieldNames; // Bug9661
  59. procedure TestApplyUpdFieldNames; // Bug 12275
  60. // Parsing SQL:
  61. procedure TestParseJoins; // bug 10148
  62. procedure TestParseUnion; // bug 8442
  63. procedure TestClearUpdateableStatus;
  64. procedure TestReadOnlyParseSQL; // bug 9254
  65. procedure TestDblQuoteEscComments;
  66. // ApplyUpdates:
  67. procedure TestpfInUpdateFlag; // bug 7565
  68. // Parameters:
  69. procedure TestParamQuery;
  70. procedure TestStringParamQuery;
  71. procedure TestFixedStringParamQuery;
  72. procedure TestDateParamQuery;
  73. procedure TestCrossStringDateParam;
  74. procedure TestSmallIntParamQuery;
  75. procedure TestIntParamQuery;
  76. procedure TestLargeIntParamQuery;
  77. procedure TestTimeParamQuery;
  78. procedure TestDateTimeParamQuery;
  79. procedure TestFmtBCDParamQuery;
  80. Procedure TestFmtBCDParamQuery2; // Bug 27077
  81. procedure TestFloatParamQuery;
  82. procedure TestCurrencyParamQuery;
  83. procedure TestBCDParamQuery;
  84. procedure TestBytesParamQuery;
  85. procedure TestVarBytesParamQuery;
  86. procedure TestBooleanParamQuery;
  87. procedure TestBlobParamQuery;
  88. procedure TestLongWordParamQuery;
  89. procedure TestSetBlobAsMemoParam;
  90. procedure TestSetBlobAsBlobParam;
  91. procedure TestSetBlobAsStringParam;
  92. procedure Test11Params;
  93. procedure TestCircularParams;
  94. procedure TestNonNullableParams;
  95. procedure TestParametersAndDates;
  96. // Opening non-select statements, which returns result set:
  97. procedure TestInsertReturningQuery;
  98. procedure TestOpenStoredProc;
  99. procedure TestOpenSpecialStatements;
  100. procedure TestErrorOnEmptyStatement;
  101. procedure TestExceptOnsecClose;
  102. procedure TestServerFilter; // bug 15456, 35887
  103. procedure TestRowsAffected; // bug 9758
  104. procedure TestLocateNull;
  105. procedure TestLocateOnMoreRecords;
  106. procedure TestRefresh;
  107. // SchemaType tests:
  108. procedure TestTableNames;
  109. procedure TestGetTables;
  110. procedure TestFieldNames;
  111. procedure TestGetFieldNames;
  112. procedure TestUpdateIndexDefs;
  113. procedure TestMultipleFieldPKIndexDefs;
  114. procedure TestGetIndexDefs;
  115. // Connection:
  116. procedure TestEmptyUpdateQuery; // bug 13654
  117. procedure TestTemporaryTable;
  118. procedure TestQueryAfterReconnect; // bug 16438
  119. procedure TestStringsReplace;
  120. // Test SQLite3 AlwaysUseBigInt, introduced after bug ID 36486.
  121. Procedure TestSQLite3AlwaysUseBigint;
  122. end;
  123. implementation
  124. uses sqldbtoolsunit,toolsunit, variants, sqldb, bufdataset, strutils, dbconst, FmtBCD;
  125. Type HackedDataset = class(TDataset);
  126. const
  127. testFloatValuesCount = 21;
  128. 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);
  129. testBCDValuesCount = 10;
  130. testBCDValues : Array[0..testBCDValuesCount-1] of currency = (-100,54.53,1.2345,123.5345,0,1,-1,0,1.42,1324.4324);
  131. testIntValuesCount = 17;
  132. 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);
  133. testDateValuesCount = 18;
  134. testDateValues : Array[0..testDateValuesCount-1] of string = (
  135. '2000-01-01',
  136. '1999-12-31',
  137. '2004-02-29',
  138. '2004-03-01',
  139. '1991-02-28',
  140. '1991-03-01',
  141. '2040-10-16',
  142. '1977-09-29',
  143. '1899-12-29',
  144. '1899-12-30',
  145. '1899-12-31',
  146. '1900-01-01',
  147. '1800-03-30',
  148. '1754-06-04',
  149. '1650-05-10',
  150. '0904-04-12',
  151. '0199-07-09',
  152. '0001-01-01'
  153. );
  154. testBlobValuesCount = 6;
  155. testBlobValues : Array[0..testBlobValuesCount-1] of ansistring = (
  156. 'Test this Blob', // common value
  157. '', // empty value
  158. 'a'#0'b'#13#10#1'c', // binary data
  159. '''":a', // single quotes
  160. '\''\', // backslash
  161. '\n'#13'\0ab''c'
  162. );
  163. testBytesValuesCount = 5;
  164. testVarBytesValuesCount = 8;
  165. testBytesValues : Array[0..testVarBytesValuesCount-1] of shortstring = (
  166. #1#0#1#0#1, #0#0#1#0#1, #0''''#13#0#1, '\'#0'"\'#13, #13#13#0#10#10,
  167. '', #0, #0#1#2#3#4#5#6#7#8#9
  168. );
  169. procedure TTestFieldTypes.CreateTableWithFieldType(ADatatype: TFieldType;
  170. ASQLTypeDecl: string);
  171. begin
  172. with TSQLDBConnector(DBConnector) do
  173. begin
  174. Connection.ExecuteDirect('create table FPDEV2 (FT ' +ASQLTypeDecl+ ')');
  175. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  176. CommitDDL;
  177. end;
  178. end;
  179. procedure TTestFieldTypes.TestFieldDeclaration(ADatatype: TFieldType;
  180. ADataSize: integer);
  181. begin
  182. with TSQLDBConnector(DBConnector).Query do
  183. begin
  184. SQL.Clear;
  185. SQL.Add('select * from FPDEV2');
  186. Open;
  187. AssertEquals(1,FieldCount);
  188. AssertTrue(SameText('FT',Fields[0].FieldName));
  189. AssertEquals('DataSize', ADataSize, Fields[0].DataSize);
  190. AssertEquals('DataType', ord(ADatatype), ord(Fields[0].DataType));
  191. Close;
  192. end;
  193. end;
  194. procedure TTestFieldTypes.TestInt;
  195. var
  196. i : byte;
  197. begin
  198. CreateTableWithFieldType(ftInteger,'INT');
  199. TestFieldDeclaration(ftInteger,4);
  200. for i := 0 to testIntValuesCount-1 do
  201. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + inttostr(testIntValues[i]) + ')');
  202. with TSQLDBConnector(DBConnector).Query do
  203. begin
  204. Open;
  205. for i := 0 to testIntValuesCount-1 do
  206. begin
  207. AssertEquals(testIntValues[i],fields[0].AsInteger);
  208. Next;
  209. end;
  210. close;
  211. end;
  212. end;
  213. procedure TTestFieldTypes.TestTinyint;
  214. const
  215. testValuesCount = 5;
  216. testValues : Array[0..testValuesCount-1] of byte = (0,1,127,128,255);
  217. var
  218. datatype: string;
  219. fieldtype: TFieldType;
  220. i: integer;
  221. begin
  222. case SQLServerType of
  223. ssMSSQL:
  224. begin
  225. datatype := 'TINYINT';
  226. fieldtype := ftWord;
  227. end;
  228. ssMySQL:
  229. begin
  230. datatype := 'TINYINT UNSIGNED';
  231. fieldtype := ftWord;
  232. end;
  233. ssOracle:
  234. begin
  235. datatype := 'NUMBER(3)';
  236. fieldtype := ftSmallint;
  237. end;
  238. ssSQLite:
  239. begin
  240. datatype := 'TINYINT';
  241. fieldtype := ftSmallint;
  242. end;
  243. else
  244. begin
  245. fieldtype := ftSmallint;
  246. datatype := FieldtypeDefinitions[fieldtype];
  247. end;
  248. end;
  249. CreateTableWithFieldType(fieldtype, datatype);
  250. TestFieldDeclaration(fieldtype, sizeof(Smallint));
  251. with TSQLDBConnector(DBConnector) do
  252. begin
  253. Query.Open;
  254. for i := 0 to testValuesCount-1 do
  255. Query.AppendRecord([testValues[i]]);
  256. Query.ApplyUpdates;
  257. Query.Close;
  258. for i := 0 to testValuesCount-1 do
  259. ExecuteDirect('insert into FPDEV2 (FT) values (' + inttostr(testValues[i]) + ')');
  260. Query.Open;
  261. for i := 0 to testValuesCount*2-1 do
  262. begin
  263. AssertEquals(testValues[i mod testValuesCount], Query.Fields[0].AsInteger);
  264. Query.Next;
  265. end;
  266. Query.Close;
  267. end;
  268. end;
  269. procedure TTestFieldTypes.TestNumeric;
  270. const
  271. testValuesCount = 13;
  272. 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);
  273. 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);
  274. FieldTypes: array [0..7] of TFieldType = (ftBCD, ftBCD, ftBCD, ftFmtBCD, ftLargeInt, ftFmtBCD, ftFmtBCD, ftFmtBCD);
  275. FieldSizes: array [0..7] of integer = (4,2,3,5,0,3,5,0); //scale for FieldTypes
  276. var
  277. i,d : integer;
  278. s,s4,s9 : string;
  279. t : TFieldType;
  280. begin
  281. with TSQLDBConnector(DBConnector) do begin
  282. if SQLConnType = INTERBASE then
  283. begin
  284. //Interbase internal storage of exact numeric data types based on precision:
  285. // 1-4 (smallint), 5-9 (integer), 10-18 (int64)
  286. s := ''; //Interbase supports precision up to 18 only
  287. FieldTypes[5] := ftBCD; //ATM TIBConnection incorrectly maps NUMERIC(18,3) to ftBCD
  288. end
  289. else
  290. s := ', N19_0 NUMERIC(19,0)';
  291. 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 + ')');
  292. CommitDDL;
  293. with Query do
  294. begin
  295. SQL.Text := 'select * from FPDEV2';
  296. Open;
  297. for i := 0 to FieldCount-1 do
  298. begin
  299. case Fields[i].DataType of
  300. ftBCD: d := sizeof(Currency);
  301. ftFmtBCD: d := sizeof(TBCD);
  302. ftLargeInt: d := sizeof(int64);
  303. else d := 0;
  304. end;
  305. t := FieldTypes[i];
  306. if t = ftLargeInt then t := ftFmtBCD; //acceptable alternative
  307. AssertEquals(Fields[i].DataSize, d);
  308. AssertTrue(Fields[i].DataType in [FieldTypes[i], t]);
  309. AssertEquals(Fields[i].Size, FieldSizes[i]);
  310. end;
  311. Close;
  312. end;
  313. for i := 0 to testValuesCount-1 do
  314. begin
  315. s4 := CurrToStrF(testValues4[i],ffFixed,2,DBConnector.FormatSettings);
  316. s9 := CurrToStrF(testValues9[i],ffFixed,3,DBConnector.FormatSettings);
  317. 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]));
  318. end;
  319. with Query do
  320. begin
  321. Open;
  322. for i := 0 to testValuesCount-1 do
  323. begin
  324. AssertEquals(testValues4[i], Fields[1].AsCurrency);
  325. AssertEquals(testValues4[i], Fields[3].AsCurrency);
  326. AssertEquals(testValues9[i], Fields[0].AsCurrency);
  327. AssertEquals(testValues9[i], Fields[2].AsCurrency);
  328. AssertEquals(testValues9[i], Fields[5].AsCurrency);
  329. AssertEquals(testValues9[i], Fields[6].AsCurrency);
  330. Next;
  331. end;
  332. Close;
  333. end;
  334. end;
  335. end;
  336. procedure TTestFieldTypes.TestFloat;
  337. const
  338. testValuesCount = 21;
  339. 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);
  340. var
  341. i : byte;
  342. begin
  343. CreateTableWithFieldType(ftFloat,'FLOAT');
  344. TestFieldDeclaration(ftFloat,sizeof(double));
  345. for i := 0 to testValuesCount-1 do
  346. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + floattostr(testValues[i],DBConnector.FormatSettings) + ')');
  347. with TSQLDBConnector(DBConnector).Query do
  348. begin
  349. Open;
  350. for i := 0 to testValuesCount-1 do
  351. begin
  352. AssertEquals(testValues[i],fields[0].AsFloat);
  353. Next;
  354. end;
  355. close;
  356. end;
  357. end;
  358. procedure TTestFieldTypes.TestString;
  359. const
  360. testValuesCount = 19;
  361. testValues : Array[0..testValuesCount-1] of string = (
  362. '',
  363. 'a',
  364. 'ab',
  365. 'abc',
  366. 'abcd',
  367. 'abcde',
  368. 'abcdef',
  369. 'abcdefg',
  370. 'abcdefgh',
  371. 'abcdefghi',
  372. 'abcdefghij',
  373. 'lMnOpQrStU',
  374. '1234567890',
  375. '_!@#$%^&*(',
  376. ')-;:/?.<>',
  377. '~`|{}- =', // note that there's no \ (backslash) since some db's uses that as escape-character
  378. ' WRaP ',
  379. 'wRaP ',
  380. ' wRAP'
  381. );
  382. var
  383. i : byte;
  384. begin
  385. CreateTableWithFieldType(ftString,'VARCHAR(10)');
  386. TestFieldDeclaration(ftString,10*DBConnector.CharSize+1);
  387. for i := 0 to testValuesCount-1 do
  388. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testValues[i] + ''')');
  389. with TSQLDBConnector(DBConnector).Query do
  390. begin
  391. Open;
  392. for i := 0 to testValuesCount-1 do
  393. begin
  394. AssertEquals(testValues[i], Fields[0].AsString);
  395. AssertEquals('IsNull', False, Fields[0].IsNull); // '' is not NULL
  396. Next;
  397. end;
  398. Close;
  399. end;
  400. end;
  401. procedure TTestFieldTypes.TestUnlVarChar;
  402. const
  403. testValuesCount = 21;
  404. testValues : Array[0..testValuesCount-1] of string = (
  405. '',
  406. 'a',
  407. 'ab',
  408. 'abc',
  409. 'abcd',
  410. 'abcde',
  411. 'abcdef',
  412. 'abcdefg',
  413. 'abcdefgh',
  414. 'abcdefghi',
  415. 'abcdefghij',
  416. 'lMnOpQrStU',
  417. '1234567890',
  418. '_!@#$%^&*(',
  419. ')-;:/?.<>',
  420. '~`|{}- =',
  421. ' WRaP ',
  422. 'wRaP ',
  423. ' wRAP',
  424. '0123456789',
  425. 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?' + 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?'
  426. + 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?' + 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 !@#$%^&*()_+-=][|}{;:,./<>?'
  427. );
  428. var
  429. i : byte;
  430. begin
  431. if SQLServerType<>ssPostgreSQL then Ignore('This test only applies to Postgres, since others don''t support varchars without length given');
  432. CreateTableWithFieldType(ftString,'VARCHAR');
  433. TestFieldDeclaration(ftString,dsMaxStringSize+1);
  434. for i := 0 to testValuesCount-1 do
  435. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testValues[i] + ''')');
  436. with TSQLDBConnector(DBConnector).Query do
  437. begin
  438. Open;
  439. for i := 0 to testValuesCount-1 do
  440. begin
  441. AssertEquals(testValues[i],fields[0].AsString);
  442. Next;
  443. end;
  444. close;
  445. end;
  446. end;
  447. procedure TTestFieldTypes.TestDate;
  448. var
  449. i : byte;
  450. begin
  451. CreateTableWithFieldType(ftDate,'DATE');
  452. TestFieldDeclaration(ftDate,8);
  453. for i := 0 to testDateValuesCount-1 do
  454. if SQLConnType=oracle then
  455. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (to_date (''' + testDateValues[i] + ''',''YYYY-MM-DD''))')
  456. else
  457. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testDateValues[i] + ''')');
  458. with TSQLDBConnector(DBConnector).Query do
  459. begin
  460. Open;
  461. for i := 0 to testDateValuesCount-1 do
  462. begin
  463. AssertEquals(testDateValues[i],FormatDateTime('yyyy/mm/dd', fields[0].AsDateTime, DBConnector.FormatSettings));
  464. Next;
  465. end;
  466. close;
  467. end;
  468. end;
  469. procedure TTestFieldTypes.TestDateTime;
  470. const
  471. testValuesCount = 31;
  472. testValues : Array[0..testValuesCount-1] of string = (
  473. '2000-01-01',
  474. '1999-12-31',
  475. '2004-02-29',
  476. '2004-03-01',
  477. '1991-02-28',
  478. '1991-03-01',
  479. '1977-09-29',
  480. '2000-01-01 10:00:00',
  481. '2000-01-01 23:59:59',
  482. '1994-03-06 11:54:30',
  483. '2040-10-16', // MySQL 4.0 doesn't support datetimes before 1970 or after 2038
  484. '2100-01-01 01:01:01',
  485. '1903-04-02 01:04:02',
  486. '1900-01-01',
  487. '1899-12-31',
  488. '1899-12-30',
  489. '1899-12-29',
  490. '1899-12-30 18:00:51',
  491. '1899-12-30 04:00:51',
  492. '1899-12-29 04:00:51',
  493. '1899-12-29 18:00:51',
  494. '1815-09-24 03:47:22',
  495. '1800-03-30',
  496. '1754-06-04',
  497. '1650-05-10', // MS SQL 2005 doesn't support datetimes before 1753
  498. '1400-02-03 12:21:53',
  499. '1333-02-03 21:44:21',
  500. '0904-04-12',
  501. '0354-11-20 21:25:15',
  502. '0199-07-09',
  503. '0001-01-01'
  504. );
  505. var
  506. i : byte;
  507. begin
  508. CreateTableWithFieldType(ftDateTime,FieldtypeDefinitions[ftDateTime]);
  509. TestFieldDeclaration(ftDateTime,8);
  510. for i := 0 to testValuesCount-1 do
  511. if SQLConnType=oracle then
  512. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (to_date (''' + testValues[i] + ''',''YYYY-MM-DD HH24:MI:SS''))')
  513. else
  514. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + testValues[i] + ''')');
  515. with TSQLDBConnector(DBConnector).Query do
  516. begin
  517. Open;
  518. for i := 0 to testValuesCount-1 do
  519. begin
  520. if length(testValues[i]) < 12 then
  521. AssertEquals(testValues[i],FormatDateTime('yyyy/mm/dd', fields[0].AsDateTime, DBConnector.FormatSettings))
  522. else
  523. AssertEquals(testValues[i],FormatDateTime('yyyy/mm/dd hh:mm:ss', fields[0].AsDateTime, DBConnector.FormatSettings));
  524. Next;
  525. end;
  526. close;
  527. end;
  528. end;
  529. procedure TTestFieldTypes.TestBlob;
  530. begin
  531. CreateTableWithFieldType(ftBlob,FieldtypeDefinitions[ftBlob]);
  532. TestFieldDeclaration(ftBlob,0);
  533. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''Test this blob'')');
  534. with TSQLDBConnector(DBConnector).Query do
  535. begin
  536. Open;
  537. AssertEquals('Test this blob',fields[0].AsString);
  538. close;
  539. end;
  540. end;
  541. procedure TTestFieldTypes.TestChangeBlob;
  542. var s : string;
  543. begin
  544. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (ID int,FT '+FieldtypeDefinitions[ftblob]+')');
  545. TSQLDBConnector(DBConnector).CommitDDL;
  546. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (ID,FT) values (1,''Test this blob'')');
  547. with TSQLDBConnector(DBConnector).Query do
  548. begin
  549. sql.clear;
  550. sql.add('select * from FPDEV2');
  551. Open;
  552. AssertEquals('Test this blob', Fields[1].AsString);
  553. Fields[1].ProviderFlags := [pfInUpdate]; // Blob is not in the where
  554. UpdateMode := upWhereAll;
  555. Edit;
  556. s := 'This blob has changed!';
  557. Fields[1].AsString := s;
  558. AssertEquals(s, Fields[1].AsString); // test before Post
  559. Cancel;
  560. AssertEquals('After Cancel', 'Test this blob', Fields[1].AsString); // original value
  561. Append; // Blob is null
  562. Fields[1].AsString := s; // Null flag must be unset
  563. AssertEquals(s, Fields[1].AsString);
  564. Fields[1].Clear;
  565. AssertTrue('Clear', Fields[1].IsNull);
  566. Cancel;
  567. Edit;
  568. With CreateBlobStream(Fields[1], bmWrite) do
  569. begin
  570. s := 'This blob has changed!';
  571. WriteBuffer(Pointer(s)^,Length(s));
  572. Post;
  573. Free;
  574. end;
  575. AssertEquals('After Post', s, Fields[1].AsString);
  576. ApplyUpdates(0);
  577. TSQLDBConnector(DBConnector).Transaction.CommitRetaining; // For debug-purposes
  578. Close;
  579. Open;
  580. AssertEquals(s, Fields[1].AsString);
  581. Close;
  582. end;
  583. end;
  584. procedure TTestFieldTypes.TestBlobGetText;
  585. begin
  586. CreateTableWithFieldType(ftBlob,FieldtypeDefinitions[ftBlob]);
  587. TestFieldDeclaration(ftBlob,0);
  588. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''Test this blob'')');
  589. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (Null)');
  590. with TSQLDBConnector(DBConnector).Query do
  591. begin
  592. Open;
  593. AssertFalse(fields[0].IsNull);
  594. AssertEquals('(BLOB)',fields[0].DisplayText);
  595. AssertEquals('Test this blob',fields[0].AsString);
  596. Next;
  597. AssertTrue(fields[0].IsNull);
  598. AssertEquals('(blob)',fields[0].Text);
  599. AssertEquals('',fields[0].AsString);
  600. close;
  601. end;
  602. end;
  603. procedure TTestFieldTypes.TestBlobSize;
  604. const
  605. TestValue: string = 'Test this blob';
  606. begin
  607. CreateTableWithFieldType(ftBlob,FieldtypeDefinitions[ftBlob]);
  608. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values ('''+TestValue+''')');
  609. with TSQLDBConnector(DBConnector).Query do
  610. begin
  611. sql.text := 'select * from FPDEV2';
  612. Open;
  613. AssertEquals(length(TestValue),TBlobField(fields[0]).BlobSize);
  614. close;
  615. end;
  616. end;
  617. procedure TTestFieldTypes.TestSQLFieldType(ADatatype : TFieldType; ASQLTypeDecl : string; ADataSize: integer; AGetSQLTextProc: TGetSQLTextProc; ACheckFieldValueProc: TCheckFieldValueProc);
  618. var
  619. i : byte;
  620. s: string;
  621. begin
  622. CreateTableWithFieldType(ADatatype,ASQLTypeDecl);
  623. TestFieldDeclaration(ADatatype,ADataSize);
  624. for i := 0 to testValuesCount-1 do
  625. begin
  626. s := AGetSQLTextProc(i);
  627. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + s + ')');
  628. end;
  629. with TSQLDBConnector(DBConnector).Query do
  630. begin
  631. Open;
  632. for i := 0 to testValuesCount-1 do
  633. begin
  634. ACheckFieldValueProc(Fields[0],i);
  635. Next;
  636. end;
  637. close;
  638. end;
  639. end;
  640. // Placed here, as long as bug 18702 is not solved
  641. function TestSQLClob_GetSQLText(const a: integer) : string;
  642. begin
  643. result := QuotedStr(testStringValues[a]);
  644. end;
  645. procedure TTestFieldTypes.TestSQLClob;
  646. procedure CheckFieldValue(AField:TField; a : integer);
  647. begin
  648. AssertEquals(testStringValues[a],AField.AsString);
  649. end;
  650. var datatype: string;
  651. begin
  652. if SQLConnType=sqlite3 then
  653. datatype:='CLOB'
  654. else
  655. datatype:=FieldtypeDefinitions[ftMemo];
  656. TestSQLFieldType(ftMemo, datatype, 0, @TestSQLClob_GetSQLText, @CheckFieldValue);
  657. end;
  658. // Placed here, as long as bug 18702 is not solved
  659. function TestSQLLargeInt_GetSQLText(const a: integer) : string;
  660. begin
  661. result := IntToStr(testLargeIntValues[a]);
  662. end;
  663. procedure TTestFieldTypes.TestSQLLargeint;
  664. procedure CheckFieldValue(AField:TField; a : integer);
  665. begin
  666. AssertEquals(testLargeIntValues[a],AField.AsLargeInt);
  667. end;
  668. var datatype: string;
  669. begin
  670. if SQLConnType=sqlite3 then
  671. datatype:='LARGEINT'
  672. else
  673. datatype:='BIGINT';
  674. TestSQLFieldType(ftLargeint, datatype, 8, @TestSQLLargeint_GetSQLText, @CheckFieldValue);
  675. end;
  676. var testIntervalValuesCount: integer;
  677. const testIntervalValues: array[0..5] of shortstring = ('00:00:00.000','00:00:01.000','23:59:59.000','99:59:59.000','838:59:59.000','1000:00:00.000');
  678. // Placed here, as long as bug 18702 is not solved
  679. function TestSQLInterval_GetSQLText(const a: integer) : string;
  680. begin
  681. if a < testIntervalValuesCount then
  682. Result := QuotedStr(testIntervalValues[a])
  683. else
  684. Result := 'NULL'
  685. end;
  686. procedure TTestFieldTypes.TestSQLInterval;
  687. procedure CheckFieldValue(AField: TField; a: integer);
  688. begin
  689. if a < testIntervalValuesCount then
  690. AssertEquals(testIntervalValues[a], DateTimeToTimeString(AField.AsDateTime))
  691. else
  692. AssertTrue(AField.IsNull);
  693. end;
  694. var datatype: string;
  695. begin
  696. if SQLConnType = postgresql then
  697. begin
  698. datatype:='INTERVAL';
  699. testIntervalValuesCount := 6;
  700. end
  701. else
  702. begin
  703. datatype:=FieldtypeDefinitions[ftTime];
  704. if datatype = '' then
  705. Ignore(STestNotApplicable);
  706. if SQLServerType = ssSQLite then
  707. testIntervalValuesCount := 6
  708. else if SQLServerType = ssMySQL then
  709. // MySQL ODBC driver prior 5.2.6 doesn't correctly handles time values >= '100:00:00'
  710. testIntervalValuesCount := 5
  711. else
  712. testIntervalValuesCount := 3;
  713. end;
  714. TestSQLFieldType(ftTime, datatype, sizeof(TDateTime), @TestSQLInterval_GetSQLText, @CheckFieldValue);
  715. end;
  716. procedure TTestFieldTypes.TestSQLIdentity;
  717. var datatype, values: string;
  718. fieldtype: TFieldType;
  719. i: integer;
  720. updatable: boolean;
  721. begin
  722. case SQLServerType of
  723. ssMySQL:
  724. begin
  725. datatype:='INT AUTO_INCREMENT PRIMARY KEY';
  726. values:='VALUES(DEFAULT)';
  727. fieldtype:=ftAutoInc;
  728. updatable:=true;
  729. end;
  730. ssSQLite:
  731. begin
  732. datatype:='INTEGER PRIMARY KEY';
  733. values:='DEFAULT VALUES';
  734. fieldtype:=ftAutoInc;
  735. updatable:=true;
  736. end;
  737. ssPostgreSQL:
  738. begin
  739. datatype:='SERIAL';
  740. values:='DEFAULT VALUES';
  741. if SQLConnType = ODBC then
  742. fieldtype:=ftAutoInc
  743. else
  744. fieldtype:=ftInteger;
  745. updatable:=true;
  746. end;
  747. ssMSSQL, ssSybase:
  748. begin
  749. datatype:='INTEGER IDENTITY';
  750. values:='DEFAULT VALUES';
  751. fieldtype:=ftAutoInc;
  752. updatable:=false;
  753. end
  754. else
  755. Ignore(STestNotApplicable);
  756. end;
  757. CreateTableWithFieldType(fieldtype, datatype);
  758. TestFieldDeclaration(fieldtype, sizeof(longint));
  759. for i := 1 to 3 do
  760. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 '+values);
  761. with TSQLDBConnector(DBConnector).Query do
  762. begin
  763. Open;
  764. AssertTrue(Locate('FT',1,[])); // bug 17624
  765. for i := 1 to 3 do
  766. begin
  767. AssertEquals(i, Fields[0].AsInteger);
  768. Next;
  769. end;
  770. // some databases (like MS SQL Server) do not allow updating identity columns
  771. AssertEquals('ReadOnly', Fields[0].ReadOnly, not updatable);
  772. // some databases (like PostgreSQL, MySQL) allow inserting explicit values and updating auto incrementing columns
  773. if updatable then
  774. begin
  775. UpdateMode:=upWhereAll; // if there is no PK for FPDEV2 table
  776. // updating:
  777. Last;
  778. while not Bof do
  779. begin
  780. Edit;
  781. Fields[0].AsInteger:=Fields[0].AsInteger+2;
  782. Post;
  783. Prior;
  784. end;
  785. // inserting:
  786. Append;
  787. Fields[0].AsInteger:=6;
  788. Post;
  789. ApplyUpdates;
  790. end;
  791. Close;
  792. end;
  793. end;
  794. function TestSQLReal_GetSQLText(const i: integer) : string;
  795. begin
  796. if i < 20 then // first 20 values fit into MySQL FLOAT data type
  797. Result := FloatToStr(testFloatValues[i], DBConnector.FormatSettings)
  798. else
  799. Result := 'NULL';
  800. end;
  801. procedure TTestFieldTypes.TestSQLReal;
  802. procedure CheckFieldValue(AField:TField; i: integer);
  803. begin
  804. if i < 20 then
  805. AssertEquals(testFloatValues[i], AField.AsFloat)
  806. else
  807. AssertTrue(AField.IsNull);
  808. end;
  809. var datatype: string;
  810. begin
  811. case SQLServerType of
  812. ssFirebird, ssInterbase,
  813. ssMySQL:
  814. datatype:='FLOAT';
  815. ssOracle:
  816. datatype:='BINARY_FLOAT';
  817. else
  818. datatype:='REAL';
  819. end;
  820. TestSQLFieldType(ftFloat, datatype, sizeof(double), @TestSQLReal_GetSQLText, @CheckFieldValue);
  821. end;
  822. const testUUIDValues: array[0..2] of shortstring = ('{00000000-0000-0000-0000-000000000000}','{A972C577-DFB0-064E-1189-0154C99310DA}','{A0EEBC99-9C0B-4EF8-BB6D-6BB9BD380A11}');
  823. // Placed here, as long as bug 18702 is not solved
  824. function TestSQLUUID_GetSQLText(const i: integer) : string;
  825. begin
  826. if i < Length(testUUIDValues) then
  827. Result := QuotedStr(Copy(testUUIDValues[i],2,36))
  828. else
  829. Result := 'NULL';
  830. end;
  831. procedure TTestFieldTypes.TestSQLUUID;
  832. procedure CheckFieldValue(AField:TField; i: integer);
  833. begin
  834. if i < Length(testUUIDValues) then
  835. AssertEquals(testUUIDValues[i], AField.AsString)
  836. else
  837. AssertTrue(AField.IsNull);
  838. end;
  839. begin
  840. if FieldtypeDefinitions[ftGuid] = '' then
  841. Ignore(STestNotApplicable);
  842. TestSQLFieldType(ftGuid, FieldtypeDefinitions[ftGuid], 39, @TestSQLUUID_GetSQLText, @CheckFieldValue);
  843. end;
  844. procedure TTestFieldTypes.TestStringLargerThen8192;
  845. // See also: TestInsertLargeStrFields
  846. var
  847. s : string;
  848. i : integer;
  849. begin
  850. // Firebird has limit 32765 bytes, so this is 8191 characters when using UNICODE character set
  851. CreateTableWithFieldType(ftString,'VARCHAR(9000)');
  852. TestFieldDeclaration(ftString,9000*DBConnector.CharSize+1);
  853. setlength(s,9000);
  854. for i := 1 to 9000 do
  855. s[i]:=chr((i mod 10)+ord('a'));
  856. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (''' + s + ''')');
  857. with TSQLDBConnector(DBConnector).Query do
  858. begin
  859. Open;
  860. AssertEquals(s,Fields[0].AsString);
  861. Close;
  862. end;
  863. end;
  864. procedure TTestFieldTypes.TestInsertLargeStrFields;
  865. // See also: TestStringLargerThen8192
  866. var
  867. FieldValues: array [1..4] of string;
  868. i,l1,l2: integer;
  869. begin
  870. FieldValues[1] := 'test1'; // string length < 8192 (dsMaxStringSize)
  871. FieldValues[2] := StringOfChar('a', 8192); // string length = 8192 (dsMaxStringSize)
  872. FieldValues[3] := StringOfChar('b', 16000); // string length > 8192 (dsMaxStringSize)
  873. FieldValues[4] := StringOfChar('c', 17000); // string length > Field.Size
  874. with TSQLDBConnector(DBConnector) do
  875. begin
  876. Connection.ExecuteDirect( 'create table FPDEV2 (' +
  877. ' ID INT NOT NULL , ' +
  878. ' F1 VARCHAR(8192), ' +
  879. ' F2 VARCHAR(16000),' +
  880. 'primary key (ID) )');
  881. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  882. TSQLDBConnector(DBConnector).CommitDDL;
  883. query.sql.Text:='select * from FPDEV2';
  884. Query.Open;
  885. for i:=1 to high(FieldValues) do
  886. Query.InsertRecord([i, FieldValues[i], FieldValues[i]]);
  887. Query.ApplyUpdates;
  888. Query.Close;
  889. Query.Open;
  890. for i:=1 to high(FieldValues) do
  891. begin
  892. l1:=length(FieldValues[i]);
  893. if l1 > 8192 then l1 := 8192;
  894. l2:=length(FieldValues[i]);
  895. if l2 > 16000 then l2 := 16000;
  896. AssertEquals(l1, length(Query.FieldByName('F1').AsString));
  897. AssertEquals(l2, length(Query.FieldByName('F2').AsString));
  898. AssertEquals(copy(FieldValues[i],1,l1), Query.FieldByName('F1').AsString);
  899. AssertEquals(copy(FieldValues[i],1,l2), Query.FieldByName('F2').AsString);
  900. Query.Next;
  901. end;
  902. Query.Close;
  903. end;
  904. end;
  905. procedure TTestFieldTypes.TestLargeRecordSize;
  906. // probably tests situation, where total record size > 64K (TDataSet.RecordSize returns word value)
  907. begin
  908. 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))');
  909. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  910. TSQLDBConnector(DBConnector).CommitDDL;
  911. with TSQLDBConnector(DBConnector).Query do
  912. begin
  913. sql.clear;
  914. 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..............'')');
  915. ExecSQL;
  916. sql.clear;
  917. sql.append('select * from FPDEV2');
  918. open;
  919. AssertEquals('ZUBNE PASTE',FieldByName('plant').AsString);
  920. AssertEquals(EncodeDate(2005,07,01),FieldByName('sampling_datetime').AsDateTime);
  921. close;
  922. end;
  923. end;
  924. procedure TTestFieldTypes.TestNullValues;
  925. begin
  926. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (FIELD1 INT, FIELD2 INT)');
  927. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  928. TSQLDBConnector(DBConnector).CommitDDL;
  929. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FIELD1) values (1)');
  930. with TSQLDBConnector(DBConnector).Query do
  931. begin
  932. sql.clear;
  933. sql.append('select * from FPDEV2');
  934. open;
  935. AssertEquals(1,FieldByName('FIELD1').AsInteger);
  936. AssertTrue('Null-values test failed',FieldByName('FIELD2').IsNull);
  937. close;
  938. end;
  939. end;
  940. procedure TTestFieldTypes.TestAggregates;
  941. begin
  942. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (FIELD1 INT, FIELD2 INT)');
  943. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  944. TSQLDBConnector(DBConnector).CommitDDL;
  945. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 values (1,1)');
  946. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 values (2,3)');
  947. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 values (3,4)');
  948. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 values (4,4)');
  949. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  950. with TSQLDBConnector(DBConnector).Query do
  951. begin
  952. sql.clear;
  953. sql.append('select count(*) from FPDEV2');
  954. open;
  955. AssertEquals(4,Fields[0].AsInteger);
  956. close;
  957. sql.clear;
  958. sql.append('select sum(FIELD1) from FPDEV2');
  959. open;
  960. AssertEquals(10,Fields[0].AsInteger);
  961. close;
  962. sql.clear;
  963. sql.append('select avg(FIELD2) from FPDEV2');
  964. open;
  965. AssertEquals(3,Fields[0].AsInteger);
  966. close;
  967. end;
  968. end;
  969. procedure TTestFieldTypes.TestBug9744;
  970. var i : integer;
  971. begin
  972. // Tests rev.8703: "Fixed MySQL ftLargeInt support"; count() returns BIGINT values
  973. with TSQLDBConnector(DBConnector) do
  974. begin
  975. try
  976. Connection.ExecuteDirect('create table TTTOBJ ( ' +
  977. ' ID INT NOT NULL, ' +
  978. ' NAME VARCHAR(250), ' +
  979. ' PRIMARY KEY (ID) ' +
  980. ') ');
  981. Connection.ExecuteDirect('create table TTTXY ( ' +
  982. ' ID INT NOT NULL, ' +
  983. ' NP INT NOT NULL, ' +
  984. ' PRIMARY KEY (ID,NP)' +
  985. ') ');
  986. Transaction.CommitRetaining;
  987. for i := 0 to 7 do
  988. begin
  989. connection.ExecuteDirect('insert into TTTOBJ(ID,NAME) values ('+inttostr(i)+',''A'+inttostr(i)+''')');
  990. connection.ExecuteDirect('insert into TTTXY(ID,NP) values ('+inttostr(i)+',1)');
  991. connection.ExecuteDirect('insert into TTTXY(ID,NP) values ('+inttostr(i)+',2)');
  992. end;
  993. Query.SQL.Text := 'select OBJ.ID, OBJ.NAME, count(XY.NP) as NPF from TTTOBJ OBJ, TTTXY XY where OBJ.ID=XY.ID group by OBJ.ID, OBJ.NAME';
  994. query.Prepare;
  995. query.open;
  996. query.close;
  997. finally
  998. Connection.ExecuteDirect('drop table TTTXY');
  999. Connection.ExecuteDirect('drop table TTTOBJ');
  1000. Transaction.CommitRetaining;
  1001. end
  1002. end;
  1003. end;
  1004. procedure TTestFieldTypes.TestDoubleFieldNames;
  1005. begin
  1006. with TSQLDBConnector(DBConnector) do
  1007. begin
  1008. with query do
  1009. begin
  1010. SQL.Text:='select FPDEV.*,TT.* from FPDEV left join FPDEV TT on TT.ID=FPDEV.ID';
  1011. Open;
  1012. AssertTrue(assigned(FindField('ID')));
  1013. AssertTrue (assigned(FindField('ID_1')));
  1014. AssertTrue(assigned(FindField('NAME')));
  1015. AssertTrue(assigned(FindField('NAME_1')));
  1016. AssertEquals(1,fieldbyname('ID').AsInteger);
  1017. AssertEquals(1,fieldbyname('ID_1').AsInteger);
  1018. AssertEquals('TestName1',fieldbyname('NAME').AsString);
  1019. AssertEquals('TestName1',fieldbyname('NAME_1').AsString);
  1020. close;
  1021. end;
  1022. end;
  1023. end;
  1024. procedure TTestFieldTypes.TestNumericFieldNames;
  1025. begin
  1026. with TSQLDBConnector(DBConnector) do
  1027. begin
  1028. Connection.ExecuteDirect('create table FPDEV2 (' +
  1029. ' '+connection.FieldNameQuoteChars[0]+'2ID'+connection.FieldNameQuoteChars[1]+' INT NOT NULL,' +
  1030. ' '+connection.FieldNameQuoteChars[0]+'3TEST'+connection.FieldNameQuoteChars[1]+' VARCHAR(10),' +
  1031. ' PRIMARY KEY ('+connection.FieldNameQuoteChars[0]+'2ID'+connection.FieldNameQuoteChars[0]+') ' +
  1032. ') ');
  1033. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1034. TSQLDBConnector(DBConnector).CommitDDL;
  1035. with query do
  1036. begin
  1037. SQL.Text:='select * from FPDEV2';
  1038. Open;
  1039. Edit;
  1040. fieldbyname('2ID').AsInteger:=1;
  1041. fieldbyname('3TEST').AsString:='3test';
  1042. Post;
  1043. ApplyUpdates(0);
  1044. close;
  1045. open;
  1046. AssertEquals('3test',FieldByName('3TEST').AsString);
  1047. Edit;
  1048. fieldbyname('3TEST').AsString:='test3';
  1049. Post;
  1050. ApplyUpdates(0);
  1051. open;
  1052. AssertEquals('test3',FieldByName('3TEST').AsString);
  1053. close;
  1054. end;
  1055. end;
  1056. end;
  1057. procedure TTestFieldTypes.TestApplyUpdFieldNames;
  1058. begin
  1059. with TSQLDBConnector(DBConnector) do
  1060. begin
  1061. AssertEquals(-1,query.RowsAffected);
  1062. Connection.ExecuteDirect('create table FPDEV2 (' +
  1063. ' ID INT NOT NULL, ' +
  1064. ' '+Connection.FieldNameQuoteChars[0]+'NAME-TEST'+Connection.FieldNameQuoteChars[1]+' VARCHAR(250), ' +
  1065. ' PRIMARY KEY (ID) ' +
  1066. ') ');
  1067. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1068. TSQLDBConnector(DBConnector).CommitDDL;
  1069. Connection.ExecuteDirect('insert into FPDEV2(ID,'+Connection.FieldNameQuoteChars[0]+'NAME-TEST'+Connection.FieldNameQuoteChars[1]+') values (1,''test1'')');
  1070. Query.SQL.Text := 'select * from FPDEV2';
  1071. Query.Open;
  1072. AssertEquals(1,Query.FieldByName('ID').AsInteger);
  1073. AssertEquals('test1',Query.FieldByName('NAME-TEST').AsString);
  1074. Query.Edit;
  1075. Query.FieldByName('NAME-TEST').AsString:='Edited';
  1076. Query.Post;
  1077. Query.ApplyUpdates;
  1078. Query.Close;
  1079. Query.Open;
  1080. AssertEquals(1,Query.FieldByName('ID').AsInteger);
  1081. AssertEquals('Edited',Query.FieldByName('NAME-TEST').AsString);
  1082. Query.Close;
  1083. end;
  1084. end;
  1085. procedure TTestFieldTypes.TestParseJoins;
  1086. begin
  1087. with TSQLDBConnector(DBConnector) do
  1088. begin
  1089. with query do
  1090. begin
  1091. SQL.Text:='select TT.NAME from FPDEV left join FPDEV TT on TT.ID=FPDEV.ID';
  1092. Open;
  1093. AssertFalse(CanModify);
  1094. Close;
  1095. SQL.Text:='select T1.NAME from FPDEV T1,FPDEV T2 where T1.ID=T2.ID';
  1096. Open;
  1097. AssertFalse(CanModify);
  1098. Close;
  1099. end;
  1100. end;
  1101. end;
  1102. procedure TTestFieldTypes.TestParseUnion;
  1103. begin
  1104. with TSQLDBConnector(DBConnector) do
  1105. begin
  1106. with query do
  1107. begin
  1108. SQL.Text:='select NAME from FPDEV where ID<5';
  1109. SQL.Add('union');
  1110. SQL.Add('select NAME from FPDEV where ID>5');
  1111. Open;
  1112. close;
  1113. end;
  1114. end;
  1115. end;
  1116. procedure TTestFieldTypes.TestClearUpdateableStatus;
  1117. // Test if CanModify is correctly disabled in case of a select query without
  1118. // a from-statement.
  1119. begin
  1120. if not (SQLServerType in [ssMySQL]) then Ignore('This test only applies to MySQL because the used SQL-statement is MySQL only.');
  1121. with TSQLDBConnector(DBConnector) do
  1122. begin
  1123. with (GetNDataset(false,5) as TSQLQuery) do
  1124. begin
  1125. Open;
  1126. AssertEquals(True,CanModify);
  1127. Close;
  1128. SQL.Text:='select last_insert_id();';
  1129. Open;
  1130. AssertEquals(False,CanModify);
  1131. close;
  1132. end;
  1133. end;
  1134. end;
  1135. procedure TTestFieldTypes.TestReadOnlyParseSQL;
  1136. begin
  1137. with TSQLDBConnector(DBConnector) do
  1138. begin
  1139. GetFieldDataset(True);
  1140. with query do
  1141. begin
  1142. AssertFalse(ReadOnly);
  1143. AssertTrue(ParseSQL);
  1144. // If ParseSQL is false, and no update-queries are given, the query
  1145. // shouldn't be updateable after open.
  1146. ParseSQL := False;
  1147. AssertFalse(ParseSQL);
  1148. AssertFalse(ReadOnly);
  1149. SQL.Text := 'select * from FPDEV;';
  1150. open;
  1151. AssertFalse(ParseSQL);
  1152. AssertFalse(ReadOnly);
  1153. AssertFalse(CanModify);
  1154. close;
  1155. // If ParseSQL is true, the query should be updateable after open.
  1156. ReadOnly := False;
  1157. ParseSQL := True;
  1158. AssertTrue(ParseSQL);
  1159. AssertFalse(ReadOnly);
  1160. SQL.Text := 'select * from FPDEV';
  1161. open;
  1162. AssertTrue(ParseSQL);
  1163. AssertFalse(ReadOnly);
  1164. AssertTrue(CanModify);
  1165. edit;
  1166. FieldByName('ID').AsInteger:=321;
  1167. post;
  1168. ApplyUpdates;
  1169. close;
  1170. // If ParseSQL is true, but the supplied query isn't updateable, then
  1171. // the query shouldn't be updateable after open.
  1172. ReadOnly := False;
  1173. SQL.Text:='select ID,NAME from FPDEV where ID<5';
  1174. sql.Add('union');
  1175. sql.Add('select ID,NAME from FPDEV where ID>5');
  1176. AssertTrue(ParseSQL);
  1177. AssertFalse(ReadOnly);
  1178. open;
  1179. AssertTrue(ParseSQL);
  1180. AssertFalse(ReadOnly);
  1181. AssertFalse(CanModify);
  1182. close;
  1183. // As above, but now with an update-query, so that the query should
  1184. // be updateable again.
  1185. ReadOnly := False;
  1186. AssertTrue(ParseSQL);
  1187. AssertFalse(ReadOnly);
  1188. UpdateSQL.Text:='update FPDEV set ID=:ID where ID=:OLD_ID';
  1189. open;
  1190. AssertTrue(ParseSQL);
  1191. AssertFalse(ReadOnly);
  1192. AssertTrue(CanModify);
  1193. edit;
  1194. post;
  1195. ApplyUpdates;
  1196. close;
  1197. // Also if ParseSQL is False, the query should be updateable if a update-
  1198. // query is given.
  1199. ReadOnly := False;
  1200. ParseSQL := False;
  1201. AssertFalse(ParseSQL);
  1202. AssertFalse(ReadOnly);
  1203. open;
  1204. AssertFalse(ParseSQL);
  1205. AssertFalse(ReadOnly);
  1206. AssertTrue(CanModify);
  1207. edit;
  1208. FieldByName('ID').AsInteger:=1; // field "ID" from UNION can be marked as ReadOnly
  1209. post;
  1210. ApplyUpdates;
  1211. close;
  1212. // But if ReadOnly is true, then CanModify should always be false
  1213. ReadOnly := True;
  1214. ParseSQL := False;
  1215. AssertFalse(ParseSQL);
  1216. AssertTrue(ReadOnly);
  1217. open;
  1218. AssertFalse(ParseSQL);
  1219. AssertTrue(ReadOnly);
  1220. AssertFalse(CanModify);
  1221. close;
  1222. end;
  1223. end;
  1224. end;
  1225. procedure TTestFieldTypes.TestDblQuoteEscComments;
  1226. begin
  1227. with TSQLDBConnector(DBConnector).Query do
  1228. begin
  1229. SQL.Clear;
  1230. SQL.Add('select * from FPDEV where NAME=''test '''' and :ThisIsNotAParameter ''');
  1231. Open;
  1232. Close;
  1233. end;
  1234. end;
  1235. procedure TTestFieldTypes.TestpfInUpdateFlag;
  1236. var ds : TCustomBufDataset;
  1237. AFld1, AFld2, AFld3 : Tfield;
  1238. begin
  1239. ds := (DBConnector.GetNDataset(True,5) as TCustomBufDataset);
  1240. with ds do
  1241. begin
  1242. AFld1 := TIntegerField.Create(ds);
  1243. AFld1.FieldName := IdentifierCase('ID');
  1244. AFld1.DataSet := ds;
  1245. AFld1.ProviderFlags := AFld1.ProviderFlags + [pfInKey];
  1246. AFld2 := TStringField.Create(ds);
  1247. AFld2.FieldName := IdentifierCase('NAME');
  1248. AFld2.DataSet := ds;
  1249. AFld3 := TIntegerField.Create(ds);
  1250. AFld3.FieldName := 'CALCFLD';
  1251. AFld3.DataSet := ds;
  1252. Afld3.FieldKind := fkCalculated;
  1253. AFld3.ProviderFlags := []; // do not include calculated fields into generated sql insert/update
  1254. Open;
  1255. Edit;
  1256. FieldByName('ID').AsInteger := 254;
  1257. Post;
  1258. ApplyUpdates;
  1259. Append;
  1260. FieldByName('ID').AsInteger := 255;
  1261. Post;
  1262. ApplyUpdates;
  1263. Close;
  1264. AFld1.Free;
  1265. AFld2.Free;
  1266. AFld3.Free;
  1267. end;
  1268. end;
  1269. procedure TTestFieldTypes.TestParamQuery;
  1270. // Tests running insert queries using parameters
  1271. const
  1272. DecoyFieldData1='decoytest';
  1273. DecoyFieldData2=':decoy ::test $decoy2 $$2';
  1274. begin
  1275. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (FIELD1 INT, FIELD2 INT, FIELD3 INT, DECOY VARCHAR(30))');
  1276. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1277. TSQLDBConnector(DBConnector).CommitDDL;
  1278. with TSQLDBConnector(DBConnector).Query do
  1279. begin
  1280. sql.clear;
  1281. sql.append('insert into FPDEV2 (FIELD1) values (:field1)');
  1282. Params.ParamByName('field1').AsInteger := 1;
  1283. ExecSQL;
  1284. sql.clear;
  1285. sql.append('insert into FPDEV2 (FIELD1,FIELD2,DECOY) values (:field1,:field2,'''+DecoyFieldData1+''')');
  1286. Params.ParamByName('field1').AsInteger := 2;
  1287. Params.ParamByName('field2').DataType := ftInteger;
  1288. Params.ParamByName('field2').Value := Null;
  1289. ExecSQL;
  1290. sql.clear;
  1291. sql.append('insert into FPDEV2 (FIELD1,FIELD2,FIELD3) values (:field1,:field2,:field3)');
  1292. Params.ParamByName('field1').AsInteger := 3;
  1293. Params.ParamByName('field2').AsInteger := 2;
  1294. Params.ParamByName('field3').AsInteger := 3;
  1295. ExecSQL;
  1296. sql.clear;
  1297. sql.append('insert into FPDEV2 (FIELD1,FIELD2,FIELD3,DECOY) values (:field1,:field2,:field3,'''+DecoyFieldData2+''')');
  1298. Params.ParamByName('field1').AsInteger := 4;
  1299. Params.ParamByName('field2').AsInteger := 2;
  1300. Params.ParamByName('field3').AsInteger := 3;
  1301. ExecSQL;
  1302. sql.clear;
  1303. sql.append('insert into FPDEV2 (FIELD1,FIELD2,FIELD3) values (:field1,:field2,:field1)');
  1304. Params.ParamByName('field1').AsInteger := 5;
  1305. Params.ParamByName('field2').AsInteger := 2;
  1306. ExecSQL;
  1307. sql.clear;
  1308. sql.append('select * from FPDEV2 order by FIELD1');
  1309. open;
  1310. AssertEquals(1,FieldByName('FIELD1').asinteger);
  1311. AssertTrue(FieldByName('FIELD2').IsNull);
  1312. AssertTrue(FieldByName('FIELD3').IsNull);
  1313. AssertTrue(FieldByName('DECOY').IsNull);
  1314. next;
  1315. AssertEquals(2,FieldByName('FIELD1').asinteger);
  1316. AssertTrue(FieldByName('FIELD2').IsNull);
  1317. AssertTrue(FieldByName('FIELD3').IsNull);
  1318. AssertEquals(DecoyFieldData1,FieldByName('DECOY').AsString);
  1319. next;
  1320. AssertEquals(3,FieldByName('FIELD1').asinteger);
  1321. AssertEquals(2,FieldByName('FIELD2').asinteger);
  1322. AssertEquals(3,FieldByName('FIELD3').asinteger);
  1323. AssertTrue(FieldByName('DECOY').IsNull);
  1324. next;
  1325. AssertEquals(4,FieldByName('FIELD1').asinteger);
  1326. AssertEquals(2,FieldByName('FIELD2').asinteger);
  1327. AssertEquals(3,FieldByName('FIELD3').asinteger);
  1328. AssertEquals(DecoyFieldData2,FieldByName('DECOY').AsString);
  1329. next;
  1330. AssertEquals(5,FieldByName('FIELD1').asinteger);
  1331. AssertEquals(2,FieldByName('FIELD2').asinteger);
  1332. AssertEquals(5,FieldByName('FIELD3').asinteger);
  1333. AssertTrue(FieldByName('DECOY').IsNull);
  1334. close;
  1335. end;
  1336. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1337. end;
  1338. procedure TTestFieldTypes.TestSmallIntParamQuery;
  1339. begin
  1340. TestXXParamQuery(ftSmallInt,FieldtypeDefinitions[ftSmallInt],testValuesCount);
  1341. end;
  1342. procedure TTestFieldTypes.TestIntParamQuery;
  1343. begin
  1344. TestXXParamQuery(ftInteger,'INT',testIntValuesCount);
  1345. end;
  1346. procedure TTestFieldTypes.TestLargeIntParamQuery;
  1347. begin
  1348. TestXXParamQuery(ftLargeInt,FieldtypeDefinitions[ftLargeInt],testValuesCount);
  1349. end;
  1350. procedure TTestFieldTypes.TestFmtBCDParamQuery;
  1351. begin
  1352. TestXXParamQuery(ftFMTBcd, FieldtypeDefinitions[ftFMTBcd], testValuesCount, testFmtBCDValues);
  1353. end;
  1354. procedure TTestFieldTypes.TestFmtBCDParamQuery2;
  1355. begin
  1356. // This test tests FmtBCD params with smaller precision, which fits into INT32
  1357. // TestFmtBCDParamQuery tests FmtBCD params with bigger precision, which fits into INT64
  1358. TestXXParamQuery(ftFMTBcd, 'NUMERIC(9,5)', 2, ['1234','1234.56781']);
  1359. end;
  1360. procedure TTestFieldTypes.TestDateParamQuery;
  1361. begin
  1362. TestXXParamQuery(ftDate,FieldtypeDefinitions[ftDate],testDateValuesCount);
  1363. end;
  1364. procedure TTestFieldTypes.TestCrossStringDateParam;
  1365. begin
  1366. TestXXParamQuery(ftDate,FieldtypeDefinitions[ftDate],testDateValuesCount,[],True);
  1367. end;
  1368. procedure TTestFieldTypes.TestTimeParamQuery;
  1369. begin
  1370. TestXXParamQuery(ftTime,FieldtypeDefinitions[ftTime],testValuesCount);
  1371. end;
  1372. procedure TTestFieldTypes.TestDateTimeParamQuery;
  1373. begin
  1374. TestXXParamQuery(ftDateTime,FieldtypeDefinitions[ftDateTime],testValuesCount);
  1375. end;
  1376. procedure TTestFieldTypes.TestFloatParamQuery;
  1377. begin
  1378. TestXXParamQuery(ftFloat,FieldtypeDefinitions[ftFloat],testFloatValuesCount);
  1379. end;
  1380. procedure TTestFieldTypes.TestCurrencyParamQuery;
  1381. begin
  1382. TestXXParamQuery(ftCurrency,FieldtypeDefinitions[ftCurrency],testValuesCount);
  1383. end;
  1384. procedure TTestFieldTypes.TestBCDParamQuery;
  1385. begin
  1386. TestXXParamQuery(ftBCD,'NUMERIC(10,4)',testBCDValuesCount);
  1387. end;
  1388. procedure TTestFieldTypes.TestBytesParamQuery;
  1389. begin
  1390. TestXXParamQuery(ftBytes, FieldtypeDefinitions[ftBytes], testBytesValuesCount, [], True);
  1391. end;
  1392. procedure TTestFieldTypes.TestVarBytesParamQuery;
  1393. begin
  1394. TestXXParamQuery(ftVarBytes, FieldtypeDefinitions[ftVarBytes], testVarBytesValuesCount, [], not(SQLServerType in [ssMSSQL, ssSybase]));
  1395. end;
  1396. procedure TTestFieldTypes.TestBooleanParamQuery;
  1397. begin
  1398. TestXXParamQuery(ftBoolean, FieldtypeDefinitions[ftBoolean], testValuesCount);
  1399. end;
  1400. procedure TTestFieldTypes.TestBlobParamQuery;
  1401. begin
  1402. TestXXParamQuery(ftBlob, FieldtypeDefinitions[ftBlob], testBlobValuesCount);
  1403. end;
  1404. procedure TTestFieldTypes.TestLongWordParamQuery;
  1405. begin
  1406. TestXXParamQuery(ftLongWord, FieldtypeDefinitions[ftLongWord], testValuesCount);
  1407. end;
  1408. procedure TTestFieldTypes.TestStringParamQuery;
  1409. begin
  1410. TestXXParamQuery(ftString,'VARCHAR(10)',testValuesCount);
  1411. end;
  1412. procedure TTestFieldTypes.TestFixedStringParamQuery;
  1413. begin
  1414. TestXXParamQuery(ftFixedChar,'CHAR(10)',testValuesCount);
  1415. end;
  1416. procedure TTestFieldTypes.TestXXParamQuery(ADataType : TFieldType; ASQLTypeDecl : string;
  1417. ParamValuesCount : integer);
  1418. begin
  1419. TestXXParamQuery(ADataType, ASQLTypeDecl, ParamValuesCount, [], False);
  1420. end;
  1421. procedure TTestFieldTypes.TestXXParamQuery(ADataType : TFieldType; ASQLTypeDecl : string;
  1422. ParamValuesCount : integer; const ParamValues: array of string; Cross : boolean = False);
  1423. var i : integer;
  1424. begin
  1425. if ASQLTypeDecl = '' then
  1426. Ignore('Fields of the type ' + FieldTypeNames[ADatatype] + ' are not supported by this sqldb-connection type');
  1427. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (ID INT, FIELD1 '+ASQLTypeDecl+')');
  1428. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1429. TSQLDBConnector(DBConnector).CommitDDL;
  1430. with TSQLDBConnector(DBConnector).Query do
  1431. begin
  1432. sql.clear;
  1433. sql.append('insert into FPDEV2 (ID,FIELD1) values (:id,:field1)');
  1434. // There is no Param.AsFixedChar, so the datatype has to be set manually
  1435. if ADataType=ftFixedChar then
  1436. Params.ParamByName('field1').DataType := ftFixedChar;
  1437. for i := 0 to ParamValuesCount-1 do
  1438. begin
  1439. Params.ParamByName('id').AsInteger := i;
  1440. case ADataType of
  1441. ftSmallInt: Params.ParamByName('field1').AsSmallInt := testSmallIntValues[i];
  1442. ftInteger : Params.ParamByName('field1').AsInteger := testIntValues[i];
  1443. ftLargeInt: Params.ParamByName('field1').AsLargeInt := testLargeIntValues[i];
  1444. ftBoolean : Params.ParamByName('field1').AsBoolean := testBooleanValues[i];
  1445. ftFloat : Params.ParamByName('field1').AsFloat := testFloatValues[i];
  1446. ftCurrency: Params.ParamByName('field1').AsCurrency:= testCurrencyValues[i];
  1447. ftBCD : Params.ParamByName('field1').AsBCD := testBCDValues[i];
  1448. ftFixedChar,
  1449. ftString : Params.ParamByName('field1').AsString := testValues[ADataType,i];
  1450. ftTime : Params.ParamByName('field1').AsTime := TimeStringToDateTime(testTimeValues[i]);
  1451. ftDate : if cross then
  1452. Params.ParamByName('field1').AsString:= testDateValues[i]
  1453. else
  1454. Params.ParamByName('field1').AsDate := StrToDate(testDateValues[i],'yyyy/mm/dd','-');
  1455. ftDateTime: Params.ParamByName('field1').AsDateTime := StrToDateTime(testValues[ADataType,i], DBConnector.FormatSettings);
  1456. ftFMTBcd : Params.ParamByName('field1').AsFMTBCD := StrToBCD(ParamValues[i], DBConnector.FormatSettings);
  1457. ftBlob : Params.ParamByName('field1').AsBlob := BytesOf(testBlobValues[i]);
  1458. ftLongWord: Params.ParamByName('field1').AsLongWord := testLongWordValues[i];
  1459. ftBytes : if cross then
  1460. Params.ParamByName('field1').Value := StringToByteArray(testBytesValues[i])
  1461. else
  1462. Params.ParamByName('field1').AsBytes := BytesOf(testBytesValues[i]);
  1463. ftVarBytes: if cross then
  1464. Params.ParamByName('field1').AsString := testBytesValues[i]
  1465. else
  1466. Params.ParamByName('field1').AsBytes := BytesOf(testBytesValues[i]);
  1467. else
  1468. AssertTrue('no test for paramtype available',False);
  1469. end;
  1470. ExecSQL;
  1471. end;
  1472. // test NULL parameter value
  1473. Params.ParamByName('id').AsInteger := ParamValuesCount;
  1474. Params.ParamByName('field1').Clear;
  1475. ExecSQL;
  1476. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1477. sql.clear;
  1478. sql.append('select * from FPDEV2 order by ID');
  1479. open;
  1480. for i := 0 to ParamValuesCount-1 do
  1481. begin
  1482. AssertEquals(i,FieldByName('ID').AsInteger);
  1483. case ADataType of
  1484. ftSmallInt : AssertEquals(testSmallIntValues[i],FieldByName('FIELD1').AsInteger);
  1485. ftInteger : AssertEquals(testIntValues[i],FieldByName('FIELD1').AsInteger);
  1486. ftLargeInt : AssertEquals(testLargeIntValues[i],FieldByName('FIELD1').AsLargeInt);
  1487. ftBoolean : AssertEquals(testBooleanValues[i],FieldByName('FIELD1').AsBoolean);
  1488. ftFloat : AssertEquals(testFloatValues[i],FieldByName('FIELD1').AsFloat);
  1489. ftCurrency : AssertEquals(testCurrencyValues[i],FieldByName('FIELD1').AsFloat,0); // TCurrencyField uses double data type (not currency) to store values!
  1490. ftBCD : AssertEquals(testBCDValues[i],FieldByName('FIELD1').AsCurrency);
  1491. ftFixedChar : AssertEquals(PadRight(testStringValues[i],10),FieldByName('FIELD1').AsString);
  1492. ftString : AssertEquals(testStringValues[i],FieldByName('FIELD1').AsString);
  1493. ftTime : AssertEquals(testTimeValues[i],DateTimeToTimeString(FieldByName('FIELD1').AsDateTime));
  1494. ftDate : AssertEquals(testDateValues[i],DateTimeToStr(FieldByName('FIELD1').AsDateTime, DBConnector.FormatSettings));
  1495. ftDateTime : AssertEquals(testValues[ADataType,i], DateTimeToStr(FieldByName('FIELD1').AsDateTime, DBConnector.FormatSettings));
  1496. ftFMTBcd : AssertEquals(ParamValues[i], BCDToStr(FieldByName('FIELD1').AsBCD, DBConnector.FormatSettings));
  1497. ftBlob : AssertEquals(testBlobValues[i], FieldByName('FIELD1').AsString);
  1498. ftLongWord : AssertEquals(testLongWordValues[i], FieldByName('FIELD1').AsLongWord);
  1499. ftVarBytes,
  1500. ftBytes : AssertEquals(testBytesValues[i], shortstring(FieldByName('FIELD1').AsString));
  1501. else
  1502. AssertTrue('no test for paramtype available',False);
  1503. end;
  1504. AssertEquals('IsNull', False, FieldByName('FIELD1').IsNull);
  1505. Next;
  1506. end;
  1507. AssertTrue('Expected IsNull', FieldByName('FIELD1').IsNull);
  1508. AssertTrue('Expected Null Variant', VarIsNull(FieldByName('FIELD1').AsVariant));
  1509. close;
  1510. end;
  1511. TSQLDBConnector(DBConnector).Transaction.CommitRetaining;
  1512. end;
  1513. procedure TTestFieldTypes.TestSetBlobAsParam(asWhat: integer);
  1514. var i: integer;
  1515. begin
  1516. CreateTableWithFieldType(ftBlob,FieldtypeDefinitions[ftBlob]);
  1517. TestFieldDeclaration(ftBlob,0);
  1518. with TSQLDBConnector(DBConnector).Query do
  1519. begin
  1520. SQL.Text := 'insert into FPDEV2 (FT) values (:BlobParam)';
  1521. for i:=0 to testBlobValuesCount - 1 do
  1522. begin
  1523. case asWhat of
  1524. 0: Params.ParamByName('blobParam').AsMemo := TestBlobValues[i];
  1525. 1: Params.ParamByName('blobParam').AsBlob := BytesOf(TestBlobValues[i]);
  1526. 2: Params.ParamByName('blobParam').AsString := TestBlobValues[i];
  1527. end;
  1528. ExecSQL;
  1529. end;
  1530. Params.ParamByName('blobParam').Clear;
  1531. ExecSQL;
  1532. SQL.Text := 'select FT from FPDEV2';
  1533. Open;
  1534. for i:=0 to testBlobValuesCount - 1 do
  1535. begin
  1536. AssertEquals(TestBlobValues[i], Fields[0].AsString);
  1537. Next;
  1538. end;
  1539. AssertTrue(Fields[0].IsNull);
  1540. Close;
  1541. end;
  1542. end;
  1543. procedure TTestFieldTypes.TestSetBlobAsMemoParam;
  1544. begin
  1545. // Firebird/Interbase ODBC driver : if parameter of ValueType=SQL_C_CHAR is bound to BLOB column
  1546. // driver interprets character data as hexadecimal string and performs conversion ('FF10'=#255#16)
  1547. TestSetBlobAsParam(0);
  1548. end;
  1549. procedure TTestFieldTypes.TestSetBlobAsBlobParam;
  1550. begin
  1551. TestSetBlobAsParam(1);
  1552. end;
  1553. procedure TTestFieldTypes.TestSetBlobAsStringParam;
  1554. begin
  1555. TestSetBlobAsParam(2);
  1556. end;
  1557. procedure TTestFieldTypes.Test11Params;
  1558. var i : integer;
  1559. begin
  1560. with TSQLDBConnector(dbconnector) do
  1561. begin
  1562. 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)');
  1563. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1564. TSQLDBConnector(DBConnector).CommitDDL;
  1565. Query.sql.Text := 'insert into FPDEV2 values(:id1,:id2,:id3,:id4,:id5,:id6,:id7,:id8,:id9,:id10,:id11)';
  1566. for i := 0 to 10 do
  1567. query.params[i].asinteger := 1;
  1568. query.ExecSQL;
  1569. query.sql.text := 'select * from FPDEV2';
  1570. query.open;
  1571. for i := 0 to 10 do
  1572. AssertEquals(1,query.fields[i].asinteger);
  1573. query.close;
  1574. end;
  1575. end;
  1576. procedure TTestFieldTypes.TestCircularParams;
  1577. begin
  1578. with TSQLDBConnector(dbconnector) do
  1579. begin
  1580. Connection.ExecuteDirect('create table FPDEV2 (id1 int, id2 int,vchar varchar(10))');
  1581. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1582. TSQLDBConnector(DBConnector).CommitDDL;
  1583. Query.sql.Text := 'insert into FPDEV2 values(:id1,:id2,:vchar)';
  1584. query.params[0].asinteger := 1;
  1585. query.params[1].asinteger := 1;
  1586. query.params[2].asstring := '$1 :id2 $';
  1587. query.ExecSQL;
  1588. query.sql.text := 'select * from FPDEV2';
  1589. query.open;
  1590. AssertEquals(1,query.fields[0].asinteger);
  1591. AssertEquals(1,query.fields[1].asinteger);
  1592. AssertEquals('$1 :id2 $',query.fields[2].AsString);
  1593. query.close;
  1594. end;
  1595. end;
  1596. procedure TTestFieldTypes.TestNonNullableParams;
  1597. var ASQLQuery : TSQLQuery;
  1598. Passed: Boolean;
  1599. begin
  1600. // Check for an exception when a null value is stored into a non-nullable
  1601. // field using a parameter
  1602. // There was a bug in IBConnection so that in this case the last used value
  1603. // for the parameter was used.
  1604. // To make sure that any changes are cancelled in the case the test fails
  1605. TSQLDBConnector(DBConnector).GetNDataset(True,1);
  1606. ASQLQuery := TSQLDBConnector(DBConnector).Query;
  1607. ASQLQuery.SQL.Text := 'update fpdev set ID=:ID1 where id = :ID2';
  1608. ASQLQuery.Params[0].Clear;
  1609. ASQLQuery.Params[1].AsInteger := 1;
  1610. AssertTrue(ASQLQuery.Params[0].IsNull);
  1611. Passed := False;
  1612. try
  1613. ASQLQuery.ExecSQL;
  1614. except
  1615. on E: Exception do
  1616. if E.ClassType.InheritsFrom(EDatabaseError) then
  1617. Passed := True;
  1618. end;
  1619. AssertTrue(Passed);
  1620. end;
  1621. procedure TTestFieldTypes.TestParametersAndDates;
  1622. // See bug 7205
  1623. var ADateStr : String;
  1624. begin
  1625. if not(SQLServerType in [ssPostgreSQL, ssOracle]) then
  1626. Ignore('This test does not apply to this sqldb connection type, since it doesn''t use semicolons for casts');
  1627. with TSQLDBConnector(DBConnector).Query do
  1628. begin
  1629. SQL.Clear;
  1630. sql.add('select now()::date as current_date where 1=1');
  1631. open;
  1632. first;
  1633. ADateStr:=fields[0].asstring; // return the correct date
  1634. // writeln(fields[0].asstring);
  1635. close;
  1636. sql.clear;
  1637. sql.add('select now()::date as current_date where cast(1 as integer) = :PARAM1');
  1638. params.parambyname('PARAM1').asinteger:= 1;
  1639. open;
  1640. first;
  1641. AssertEquals(ADateStr,fields[0].asstring); // return invalid date
  1642. // writeln(fields[0].asstring);
  1643. close;
  1644. end
  1645. end;
  1646. procedure TTestFieldTypes.TestInsertReturningQuery;
  1647. begin
  1648. if not(SQLServerType in [ssFirebird, ssOracle, ssPostgreSQL]) then Ignore(STestNotApplicable);
  1649. with TSQLDBConnector(DBConnector) do
  1650. begin
  1651. // This only works with databases that supports 'insert into .. returning'
  1652. // for example: PostgreSQL, Oracle, Firebird version 2.0 and up
  1653. CreateTableWithFieldType(ftInteger,'int');
  1654. Query.SQL.Text:='insert into FPDEV2 values(154) returning FT';
  1655. Query.Open;
  1656. AssertTrue(CompareText('FT',Query.Fields[0].FieldName)=0);
  1657. AssertEquals(154,Query.fields[0].AsInteger);
  1658. Query.Close;
  1659. end;
  1660. end;
  1661. procedure TTestFieldTypes.TestOpenStoredProc;
  1662. begin
  1663. with TSQLDBConnector(DBConnector) do
  1664. begin
  1665. case SQLServerType of
  1666. ssMySQL:
  1667. begin
  1668. Connection.ExecuteDirect('create procedure FPDEV_PROC() select 1 union select 2;');
  1669. Query.SQL.Text:='call FPDEV_PROC';
  1670. end;
  1671. ssFirebird, ssInterbase:
  1672. begin
  1673. Connection.ExecuteDirect('create procedure FPDEV_PROC returns (r integer) as begin r=1; end');
  1674. Query.SQL.Text:='execute procedure FPDEV_PROC';
  1675. end;
  1676. ssMSSQL, ssSybase:
  1677. begin
  1678. Connection.ExecuteDirect('create procedure FPDEV_PROC as select 1 union select 2;');
  1679. Query.SQL.Text:='execute FPDEV_PROC';
  1680. end;
  1681. else
  1682. begin
  1683. Ignore('This test does not apply to this sqldb connection type, since it does not support selectable stored procedures.');
  1684. Exit;
  1685. end;
  1686. end;
  1687. Transaction.CommitRetaining;
  1688. try
  1689. Query.Open;
  1690. AssertEquals(1, Query.Fields[0].AsInteger);
  1691. Query.Next;
  1692. if not(SQLServerType in [ssFirebird, ssInterbase]) then
  1693. begin
  1694. AssertFalse('Eof after 1st row', Query.Eof);
  1695. AssertEquals(2, Query.Fields[0].AsInteger);
  1696. Query.Next;
  1697. end;
  1698. AssertTrue('No Eof after last row', Query.Eof);
  1699. Query.Close;
  1700. finally
  1701. Connection.ExecuteDirect('drop procedure FPDEV_PROC');
  1702. Transaction.CommitRetaining;
  1703. end;
  1704. end;
  1705. end;
  1706. procedure TTestFieldTypes.TestOpenSpecialStatements;
  1707. const CTE_SELECT = 'WITH a AS (SELECT * FROM FPDEV) SELECT * FROM a';
  1708. type TTestStatements = array of string;
  1709. var statements: TTestStatements;
  1710. s: string;
  1711. begin
  1712. // tests non-select statements (other than "SELECT ..."), which return result-set
  1713. // at least one row must be returned
  1714. with TSQLDBConnector(DBConnector) do
  1715. begin
  1716. case SQLServerType of
  1717. ssSQLite:
  1718. statements := TTestStatements.Create('pragma table_info(FPDEV)');
  1719. ssFirebird:
  1720. statements := TTestStatements.Create(
  1721. CTE_SELECT (*FB 2.1*),
  1722. 'EXECUTE BLOCK RETURNS (U VARCHAR(255)) AS BEGIN SELECT rdb$get_context(''SYSTEM'',''CURRENT_USER'') FROM rdb$database INTO U; SUSPEND; END' (*FB 2.0*)
  1723. );
  1724. ssPostgreSQL:
  1725. statements := TTestStatements.Create(CTE_SELECT, 'EXPLAIN '+CTE_SELECT);
  1726. ssMSSQL:
  1727. statements := TTestStatements.Create(CTE_SELECT (*MS SQL 2005*));
  1728. ssMySQL:
  1729. statements := TTestStatements.Create(
  1730. 'check table FPDEV', // bug 14519
  1731. 'show tables from '+Connection.DatabaseName // bug 16842
  1732. )
  1733. else
  1734. Ignore(STestNotApplicable);
  1735. end;
  1736. for s in statements do
  1737. begin
  1738. Query.SQL.Text := s;
  1739. Query.Open;
  1740. AssertTrue(Query.FieldCount>0);
  1741. AssertFalse('Eof after open', Query.Eof);
  1742. Query.Next;
  1743. Query.Close;
  1744. end;
  1745. end;
  1746. end;
  1747. procedure TTestFieldTypes.TestErrorOnEmptyStatement;
  1748. var PassException : boolean;
  1749. begin
  1750. PassException:=False;
  1751. with TSQLDBConnector(DBConnector).Query do
  1752. begin
  1753. sql.Text := '';
  1754. try
  1755. Open;
  1756. except
  1757. on E:EDatabaseError do
  1758. if Pos(SErrNoStatement,E.Message) > 0 then
  1759. PassException := True;
  1760. end;
  1761. AssertTrue(PassException);
  1762. end;
  1763. end;
  1764. procedure TTestFieldTypes.TestExceptOnsecClose;
  1765. var passed : boolean;
  1766. begin
  1767. with TSQLDBConnector(DBConnector).Query do
  1768. begin
  1769. SQL.Clear;
  1770. SQL.Add('select * from FPDEV');
  1771. Open;
  1772. close;
  1773. SQL.Clear;
  1774. SQL.Add('select blaise from FPDEV');
  1775. passed := false;
  1776. try
  1777. open;
  1778. except
  1779. on E: Exception do
  1780. begin
  1781. passed := (E.ClassType.InheritsFrom(EDatabaseError))
  1782. end;
  1783. end;
  1784. AssertTrue(passed);
  1785. Close;
  1786. end;
  1787. end;
  1788. procedure TTestFieldTypes.TestServerFilter;
  1789. begin
  1790. // Tests SQLParser and ServerFilter
  1791. with TSQLDBConnector(DBConnector).Query do
  1792. begin
  1793. ServerFilter:='ID=21';
  1794. ServerFiltered:=true;
  1795. // tests parsing SELECT without WHERE
  1796. SQL.Text:='select * from FPDEV';
  1797. Open;
  1798. CheckTrue(CanModify, SQL.Text);
  1799. CheckEquals(1, RecordCount);
  1800. Close;
  1801. SQL.Text:='select *'#13'from FPDEV'#13'order by 1';
  1802. Open;
  1803. CheckTrue(CanModify, SQL.Text);
  1804. CheckEquals(1, RecordCount);
  1805. Close;
  1806. // tests parsing SELECT with simple WHERE
  1807. SQL.Text:='select *'#9'from FPDEV'#9'where NAME<>''''';
  1808. Open;
  1809. CheckTrue(CanModify, SQL.Text);
  1810. CheckEquals(1, RecordCount);
  1811. Close;
  1812. // tests parsing SELECT with simple WHERE followed by ORDER BY
  1813. SQL.Text:='select *'#10'from FPDEV'#10'where NAME>'''' order by 1';
  1814. Open;
  1815. CheckTrue(CanModify, SQL.Text);
  1816. CheckEquals(1, RecordCount);
  1817. Close;
  1818. // tests parsing of WHERE ... LIMIT
  1819. case SQLServerType of
  1820. ssFirebird, ssInterbase:
  1821. SQL.Text:='select first 1 NAME from FPDEV where NAME=''TestName21''';
  1822. ssMSSQL, ssSybase:
  1823. SQL.Text:='select top 1 NAME from FPDEV where NAME=''TestName21''';
  1824. else
  1825. SQL.Text:='select NAME from FPDEV where NAME=''TestName21'' limit 1';
  1826. end;
  1827. Open;
  1828. CheckTrue(CanModify, SQL.Text);
  1829. Close;
  1830. // tests parsing SELECT with table alias and embedded comments (MySQL requires space after -- )
  1831. SQL.Text:='/**/select * from/**/FPDEV as fp-- comment'#13'where(NAME>''TestName20'')/**/order by 1';
  1832. Open;
  1833. CheckTrue(CanModify, 'CanModify: '+SQL.Text);
  1834. CheckTrue(ServerIndexDefs.Count >= 1, 'ServerIndexDefs: '+SQL.Text); // is TableName extracted correctly? (MS SQL Server can automatically creates index)
  1835. Close;
  1836. // tests parsing SELECT with quoted identifiers (MySQL requires sql-mode=ANSI_QUOTES)
  1837. // The folding of unquoted names to lower case in PostgreSQL is incompatible with the SQL standard
  1838. SQL.Text:=IdentifierCase('SELECT"ID"FROM"FPDEV"ORDER BY"ID"');
  1839. Open;
  1840. CheckTrue(CanModify, SQL.Text);
  1841. Close;
  1842. // tests change of ServerFilter, while DataSet is opened and not all records were fetched
  1843. PacketRecords:=2;
  1844. ServerFilter:='ID>=1';
  1845. Open;
  1846. CheckEquals(1, FieldByName('ID').AsInteger);
  1847. ServerFilter:='ID>=21';
  1848. CheckEquals(21, FieldByName('ID').AsInteger);
  1849. Close;
  1850. end;
  1851. end;
  1852. procedure TTestFieldTypes.TestRowsAffected;
  1853. var Query2: TSQLQuery;
  1854. begin
  1855. with TSQLDBConnector(DBConnector) do
  1856. begin
  1857. Query2 := GetNDataset(0) as TSQLQuery;
  1858. CheckEquals(-1, Query.RowsAffected, 'Inactive dataset');
  1859. Connection.ExecuteDirect('create table FPDEV2 (' +
  1860. ' ID INT NOT NULL, ' +
  1861. ' NAME VARCHAR(250),' +
  1862. ' PRIMARY KEY (ID) )');
  1863. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  1864. TSQLDBConnector(DBConnector).CommitDDL;
  1865. Query.SQL.Text := 'insert into FPDEV2(ID,NAME) values (1,''test1'')';
  1866. Query.ExecSQL;
  1867. AssertEquals(1, Query.RowsAffected);
  1868. Query.SQL.Text := 'insert into FPDEV2(ID,NAME) values (2,''test2'')';
  1869. Query.ExecSQL;
  1870. AssertEquals(1, Query.RowsAffected);
  1871. Query.SQL.Text := 'update FPDEV2 set NAME=''NewTest''';
  1872. Query.ExecSQL;
  1873. AssertEquals(-1, Query2.RowsAffected);
  1874. Query2.SQL.Text := 'insert into FPDEV2 values(3,''test3'')';
  1875. Query2.ExecSQL;
  1876. AssertEquals(1, Query2.RowsAffected);
  1877. // tests, that RowsAffected is specific per query, not per connection
  1878. // i.e. that it doesn't return only RowsAffected of last query executed over connection
  1879. AssertEquals(2, Query.RowsAffected);
  1880. Query.SQL.Text := 'select * from FPDEV2';
  1881. Query.Open;
  1882. AssertTrue(Query.RowsAffected<>0); // It should return -1 or the number of selected rows.
  1883. Query.Close;
  1884. AssertTrue(Query.RowsAffected<>0); // It should return -1 or the same as the last time it was called.
  1885. Query.SQL.Text := 'delete from FPDEV2 where ID>0'; // sqlite doesn't count the RowsAffected if there is no where-clause
  1886. Query.ExecSQL;
  1887. AssertEquals(3, Query.RowsAffected);
  1888. Query.SQL.Text := 'delete from FPDEV2';
  1889. Query.ExecSQL;
  1890. AssertEquals(0, Query.RowsAffected);
  1891. end;
  1892. end;
  1893. procedure TTestFieldTypes.TestLocateNull;
  1894. var DS: TCustomBufDataset;
  1895. begin
  1896. ds := TSQLDBConnector(DBConnector).GetNDataset(true,5) as TCustomBufDataset;
  1897. with ds do
  1898. begin
  1899. open;
  1900. edit;
  1901. fieldbyname('name').Clear;
  1902. post;
  1903. next;
  1904. AssertFalse(Locate('name',VarArrayOf(['TestName1']),[]));
  1905. AssertTrue(Locate('name',VarArrayOf([Null]),[]));
  1906. AssertEquals(1,fieldbyname('ID').AsInteger);
  1907. end;
  1908. end;
  1909. procedure TTestFieldTypes.TestLocateOnMoreRecords;
  1910. var DS: TCustomBufDataset;
  1911. begin
  1912. with TSQLDBConnector(DBConnector) do
  1913. begin
  1914. ds := GetNDataset(true,30) as TCustomBufDataset;
  1915. with query do
  1916. begin
  1917. SQL.Text:='update FPDEV set NAME = null where ID<11;';
  1918. ExecSQL;
  1919. SQL.Text:='update FPDEV set NAME = null where (ID>11) and (ID<23);';
  1920. ExecSQL;
  1921. end;
  1922. with ds do
  1923. begin
  1924. Open;
  1925. // Must be exactly 11 to trigger bug/test
  1926. AssertTrue(Locate('name',VarArrayOf(['TestName11']),[]));
  1927. AssertEquals(11,fieldbyname('ID').AsInteger);
  1928. // Must be exactly 23 to trigger bug/test
  1929. AssertTrue(Locate('name',VarArrayOf(['TestName23']),[]));
  1930. AssertEquals(23,fieldbyname('ID').AsInteger);
  1931. end;
  1932. end;
  1933. end;
  1934. procedure TTestFieldTypes.TestRefresh;
  1935. var ADataset: TDataset;
  1936. i: integer;
  1937. AFldID, AFldName: TField;
  1938. begin
  1939. ADataset := TSQLDBConnector(DBConnector).GetNDataset(true,5);
  1940. Adataset.Open;
  1941. AFldId:=Adataset.Fields[0];
  1942. AFldName:=Adataset.Fields[1];
  1943. for i := 1 to 5 do
  1944. begin
  1945. AssertEquals(i, AFldID.AsInteger);
  1946. AssertEquals('TestName'+inttostr(i), AFldName.AsString);
  1947. ADataset.Next;
  1948. end;
  1949. ADataset.Next;
  1950. AssertTrue(ADataset.EOF);
  1951. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('update FPDEV set NAME=''test'' where ID=2');
  1952. ADataset.Refresh;
  1953. ADataset.First;
  1954. for i := 1 to 5 do
  1955. begin
  1956. AssertEquals('ID', i, AFldID.AsInteger);
  1957. if i = 2 then
  1958. AssertEquals('NAME', 'test', AFldName.AsString)
  1959. else
  1960. AssertEquals('NAME', 'TestName'+inttostr(i), AFldName.AsString);
  1961. ADataset.Next;
  1962. end;
  1963. ADataset.Next;
  1964. AssertTrue(ADataset.EOF);
  1965. end;
  1966. procedure TTestFieldTypes.TestTableNames;
  1967. var TableList : TStringList;
  1968. begin
  1969. TableList := TStringList.Create;
  1970. try
  1971. TSQLDBConnector(DBConnector).Connection.GetTableNames(TableList);
  1972. AssertTrue(TableList.IndexOf('fpdev')<>-1);
  1973. finally
  1974. TableList.Free;
  1975. end;
  1976. end;
  1977. procedure TTestFieldTypes.TestGetTables;
  1978. var TableNames : TStringList;
  1979. begin
  1980. with TSQLDBConnector(DBConnector) do
  1981. begin
  1982. TableNames := TStringList.Create;
  1983. try
  1984. Connection.GetTableNames(TableNames);
  1985. AssertTrue(TableNames.Count>0);
  1986. AssertTrue(TableNames.IndexOf('FPDEV')>-1);
  1987. AssertTrue(TableNames.IndexOf('FPDEV_FIELD')>-1);
  1988. finally
  1989. TableNames.Free;
  1990. end;
  1991. end;
  1992. end;
  1993. procedure TTestFieldTypes.TestFieldNames;
  1994. var FieldList : TStringList;
  1995. begin
  1996. FieldList := TStringList.Create;
  1997. try
  1998. TSQLDBConnector(DBConnector).Connection.GetFieldNames('fpdev',FieldList);
  1999. AssertTrue(FieldList.IndexOf('id')<>-1);
  2000. finally
  2001. FieldList.Free;
  2002. end;
  2003. end;
  2004. procedure TTestFieldTypes.TestGetFieldNames;
  2005. var FieldNames : TStringList;
  2006. begin
  2007. with TSQLDBConnector(DBConnector) do
  2008. begin
  2009. FieldNames := TStringList.Create;
  2010. try
  2011. if SQLConnType in MySQLConnTypes then
  2012. Connection.GetFieldNames('FPDEV',FieldNames)
  2013. else
  2014. Connection.GetFieldNames('fpDEv',FieldNames);
  2015. AssertEquals(2,FieldNames.Count);
  2016. AssertEquals('ID',UpperCase(FieldNames[0]));
  2017. AssertEquals('NAME',UpperCase(FieldNames[1]));
  2018. finally
  2019. FieldNames.Free;
  2020. end;
  2021. end;
  2022. end;
  2023. procedure TTestFieldTypes.TestUpdateIndexDefs;
  2024. var ds : TSQLQuery;
  2025. begin
  2026. // Firebird/Interbase ODBC driver returns for :
  2027. // SQLPrimaryKeys (PK_NAME): RDB$RELATION_CONSTRAINTS(RDB$CONSTRAINT_NAME)
  2028. // SQLStatistics (INDEX_NAME): RDB$INDICES(RDB$INDEX_NAME)
  2029. // these two names can differ (when PRIMARY KEY is created without giving constraint name),
  2030. // therefore two indexes may be created instead of one (see TODBCConnection.UpdateIndexDefs)
  2031. ds := DBConnector.GetNDataset(1) as TSQLQuery;
  2032. ds.Prepare;
  2033. ds.ServerIndexDefs.Update;
  2034. AssertEquals(1,ds.ServerIndexDefs.count);
  2035. AssertTrue(CompareText('ID',ds.ServerIndexDefs[0].Fields)=0);
  2036. Asserttrue(ds.ServerIndexDefs[0].Options=[ixPrimary,ixUnique]);
  2037. ds.ServerIndexDefs.Update;
  2038. AssertEquals(1,ds.ServerIndexDefs.count);
  2039. AssertTrue(CompareText('ID',ds.ServerIndexDefs[0].Fields)=0);
  2040. Asserttrue(ds.ServerIndexDefs[0].Options=[ixPrimary,ixUnique]);
  2041. end;
  2042. procedure TTestFieldTypes.TestMultipleFieldPKIndexDefs;
  2043. var ds : TSQLQuery;
  2044. begin
  2045. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('create table FPDEV2 (' +
  2046. ' ID1 INT NOT NULL, ' +
  2047. ' ID2 INT NOT NULL, ' +
  2048. ' NAME VARCHAR(50), ' +
  2049. ' PRIMARY KEY (ID1, ID2)' +
  2050. ') ');
  2051. // Firebird/Interbase need a commit after a DDL statement. Not necessary for the other connections
  2052. TSQLDBConnector(DBConnector).CommitDDL;
  2053. ds := TSQLDBConnector(DBConnector).Query;
  2054. ds.sql.Text:='select * from FPDEV2';
  2055. ds.Prepare;
  2056. ds.ServerIndexDefs.Update;
  2057. AssertEquals(1,ds.ServerIndexDefs.count);
  2058. AssertTrue(SameText('ID1;ID2',ds.ServerIndexDefs[0].Fields));
  2059. Asserttrue(ds.ServerIndexDefs[0].Options=[ixPrimary,ixUnique]);
  2060. end;
  2061. procedure TTestFieldTypes.TestGetIndexDefs;
  2062. var ds : TSQLQuery;
  2063. inddefs : TIndexDefs;
  2064. begin
  2065. ds := DBConnector.GetNDataset(1) as TSQLQuery;
  2066. ds.Open;
  2067. AssertEquals('ServerIndexDefs.Count', 1, ds.ServerIndexDefs.Count);
  2068. inddefs := HackedDataset(ds).GetIndexDefs(ds.ServerIndexDefs,[ixPrimary]);
  2069. AssertEquals('ixPrimary', 1, inddefs.count);
  2070. AssertTrue(CompareText('ID',inddefs[0].Fields)=0);
  2071. AssertTrue(inddefs[0].Options=[ixPrimary,ixUnique]);
  2072. inddefs.Free;
  2073. inddefs := HackedDataset(ds).GetIndexDefs(ds.ServerIndexDefs,[ixPrimary,ixUnique]);
  2074. AssertEquals('ixPrimary,ixUnique', 1, inddefs.count);
  2075. AssertTrue(CompareText('ID',inddefs[0].Fields)=0);
  2076. AssertTrue(inddefs[0].Options=[ixPrimary,ixUnique]);
  2077. inddefs.Free;
  2078. inddefs := HackedDataset(ds).GetIndexDefs(ds.ServerIndexDefs,[ixDescending]);
  2079. AssertEquals('ixDescending', 0, inddefs.count);
  2080. inddefs.Free;
  2081. end;
  2082. procedure TTestFieldTypes.TestEmptyUpdateQuery;
  2083. begin
  2084. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('update FPDEV set NAME=''nothing'' where (1=0)');
  2085. end;
  2086. procedure TTestFieldTypes.TestTemporaryTable;
  2087. begin
  2088. // Tests rev.6481: "Do not use a new connection for every statement that is executed";
  2089. if SQLServerType in [ssMSSQL, ssSybase] then Ignore('This test does not apply to this sqldb connection type, since it doesn''t support temporary tables');
  2090. with TSQLDBConnector(DBConnector).Query do
  2091. begin
  2092. SQL.Clear;
  2093. if SQLServerType in [ssFirebird, ssInterbase, ssOracle] then
  2094. // Global temporary table: introduced in Firebird 2.1
  2095. // has persistent metadata; data is per transaction (default) or per connection
  2096. SQL.Add('CREATE GLOBAL TEMPORARY TABLE FPDEV_TEMP (id int)')
  2097. else
  2098. SQL.Add('CREATE TEMPORARY TABLE FPDEV_TEMP (id int)');
  2099. ExecSQL;
  2100. try
  2101. // Firebird/Interbase needs a commit after DDL:
  2102. TSQLDBConnector(DBConnector).CommitDDL;
  2103. SQL.Text := 'INSERT INTO FPDEV_TEMP(id) values (5)';
  2104. ExecSQL;
  2105. SQL.Text := 'SELECT * FROM FPDEV_TEMP';
  2106. Open;
  2107. AssertEquals(5, Fields[0].AsInteger);
  2108. Close;
  2109. finally
  2110. // For Firebird/Interbase, we need to explicitly delete the table as well (it's active within the transaction)
  2111. if SQLServerType in [ssFirebird, ssInterbase, ssOracle] then
  2112. begin
  2113. SQL.Text := 'DROP TABLE FPDEV_TEMP';
  2114. ExecSQL;
  2115. TSQLDBConnector(DBConnector).CommitDDL;
  2116. end;
  2117. end;
  2118. end;
  2119. end;
  2120. procedure TTestFieldTypes.TestQueryAfterReconnect;
  2121. var DS: TDataset;
  2122. begin
  2123. ds := DBConnector.GetNDataset(true,5);
  2124. with ds do
  2125. begin
  2126. open;
  2127. close;
  2128. TSQLDBConnector(DBConnector).Connection.Close;
  2129. TSQLDBConnector(DBConnector).Connection.Open;
  2130. open;
  2131. close;
  2132. end;
  2133. end;
  2134. procedure TTestFieldTypes.TestStringsReplace;
  2135. begin
  2136. AssertEquals('dit is een string',StringsReplace('dit was een string',['was'],['is'],[]));
  2137. AssertEquals('dit is een string was een string',StringsReplace('dit was een string was een string',['was'],['is'],[]));
  2138. AssertEquals('dit is een string is een string',StringsReplace('dit was een string was een string',['was'],['is'],[rfReplaceAll]));
  2139. AssertEquals('dit is een char is een char',StringsReplace('dit was een string was een string',['was','string'],['is','char'],[rfReplaceAll]));
  2140. AssertEquals('dit is een string was een string',StringsReplace('dit was een string was een string',['string','was'],['char','is'],[]));
  2141. AssertEquals('dit is een char is een strin',StringsReplace('dit was een string was een strin',['string','was'],['char','is'],[rfReplaceAll]));
  2142. AssertEquals('dit Was een char is een char',StringsReplace('dit Was een string was een string',['was','string'],['is','char'],[rfReplaceAll]));
  2143. AssertEquals('dit wAs een char is een char',StringsReplace('dit wAs een string was een string',['was','string'],['is','char'],[rfReplaceAll]));
  2144. AssertEquals('dit is een char is een char',StringsReplace('dit Was een sTring was een string',['was','string'],['is','char'],[rfReplaceAll,rfIgnoreCase]));
  2145. AssertEquals('dit is een char is een char',StringsReplace('dit wAs een STRING was een string',['was','string'],['is','char'],[rfReplaceAll,rfIgnoreCase]));
  2146. AssertEquals('dit was een si was een sa',StringsReplace('dit was een string was een straat',['straat','string'],['sa','si'],[rfReplaceAll]));
  2147. AssertEquals('dit was een si was een sa',StringsReplace('dit was een string was een straat',['string','straat'],['si','sa'],[rfReplaceAll]));
  2148. AssertEquals('dit was een sing was een saat',StringsReplace('dit was een string was een straat',['str','string'],['s','si'],[rfReplaceAll]));
  2149. AssertEquals('dit was een si was een saat',StringsReplace('dit was een string was een straat',['string','str'],['si','s'],[rfReplaceAll]));
  2150. AssertEquals('dit was een string was een string',StringsReplace('dit was een string was een string',[''],['is'],[rfReplaceAll]));
  2151. AssertEquals('dit een string een string',StringsReplace('dit was een string was een string',['was'],[''],[rfReplaceAll]));
  2152. end;
  2153. procedure TTestFieldTypes.SetUp;
  2154. begin
  2155. InitialiseDBConnector;
  2156. DBConnector.StartTest(TestName);
  2157. end;
  2158. procedure TTestFieldTypes.TearDown;
  2159. begin
  2160. DBConnector.StopTest(TestName);
  2161. if assigned(DBConnector) then
  2162. TSQLDBConnector(DBConnector).Transaction.Rollback;
  2163. FreeDBConnector;
  2164. end;
  2165. procedure TTestFieldTypes.RunTest;
  2166. begin
  2167. // if (SQLConnType in TSQLConnType) then
  2168. inherited RunTest;
  2169. end;
  2170. procedure TTestFieldTypes.TestSQLite3AlwaysUseBigint;
  2171. var
  2172. I : byte;
  2173. begin
  2174. If SQLConnType<>sqlite3 then
  2175. Ignore('Test only for SQLite');
  2176. TSQLDBConnector(DBConnector).Connection.Params.Values['AlwaysUseBigint']:='1';
  2177. CreateTableWithFieldType(ftInteger,'INT');
  2178. TestFieldDeclaration(ftLargeInt,8);
  2179. for i := 0 to testIntValuesCount-1 do
  2180. TSQLDBConnector(DBConnector).Connection.ExecuteDirect('insert into FPDEV2 (FT) values (' + inttostr(testIntValues[i]) + ')');
  2181. with TSQLDBConnector(DBConnector).Query do
  2182. begin
  2183. Open;
  2184. for i := 0 to testIntValuesCount-1 do
  2185. begin
  2186. AssertEquals(testIntValues[i],fields[0].AsLargeInt);
  2187. Next;
  2188. end;
  2189. close;
  2190. end;
  2191. end;
  2192. initialization
  2193. // Only test if using sqldb
  2194. if uppercase(dbconnectorname)='SQL' then
  2195. RegisterTest(TTestFieldTypes);
  2196. end.