2 * Copyright (C) 2005 Mike McCormack for CodeWeavers
4 * A test program for MSI database files.
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
31 #include "wine/test.h"
33 static const char *msifile = "winetest.msi";
34 static const char *msifile2 = "winetst2.msi";
35 static const char *mstfile = "winetst.mst";
37 static void test_msidatabase(void)
39 MSIHANDLE hdb = 0, hdb2 = 0;
44 res = MsiOpenDatabase( msifile, msifile2, &hdb );
45 ok( res == ERROR_OPEN_FAILED, "expected failure\n");
47 res = MsiOpenDatabase( msifile, (LPSTR) 0xff, &hdb );
48 ok( res == ERROR_INVALID_PARAMETER, "expected failure\n");
50 res = MsiCloseHandle( hdb );
51 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
53 /* create an empty database */
54 res = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb );
55 ok( res == ERROR_SUCCESS , "Failed to create database\n" );
57 res = MsiDatabaseCommit( hdb );
58 ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
60 ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile ), "database should exist\n");
62 res = MsiCloseHandle( hdb );
63 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
64 res = MsiOpenDatabase( msifile, msifile2, &hdb2 );
65 ok( res == ERROR_SUCCESS , "Failed to open database\n" );
67 ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile2 ), "database should exist\n");
69 res = MsiDatabaseCommit( hdb2 );
70 ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
72 res = MsiCloseHandle( hdb2 );
73 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
75 res = MsiOpenDatabase( msifile, msifile2, &hdb2 );
76 ok( res == ERROR_SUCCESS , "Failed to open database\n" );
78 res = MsiCloseHandle( hdb2 );
79 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
81 ok( INVALID_FILE_ATTRIBUTES == GetFileAttributes( msifile2 ), "uncommitted database should not exist\n");
83 res = MsiOpenDatabase( msifile, msifile2, &hdb2 );
84 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
86 res = MsiDatabaseCommit( hdb2 );
87 ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
89 res = MsiCloseHandle( hdb2 );
90 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
92 ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile2 ), "committed database should exist\n");
94 res = MsiOpenDatabase( msifile, MSIDBOPEN_READONLY, &hdb );
95 ok( res == ERROR_SUCCESS , "Failed to open database\n" );
97 res = MsiCloseHandle( hdb );
98 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
100 res = MsiOpenDatabase( msifile, MSIDBOPEN_DIRECT, &hdb );
101 ok( res == ERROR_SUCCESS , "Failed to open database\n" );
103 res = MsiCloseHandle( hdb );
104 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
106 res = MsiOpenDatabase( msifile, MSIDBOPEN_TRANSACT, &hdb );
107 ok( res == ERROR_SUCCESS , "Failed to open database\n" );
109 res = MsiCloseHandle( hdb );
110 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
111 ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile ), "database should exist\n");
113 /* MSIDBOPEN_CREATE deletes the database if MsiCommitDatabase isn't called */
114 res = MsiOpenDatabase( msifile, MSIDBOPEN_CREATE, &hdb );
115 ok( res == ERROR_SUCCESS , "Failed to open database\n" );
117 ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile ), "database should exist\n");
119 res = MsiCloseHandle( hdb );
120 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
122 ok( INVALID_FILE_ATTRIBUTES == GetFileAttributes( msifile ), "database should exist\n");
124 res = MsiOpenDatabase( msifile, MSIDBOPEN_CREATE, &hdb );
125 ok( res == ERROR_SUCCESS , "Failed to open database\n" );
127 res = MsiDatabaseCommit( hdb );
128 ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
130 ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile ), "database should exist\n");
132 res = MsiCloseHandle( hdb );
133 ok( res == ERROR_SUCCESS , "Failed to close database\n" );
135 res = DeleteFile( msifile2 );
136 ok( res == TRUE, "Failed to delete database\n" );
138 res = DeleteFile( msifile );
139 ok( res == TRUE, "Failed to delete database\n" );
142 static UINT do_query(MSIHANDLE hdb, const char *query, MSIHANDLE *phrec)
147 /* open a select query */
148 r = MsiDatabaseOpenView(hdb, query, &hview);
149 if (r != ERROR_SUCCESS)
151 r = MsiViewExecute(hview, 0);
152 if (r != ERROR_SUCCESS)
154 ret = MsiViewFetch(hview, phrec);
155 r = MsiViewClose(hview);
156 if (r != ERROR_SUCCESS)
158 r = MsiCloseHandle(hview);
159 if (r != ERROR_SUCCESS)
164 static UINT run_query( MSIHANDLE hdb, MSIHANDLE hrec, const char *query )
169 r = MsiDatabaseOpenView(hdb, query, &hview);
170 if( r != ERROR_SUCCESS )
173 r = MsiViewExecute(hview, hrec);
174 if( r == ERROR_SUCCESS )
175 r = MsiViewClose(hview);
176 MsiCloseHandle(hview);
180 static UINT create_component_table( MSIHANDLE hdb )
182 return run_query( hdb, 0,
183 "CREATE TABLE `Component` ( "
184 "`Component` CHAR(72) NOT NULL, "
185 "`ComponentId` CHAR(38), "
186 "`Directory_` CHAR(72) NOT NULL, "
187 "`Attributes` SHORT NOT NULL, "
188 "`Condition` CHAR(255), "
189 "`KeyPath` CHAR(72) "
190 "PRIMARY KEY `Component`)" );
193 static UINT create_feature_components_table( MSIHANDLE hdb )
195 return run_query( hdb, 0,
196 "CREATE TABLE `FeatureComponents` ( "
197 "`Feature_` CHAR(38) NOT NULL, "
198 "`Component_` CHAR(72) NOT NULL "
199 "PRIMARY KEY `Feature_`, `Component_` )" );
202 static UINT create_std_dlls_table( MSIHANDLE hdb )
204 return run_query( hdb, 0,
205 "CREATE TABLE `StdDlls` ( "
206 "`File` CHAR(255) NOT NULL, "
207 "`Binary_` CHAR(72) NOT NULL "
208 "PRIMARY KEY `File` )" );
211 static UINT create_binary_table( MSIHANDLE hdb )
213 return run_query( hdb, 0,
214 "CREATE TABLE `Binary` ( "
215 "`Name` CHAR(72) NOT NULL, "
216 "`Data` CHAR(72) NOT NULL "
217 "PRIMARY KEY `Name` )" );
220 static UINT add_component_entry( MSIHANDLE hdb, const char *values )
222 char insert[] = "INSERT INTO `Component` "
223 "(`Component`, `ComponentId`, `Directory_`, `Attributes`, `Condition`, `KeyPath`) "
228 sz = strlen(values) + sizeof insert;
229 query = HeapAlloc(GetProcessHeap(),0,sz);
230 sprintf(query,insert,values);
231 r = run_query( hdb, 0, query );
232 HeapFree(GetProcessHeap(), 0, query);
236 static UINT add_feature_components_entry( MSIHANDLE hdb, const char *values )
238 char insert[] = "INSERT INTO `FeatureComponents` "
239 "(`Feature_`, `Component_`) "
244 sz = strlen(values) + sizeof insert;
245 query = HeapAlloc(GetProcessHeap(),0,sz);
246 sprintf(query,insert,values);
247 r = run_query( hdb, 0, query );
248 HeapFree(GetProcessHeap(), 0, query);
252 static UINT add_std_dlls_entry( MSIHANDLE hdb, const char *values )
254 char insert[] = "INSERT INTO `StdDlls` "
255 "(`File`, `Binary_`) "
260 sz = strlen(values) + sizeof insert;
261 query = HeapAlloc(GetProcessHeap(),0,sz);
262 sprintf(query,insert,values);
263 r = run_query( hdb, 0, query );
264 HeapFree(GetProcessHeap(), 0, query);
268 static UINT add_binary_entry( MSIHANDLE hdb, const char *values )
270 char insert[] = "INSERT INTO `Binary` "
276 sz = strlen(values) + sizeof insert;
277 query = HeapAlloc(GetProcessHeap(),0,sz);
278 sprintf(query,insert,values);
279 r = run_query( hdb, 0, query );
280 HeapFree(GetProcessHeap(), 0, query);
284 static void test_msiinsert(void)
286 MSIHANDLE hdb = 0, hview = 0, hrec = 0;
294 /* just MsiOpenDatabase should not create a file */
295 r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
296 ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
299 query = "CREATE TABLE `phone` ( "
300 "`id` INT, `name` CHAR(32), `number` CHAR(32) "
302 r = MsiDatabaseOpenView(hdb, query, &hview);
303 ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
304 r = MsiViewExecute(hview, 0);
305 ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
306 r = MsiViewClose(hview);
307 ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
308 r = MsiCloseHandle(hview);
309 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
311 /* insert a value into it */
312 query = "INSERT INTO `phone` ( `id`, `name`, `number` )"
313 "VALUES('1', 'Abe', '8675309')";
314 r = MsiDatabaseOpenView(hdb, query, &hview);
315 ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
316 r = MsiViewExecute(hview, 0);
317 ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
318 r = MsiViewClose(hview);
319 ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
320 r = MsiCloseHandle(hview);
321 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
323 query = "SELECT * FROM `phone` WHERE `id` = 1";
324 r = do_query(hdb, query, &hrec);
325 ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
327 /* check the record contains what we put in it */
328 r = MsiRecordGetFieldCount(hrec);
329 ok(r == 3, "record count wrong\n");
332 r = MsiRecordIsNull(hrec, 0);
333 ok(r == FALSE, "field 0 not null\n");
336 r = MsiRecordGetInteger(hrec, 1);
337 ok(r == 1, "field 1 contents wrong\n");
339 r = MsiRecordGetString(hrec, 2, buf, &sz);
340 ok(r == ERROR_SUCCESS, "field 2 content fetch failed\n");
341 ok(!strcmp(buf,"Abe"), "field 2 content incorrect\n");
343 r = MsiRecordGetString(hrec, 3, buf, &sz);
344 ok(r == ERROR_SUCCESS, "field 3 content fetch failed\n");
345 ok(!strcmp(buf,"8675309"), "field 3 content incorrect\n");
347 r = MsiCloseHandle(hrec);
348 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
350 /* open a select query */
352 query = "SELECT * FROM `phone` WHERE `id` >= 10";
353 r = do_query(hdb, query, &hrec);
354 ok(r == ERROR_NO_MORE_ITEMS, "MsiViewFetch failed\n");
355 ok(hrec == 0, "hrec should be null\n");
357 r = MsiCloseHandle(hrec);
358 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
360 query = "SELECT * FROM `phone` WHERE `id` < 0";
361 r = do_query(hdb, query, &hrec);
362 ok(r == ERROR_NO_MORE_ITEMS, "MsiViewFetch failed\n");
364 query = "SELECT * FROM `phone` WHERE `id` <= 0";
365 r = do_query(hdb, query, &hrec);
366 ok(r == ERROR_NO_MORE_ITEMS, "MsiViewFetch failed\n");
368 query = "SELECT * FROM `phone` WHERE `id` <> 1";
369 r = do_query(hdb, query, &hrec);
370 ok(r == ERROR_NO_MORE_ITEMS, "MsiViewFetch failed\n");
372 query = "SELECT * FROM `phone` WHERE `id` > 10";
373 r = do_query(hdb, query, &hrec);
374 ok(r == ERROR_NO_MORE_ITEMS, "MsiViewFetch failed\n");
376 /* now try a few bad INSERT xqueries */
377 query = "INSERT INTO `phone` ( `id`, `name`, `number` )"
379 r = MsiDatabaseOpenView(hdb, query, &hview);
380 ok(r == ERROR_BAD_QUERY_SYNTAX, "MsiDatabaseOpenView failed\n");
382 /* construct a record to insert */
383 hrec = MsiCreateRecord(4);
384 r = MsiRecordSetInteger(hrec, 1, 2);
385 ok(r == ERROR_SUCCESS, "MsiRecordSetInteger failed\n");
386 r = MsiRecordSetString(hrec, 2, "Adam");
387 ok(r == ERROR_SUCCESS, "MsiRecordSetString failed\n");
388 r = MsiRecordSetString(hrec, 3, "96905305");
389 ok(r == ERROR_SUCCESS, "MsiRecordSetString failed\n");
391 /* insert another value, using a record and wildcards */
392 query = "INSERT INTO `phone` ( `id`, `name`, `number` )"
394 r = MsiDatabaseOpenView(hdb, query, &hview);
395 ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
397 if (r == ERROR_SUCCESS)
399 r = MsiViewExecute(hview, hrec);
400 ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
401 r = MsiViewClose(hview);
402 ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
403 r = MsiCloseHandle(hview);
404 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
406 r = MsiCloseHandle(hrec);
407 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
409 r = MsiViewFetch(0, NULL);
410 ok(r == ERROR_INVALID_PARAMETER, "MsiViewFetch failed\n");
412 r = MsiDatabaseCommit(hdb);
413 ok(r == ERROR_SUCCESS, "MsiDatabaseCommit failed\n");
415 r = MsiCloseHandle(hdb);
416 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
418 r = DeleteFile(msifile);
419 ok(r == TRUE, "file didn't exist after commit\n");
422 typedef UINT (WINAPI *fnMsiDecomposeDescriptorA)(LPCSTR, LPCSTR, LPSTR, LPSTR, DWORD *);
423 static fnMsiDecomposeDescriptorA pMsiDecomposeDescriptorA;
425 static void test_msidecomposedesc(void)
427 char prod[MAX_FEATURE_CHARS+1], comp[MAX_FEATURE_CHARS+1], feature[MAX_FEATURE_CHARS+1];
433 hmod = GetModuleHandle("msi.dll");
436 pMsiDecomposeDescriptorA = (fnMsiDecomposeDescriptorA)
437 GetProcAddress(hmod, "MsiDecomposeDescriptorA");
438 if (!pMsiDecomposeDescriptorA)
441 /* test a valid feature descriptor */
442 desc = "']gAVn-}f(ZXfeAR6.jiFollowTheWhiteRabbit>3w2x^IGfe?CxI5heAvk.";
444 r = pMsiDecomposeDescriptorA(desc, prod, feature, comp, &len);
445 ok(r == ERROR_SUCCESS, "returned an error\n");
446 ok(len == strlen(desc), "length was wrong\n");
447 ok(strcmp(prod,"{90110409-6000-11D3-8CFE-0150048383C9}")==0, "product wrong\n");
448 ok(strcmp(feature,"FollowTheWhiteRabbit")==0, "feature wrong\n");
449 ok(strcmp(comp,"{A7CD68DB-EF74-49C8-FBB2-A7C463B2AC24}")==0,"component wrong\n");
451 /* test an invalid feature descriptor with too many characters */
452 desc = "']gAVn-}f(ZXfeAR6.ji"
453 "ThisWillFailIfTheresMoreThanAGuidsChars>"
454 "3w2x^IGfe?CxI5heAvk.";
456 r = pMsiDecomposeDescriptorA(desc, prod, feature, comp, &len);
457 ok(r == ERROR_INVALID_PARAMETER, "returned wrong error\n");
460 * Test a valid feature descriptor with the
461 * maximum number of characters and some trailing characters.
463 desc = "']gAVn-}f(ZXfeAR6.ji"
464 "ThisWillWorkIfTheresLTEThanAGuidsChars>"
465 "3w2x^IGfe?CxI5heAvk."
468 r = pMsiDecomposeDescriptorA(desc, prod, feature, comp, &len);
469 ok(r == ERROR_SUCCESS, "returned wrong error\n");
470 ok(len == (strlen(desc) - strlen("extra")), "length wrong\n");
473 r = pMsiDecomposeDescriptorA(desc, prod, feature, NULL, &len);
474 ok(r == ERROR_SUCCESS, "returned wrong error\n");
475 ok(len == (strlen(desc) - strlen("extra")), "length wrong\n");
478 r = pMsiDecomposeDescriptorA(desc, prod, NULL, NULL, &len);
479 ok(r == ERROR_SUCCESS, "returned wrong error\n");
480 ok(len == (strlen(desc) - strlen("extra")), "length wrong\n");
483 r = pMsiDecomposeDescriptorA(desc, NULL, NULL, NULL, &len);
484 ok(r == ERROR_SUCCESS, "returned wrong error\n");
485 ok(len == (strlen(desc) - strlen("extra")), "length wrong\n");
488 r = pMsiDecomposeDescriptorA(NULL, NULL, NULL, NULL, &len);
489 ok(r == ERROR_INVALID_PARAMETER, "returned wrong error\n");
490 ok(len == 0, "length wrong\n");
493 static UINT try_query_param( MSIHANDLE hdb, LPCSTR szQuery, MSIHANDLE hrec )
498 res = MsiDatabaseOpenView( hdb, szQuery, &htab );
499 if(res == ERROR_SUCCESS )
503 r = MsiViewExecute( htab, hrec );
504 if(r != ERROR_SUCCESS )
507 r = MsiViewClose( htab );
508 if(r != ERROR_SUCCESS )
511 r = MsiCloseHandle( htab );
512 if(r != ERROR_SUCCESS )
518 static UINT try_query( MSIHANDLE hdb, LPCSTR szQuery )
520 return try_query_param( hdb, szQuery, 0 );
523 static UINT try_insert_query( MSIHANDLE hdb, LPCSTR szQuery )
528 hrec = MsiCreateRecord( 1 );
529 MsiRecordSetString( hrec, 1, "Hello");
531 r = try_query_param( hdb, szQuery, hrec );
533 MsiCloseHandle( hrec );
537 static void test_msibadqueries(void)
544 /* just MsiOpenDatabase should not create a file */
545 r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
546 ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
548 r = MsiDatabaseCommit( hdb );
549 ok(r == ERROR_SUCCESS , "Failed to commit database\n");
551 r = MsiCloseHandle( hdb );
552 ok(r == ERROR_SUCCESS , "Failed to close database\n");
554 /* open it readonly */
555 r = MsiOpenDatabase(msifile, MSIDBOPEN_READONLY, &hdb );
556 ok(r == ERROR_SUCCESS , "Failed to open database r/o\n");
558 /* add a table to it */
559 r = try_query( hdb, "select * from _Tables");
560 ok(r == ERROR_SUCCESS , "query 1 failed\n");
562 r = MsiCloseHandle( hdb );
563 ok(r == ERROR_SUCCESS , "Failed to close database r/o\n");
565 /* open it read/write */
566 r = MsiOpenDatabase(msifile, MSIDBOPEN_TRANSACT, &hdb );
567 ok(r == ERROR_SUCCESS , "Failed to open database r/w\n");
569 /* a bunch of test queries that fail with the native MSI */
571 r = try_query( hdb, "CREATE TABLE");
572 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2a return code\n");
574 r = try_query( hdb, "CREATE TABLE `a`");
575 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2b return code\n");
577 r = try_query( hdb, "CREATE TABLE `a` ()");
578 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2c return code\n");
580 r = try_query( hdb, "CREATE TABLE `a` (`b`)");
581 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2d return code\n");
583 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) )");
584 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2e return code\n");
586 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL)");
587 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2f return code\n");
589 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY)");
590 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2g return code\n");
592 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY)");
593 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2h return code\n");
595 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY)");
596 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2i return code\n");
598 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY 'b')");
599 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2j return code\n");
601 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY `b')");
602 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2k return code\n");
604 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY `b')");
605 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2l return code\n");
607 r = try_query( hdb, "CREATE TABLE `a` (`b` CHA(72) NOT NULL PRIMARY KEY `b`)");
608 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2m return code\n");
610 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(-1) NOT NULL PRIMARY KEY `b`)");
611 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2n return code\n");
613 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(720) NOT NULL PRIMARY KEY `b`)");
614 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2o return code\n");
616 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL KEY `b`)");
617 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2p return code\n");
619 r = try_query( hdb, "CREATE TABLE `a` (`` CHAR(72) NOT NULL PRIMARY KEY `b`)");
620 ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2p return code\n");
622 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY `b`)");
623 ok(r == ERROR_SUCCESS , "valid query 2z failed\n");
625 r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY `b`)");
626 ok(r == ERROR_BAD_QUERY_SYNTAX , "created same table again\n");
628 r = try_query( hdb, "CREATE TABLE `aa` (`b` CHAR(72) NOT NULL, `c` "
629 "CHAR(72), `d` CHAR(255) NOT NULL LOCALIZABLE PRIMARY KEY `b`)");
630 ok(r == ERROR_SUCCESS , "query 4 failed\n");
632 r = MsiDatabaseCommit( hdb );
633 ok(r == ERROR_SUCCESS , "Failed to commit database after write\n");
635 r = try_query( hdb, "CREATE TABLE `blah` (`foo` CHAR(72) NOT NULL "
636 "PRIMARY KEY `foo`)");
637 ok(r == ERROR_SUCCESS , "query 4 failed\n");
639 r = try_insert_query( hdb, "insert into a ( `b` ) VALUES ( ? )");
640 ok(r == ERROR_SUCCESS , "failed to insert record in db\n");
642 r = MsiDatabaseCommit( hdb );
643 ok(r == ERROR_SUCCESS , "Failed to commit database after write\n");
645 r = try_query( hdb, "CREATE TABLE `boo` (`foo` CHAR(72) NOT NULL "
646 "PRIMARY KEY `ba`)");
647 ok(r != ERROR_SUCCESS , "query 5 succeeded\n");
649 r = try_query( hdb,"CREATE TABLE `bee` (`foo` CHAR(72) NOT NULL )");
650 ok(r != ERROR_SUCCESS , "query 6 succeeded\n");
652 r = try_query( hdb, "CREATE TABLE `temp` (`t` CHAR(72) NOT NULL "
654 ok(r == ERROR_SUCCESS , "query 7 failed\n");
656 r = try_query( hdb, "CREATE TABLE `c` (`b` CHAR NOT NULL PRIMARY KEY `b`)");
657 ok(r == ERROR_SUCCESS , "query 8 failed\n");
659 r = MsiCloseHandle( hdb );
660 ok(r == ERROR_SUCCESS , "Failed to close database transact\n");
662 r = DeleteFile( msifile );
663 ok(r == TRUE, "file didn't exist after commit\n");
666 static void test_viewmodify(void)
668 MSIHANDLE hdb = 0, hview = 0, hrec = 0;
676 /* just MsiOpenDatabase should not create a file */
677 r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
678 ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
680 query = "CREATE TABLE `phone` ( "
681 "`id` INT, `name` CHAR(32), `number` CHAR(32) "
683 r = run_query( hdb, 0, query );
684 ok(r == ERROR_SUCCESS, "query failed\n");
686 /* check what the error function reports without doing anything */
688 /* passing NULL as the 3rd param make function to crash on older platforms */
689 r = MsiViewGetError( 0, NULL, &sz );
690 ok(r == MSIDBERROR_INVALIDARG, "MsiViewGetError return\n");
693 query = "SELECT * FROM `phone`";
694 r = MsiDatabaseOpenView(hdb, query, &hview);
695 ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
697 /* see what happens with a good hview and bad args */
698 r = MsiViewGetError( hview, NULL, NULL );
699 ok(r == MSIDBERROR_INVALIDARG || r == MSIDBERROR_NOERROR,
700 "MsiViewGetError returns %u (expected -3)\n", r);
701 r = MsiViewGetError( hview, buffer, NULL );
702 ok(r == MSIDBERROR_INVALIDARG, "MsiViewGetError return\n");
704 /* see what happens with a zero length buffer */
707 r = MsiViewGetError( hview, buffer, &sz );
708 ok(r == MSIDBERROR_MOREDATA, "MsiViewGetError return\n");
709 ok(buffer[0] == 'x', "buffer cleared\n");
710 ok(sz == 0, "size not zero\n");
712 /* ok this one is strange */
714 r = MsiViewGetError( hview, NULL, &sz );
715 ok(r == MSIDBERROR_NOERROR, "MsiViewGetError return\n");
716 ok(sz == 0, "size not zero\n");
718 /* see if it really has an error */
721 r = MsiViewGetError( hview, buffer, &sz );
722 ok(r == MSIDBERROR_NOERROR, "MsiViewGetError return\n");
723 ok(buffer[0] == 0, "buffer not cleared\n");
724 ok(sz == 0, "size not zero\n");
726 r = MsiViewExecute(hview, 0);
727 ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
729 /* try some invalid records */
730 r = MsiViewModify(hview, MSIMODIFY_INSERT, 0 );
731 ok(r == ERROR_INVALID_HANDLE, "MsiViewModify failed\n");
732 r = MsiViewModify(hview, -1, 0 );
733 ok(r == ERROR_INVALID_HANDLE, "MsiViewModify failed\n");
735 /* try an small record */
736 hrec = MsiCreateRecord(1);
737 r = MsiViewModify(hview, -1, hrec );
738 ok(r == ERROR_INVALID_DATA, "MsiViewModify failed\n");
740 r = MsiCloseHandle(hrec);
741 ok(r == ERROR_SUCCESS, "failed to close record\n");
743 /* insert a valid record */
744 hrec = MsiCreateRecord(3);
746 r = MsiRecordSetInteger(hrec, 2, 1);
747 ok(r == ERROR_SUCCESS, "failed to set integer\n");
748 r = MsiRecordSetString(hrec, 2, "bob");
749 ok(r == ERROR_SUCCESS, "failed to set integer\n");
750 r = MsiRecordSetString(hrec, 3, "7654321");
751 ok(r == ERROR_SUCCESS, "failed to set integer\n");
753 r = MsiViewExecute(hview, 0);
754 ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
755 r = MsiViewModify(hview, MSIMODIFY_INSERT_TEMPORARY, hrec );
756 ok(r == ERROR_SUCCESS, "MsiViewModify failed\n");
758 /* insert the same thing again */
759 r = MsiViewExecute(hview, 0);
760 ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
762 /* should fail ... */
764 r = MsiViewModify(hview, MSIMODIFY_INSERT_TEMPORARY, hrec );
765 ok(r == ERROR_FUNCTION_FAILED, "MsiViewModify failed\n");
768 r = MsiCloseHandle(hrec);
769 ok(r == ERROR_SUCCESS, "failed to close record\n");
771 r = MsiViewClose(hview);
772 ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
773 r = MsiCloseHandle(hview);
774 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
776 r = MsiCloseHandle( hdb );
777 ok(r == ERROR_SUCCESS, "MsiOpenDatabase close failed\n");
780 static MSIHANDLE create_db(void)
787 /* create an empty database */
788 res = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb );
789 ok( res == ERROR_SUCCESS , "Failed to create database\n" );
790 if( res != ERROR_SUCCESS )
793 res = MsiDatabaseCommit( hdb );
794 ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
799 static void test_getcolinfo(void)
801 MSIHANDLE hdb, hview = 0, rec = 0;
806 /* create an empty db */
808 ok( hdb, "failed to create db\n");
810 /* tables should be present */
811 r = MsiDatabaseOpenView(hdb, "select * from _Tables", &hview);
812 ok( r == ERROR_SUCCESS, "failed to open query\n");
814 r = MsiViewExecute(hview, 0);
815 ok( r == ERROR_SUCCESS, "failed to execute query\n");
817 /* check that NAMES works */
819 r = MsiViewGetColumnInfo( hview, MSICOLINFO_NAMES, &rec );
820 ok( r == ERROR_SUCCESS, "failed to get names\n");
822 r = MsiRecordGetString(rec, 1, buffer, &sz );
823 ok( r == ERROR_SUCCESS, "failed to get string\n");
824 ok( !strcmp(buffer,"Name"), "_Tables has wrong column name\n");
825 r = MsiCloseHandle( rec );
826 ok( r == ERROR_SUCCESS, "failed to close record handle\n");
828 /* check that TYPES works */
830 r = MsiViewGetColumnInfo( hview, MSICOLINFO_TYPES, &rec );
831 ok( r == ERROR_SUCCESS, "failed to get names\n");
833 r = MsiRecordGetString(rec, 1, buffer, &sz );
834 ok( r == ERROR_SUCCESS, "failed to get string\n");
835 ok( !strcmp(buffer,"s64"), "_Tables has wrong column type\n");
836 r = MsiCloseHandle( rec );
837 ok( r == ERROR_SUCCESS, "failed to close record handle\n");
839 /* check that invalid values fail */
841 r = MsiViewGetColumnInfo( hview, 100, &rec );
842 ok( r == ERROR_INVALID_PARAMETER, "wrong error code\n");
843 ok( rec == 0, "returned a record\n");
845 r = MsiViewGetColumnInfo( hview, MSICOLINFO_TYPES, NULL );
846 ok( r == ERROR_INVALID_PARAMETER, "wrong error code\n");
848 r = MsiViewGetColumnInfo( 0, MSICOLINFO_TYPES, &rec );
849 ok( r == ERROR_INVALID_HANDLE, "wrong error code\n");
851 r = MsiViewClose(hview);
852 ok( r == ERROR_SUCCESS, "failed to close view\n");
853 r = MsiCloseHandle(hview);
854 ok( r == ERROR_SUCCESS, "failed to close view handle\n");
855 r = MsiCloseHandle(hdb);
856 ok( r == ERROR_SUCCESS, "failed to close database\n");
859 static MSIHANDLE get_column_info(MSIHANDLE hdb, const char *query, MSICOLINFO type)
861 MSIHANDLE hview = 0, rec = 0;
864 r = MsiDatabaseOpenView(hdb, query, &hview);
865 if( r != ERROR_SUCCESS )
868 r = MsiViewExecute(hview, 0);
869 if( r == ERROR_SUCCESS )
871 MsiViewGetColumnInfo( hview, type, &rec );
874 MsiCloseHandle(hview);
878 static UINT get_columns_table_type(MSIHANDLE hdb, const char *table, UINT field)
880 MSIHANDLE hview = 0, rec = 0;
884 sprintf(query, "select * from `_Columns` where `Table` = '%s'", table );
886 r = MsiDatabaseOpenView(hdb, query, &hview);
887 if( r != ERROR_SUCCESS )
890 r = MsiViewExecute(hview, 0);
891 if( r == ERROR_SUCCESS )
895 r = MsiViewFetch( hview, &rec );
896 if( r != ERROR_SUCCESS)
898 r = MsiRecordGetInteger( rec, 2 );
900 type = MsiRecordGetInteger( rec, 4 );
901 MsiCloseHandle( rec );
906 MsiCloseHandle(hview);
910 static BOOL check_record( MSIHANDLE rec, UINT field, LPCSTR val )
917 r = MsiRecordGetString( rec, field, buffer, &sz );
918 return (r == ERROR_SUCCESS ) && !strcmp(val, buffer);
921 static void test_viewgetcolumninfo(void)
923 MSIHANDLE hdb = 0, rec;
927 ok( hdb, "failed to create db\n");
929 r = run_query( hdb, 0,
930 "CREATE TABLE `Properties` "
931 "( `Property` CHAR(255), `Value` CHAR(1) PRIMARY KEY `Property`)" );
932 ok( r == ERROR_SUCCESS , "Failed to create table\n" );
934 /* check the column types */
935 rec = get_column_info( hdb, "select * from `Properties`", MSICOLINFO_TYPES );
936 ok( rec, "failed to get column info record\n" );
938 ok( check_record( rec, 1, "S255"), "wrong record type\n");
939 ok( check_record( rec, 2, "S1"), "wrong record type\n");
941 MsiCloseHandle( rec );
943 /* check the type in _Columns */
944 ok( 0x3dff == get_columns_table_type(hdb, "Properties", 1 ), "_columns table wrong\n");
945 ok( 0x1d01 == get_columns_table_type(hdb, "Properties", 2 ), "_columns table wrong\n");
947 /* now try the names */
948 rec = get_column_info( hdb, "select * from `Properties`", MSICOLINFO_NAMES );
949 ok( rec, "failed to get column info record\n" );
951 ok( check_record( rec, 1, "Property"), "wrong record type\n");
952 ok( check_record( rec, 2, "Value"), "wrong record type\n");
954 MsiCloseHandle( rec );
956 r = run_query( hdb, 0,
957 "CREATE TABLE `Binary` "
958 "( `Name` CHAR(255), `Data` OBJECT PRIMARY KEY `Name`)" );
959 ok( r == ERROR_SUCCESS , "Failed to create table\n" );
961 /* check the column types */
962 rec = get_column_info( hdb, "select * from `Binary`", MSICOLINFO_TYPES );
963 ok( rec, "failed to get column info record\n" );
965 ok( check_record( rec, 1, "S255"), "wrong record type\n");
966 ok( check_record( rec, 2, "V0"), "wrong record type\n");
968 MsiCloseHandle( rec );
970 /* check the type in _Columns */
971 ok( 0x3dff == get_columns_table_type(hdb, "Binary", 1 ), "_columns table wrong\n");
972 ok( 0x1900 == get_columns_table_type(hdb, "Binary", 2 ), "_columns table wrong\n");
974 /* now try the names */
975 rec = get_column_info( hdb, "select * from `Binary`", MSICOLINFO_NAMES );
976 ok( rec, "failed to get column info record\n" );
978 ok( check_record( rec, 1, "Name"), "wrong record type\n");
979 ok( check_record( rec, 2, "Data"), "wrong record type\n");
980 MsiCloseHandle( rec );
982 r = run_query( hdb, 0,
983 "CREATE TABLE `UIText` "
984 "( `Key` CHAR(72) NOT NULL, `Text` CHAR(255) LOCALIZABLE PRIMARY KEY `Key`)" );
985 ok( r == ERROR_SUCCESS , "Failed to create table\n" );
987 ok( 0x2d48 == get_columns_table_type(hdb, "UIText", 1 ), "_columns table wrong\n");
988 ok( 0x1fff == get_columns_table_type(hdb, "UIText", 2 ), "_columns table wrong\n");
990 rec = get_column_info( hdb, "select * from `UIText`", MSICOLINFO_NAMES );
991 ok( rec, "failed to get column info record\n" );
992 ok( check_record( rec, 1, "Key"), "wrong record type\n");
993 ok( check_record( rec, 2, "Text"), "wrong record type\n");
994 MsiCloseHandle( rec );
996 rec = get_column_info( hdb, "select * from `UIText`", MSICOLINFO_TYPES );
997 ok( rec, "failed to get column info record\n" );
998 ok( check_record( rec, 1, "s72"), "wrong record type\n");
999 ok( check_record( rec, 2, "L255"), "wrong record type\n");
1000 MsiCloseHandle( rec );
1002 MsiCloseHandle( hdb );
1005 static void test_msiexport(void)
1007 MSIHANDLE hdb = 0, hview = 0;
1010 char path[MAX_PATH];
1011 const char file[] = "phone.txt";
1015 const char expected[] =
1016 "id\tname\tnumber\r\n"
1019 "1\tAbe\t8675309\r\n";
1021 DeleteFile(msifile);
1023 /* just MsiOpenDatabase should not create a file */
1024 r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
1025 ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
1027 /* create a table */
1028 query = "CREATE TABLE `phone` ( "
1029 "`id` INT, `name` CHAR(32), `number` CHAR(32) "
1030 "PRIMARY KEY `id`)";
1031 r = MsiDatabaseOpenView(hdb, query, &hview);
1032 ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
1033 r = MsiViewExecute(hview, 0);
1034 ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
1035 r = MsiViewClose(hview);
1036 ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
1037 r = MsiCloseHandle(hview);
1038 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
1040 /* insert a value into it */
1041 query = "INSERT INTO `phone` ( `id`, `name`, `number` )"
1042 "VALUES('1', 'Abe', '8675309')";
1043 r = MsiDatabaseOpenView(hdb, query, &hview);
1044 ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
1045 r = MsiViewExecute(hview, 0);
1046 ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
1047 r = MsiViewClose(hview);
1048 ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
1049 r = MsiCloseHandle(hview);
1050 ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
1052 GetCurrentDirectory(MAX_PATH, path);
1054 r = MsiDatabaseExport(hdb, "phone", path, file);
1055 ok(r == ERROR_SUCCESS, "MsiDatabaseExport failed\n");
1057 MsiCloseHandle(hdb);
1059 lstrcat(path, "\\");
1060 lstrcat(path, file);
1062 /* check the data that was written */
1064 memset(buffer, 0, sizeof buffer);
1065 handle = CreateFile(path, GENERIC_READ, 0, NULL, OPEN_EXISTING, 0, NULL);
1066 if (handle != INVALID_HANDLE_VALUE)
1068 ReadFile(handle, buffer, sizeof buffer, &length, NULL);
1069 CloseHandle(handle);
1073 ok(0, "failed to open file %s\n", path);
1075 ok( length == strlen(expected), "length of data wrong\n");
1076 ok( !lstrcmp(buffer, expected), "data doesn't match\n");
1077 DeleteFile(msifile);
1080 static void test_longstrings(void)
1082 const char insert_query[] =
1083 "INSERT INTO `strings` ( `id`, `val` ) VALUES('1', 'Z')";
1085 MSIHANDLE hdb = 0, hview = 0, hrec = 0;
1088 const DWORD STRING_LENGTH = 0x10005;
1090 DeleteFile(msifile);
1091 /* just MsiOpenDatabase should not create a file */
1092 r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
1093 ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
1095 /* create a table */
1097 "CREATE TABLE `strings` ( `id` INT, `val` CHAR(0) PRIMARY KEY `id`)");
1098 ok(r == ERROR_SUCCESS, "query failed\n");
1100 /* try a insert a very long string */
1101 str = HeapAlloc(GetProcessHeap(), 0, STRING_LENGTH+sizeof insert_query);
1102 len = strchr(insert_query, 'Z') - insert_query;
1103 strcpy(str, insert_query);
1104 memset(str+len, 'Z', STRING_LENGTH);
1105 strcpy(str+len+STRING_LENGTH, insert_query+len+1);
1106 r = try_query( hdb, str );
1107 ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
1109 HeapFree(GetProcessHeap(), 0, str);
1111 MsiDatabaseCommit(hdb);
1112 ok(r == ERROR_SUCCESS, "MsiDatabaseCommit failed\n");
1113 MsiCloseHandle(hdb);
1115 r = MsiOpenDatabase(msifile, MSIDBOPEN_READONLY, &hdb);
1116 ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
1118 r = MsiDatabaseOpenView(hdb, "select * from `strings` where `id` = 1", &hview);
1119 ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
1121 r = MsiViewExecute(hview, 0);
1122 ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
1124 r = MsiViewFetch(hview, &hrec);
1125 ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
1127 MsiCloseHandle(hview);
1129 r = MsiRecordGetString(hrec, 2, NULL, &len);
1130 ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
1131 ok(len == STRING_LENGTH, "string length wrong\n");
1133 MsiCloseHandle(hrec);
1134 MsiCloseHandle(hdb);
1135 DeleteFile(msifile);
1138 static void create_file(const CHAR *name)
1143 file = CreateFileA(name, GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, 0, NULL);
1144 ok(file != INVALID_HANDLE_VALUE, "Failure to open file %s\n", name);
1145 WriteFile(file, name, strlen(name), &written, NULL);
1146 WriteFile(file, "\n", strlen("\n"), &written, NULL);
1150 static void test_streamtable(void)
1152 MSIHANDLE hdb = 0, rec, view;
1153 char file[MAX_PATH];
1159 ok( hdb, "failed to create db\n");
1161 r = run_query( hdb, 0,
1162 "CREATE TABLE `Properties` "
1163 "( `Property` CHAR(255), `Value` CHAR(1) PRIMARY KEY `Property`)" );
1164 ok( r == ERROR_SUCCESS , "Failed to create table\n" );
1166 /* check the column types */
1167 rec = get_column_info( hdb, "select * from `_Streams`", MSICOLINFO_TYPES );
1168 ok( rec, "failed to get column info record\n" );
1171 ok( check_record( rec, 1, "s62"), "wrong record type\n");
1172 ok( check_record( rec, 2, "V0"), "wrong record type\n");
1175 MsiCloseHandle( rec );
1177 /* now try the names */
1178 rec = get_column_info( hdb, "select * from `_Streams`", MSICOLINFO_NAMES );
1179 ok( rec, "failed to get column info record\n" );
1182 ok( check_record( rec, 1, "Name"), "wrong record type\n");
1183 ok( check_record( rec, 2, "Data"), "wrong record type\n");
1186 MsiCloseHandle( rec );
1188 /* insert a file into the _Streams table */
1189 create_file( "test.txt" );
1191 rec = MsiCreateRecord( 2 );
1192 MsiRecordSetString( rec, 1, "data" );
1194 r = MsiRecordSetStream( rec, 2, "test.txt" );
1195 ok( r == ERROR_SUCCESS, "Failed to add stream data to the record: %d\n", r);
1197 DeleteFile("test.txt");
1199 r = MsiDatabaseOpenView( hdb,
1200 "INSERT INTO `_Streams` ( `Name`, `Data` ) VALUES ( ?, ? )", &view );
1203 ok( r == ERROR_SUCCESS, "Failed to open database view: %d\n", r);
1206 r = MsiViewExecute( view, rec );
1209 ok( r == ERROR_SUCCESS, "Failed to execute view: %d\n", r);
1212 MsiCloseHandle( rec );
1213 MsiCloseHandle( view );
1215 r = MsiDatabaseOpenView( hdb,
1216 "SELECT `Name`, `Data` FROM `_Streams`", &view );
1219 ok( r == ERROR_SUCCESS, "Failed to open database view: %d\n", r);
1222 r = MsiViewExecute( view, 0 );
1225 ok( r == ERROR_SUCCESS, "Failed to execute view: %d\n", r);
1228 r = MsiViewFetch( view, &rec );
1231 ok( r == ERROR_SUCCESS, "Failed to fetch record: %d\n", r);
1235 r = MsiRecordGetString( rec, 1, file, &size );
1238 ok( r == ERROR_SUCCESS, "Failed to get string: %d\n", r);
1239 ok( !lstrcmp(file, "data"), "Expected 'data', got %s\n", file);
1243 memset(buf, 0, MAX_PATH);
1244 r = MsiRecordReadStream( rec, 2, buf, &size );
1247 ok( r == ERROR_SUCCESS, "Failed to get stream: %d\n", r);
1248 ok( !lstrcmp(buf, "test.txt\n"), "Expected 'test.txt\\n', got %s\n", buf);
1251 MsiCloseHandle( rec );
1253 r = MsiViewFetch( view, &rec );
1256 ok( r == ERROR_NO_MORE_ITEMS, "Expected ERROR_NO_MORE_ITEMS, got %d\n", r);
1259 MsiCloseHandle( view );
1260 MsiCloseHandle( hdb );
1261 DeleteFile(msifile);
1264 static void test_where(void)
1266 MSIHANDLE hdb = 0, rec, view;
1274 ok( hdb, "failed to create db\n");
1276 r = run_query( hdb, 0,
1277 "CREATE TABLE `Media` ("
1278 "`DiskId` SHORT NOT NULL, "
1279 "`LastSequence` LONG, "
1280 "`DiskPrompt` CHAR(64) LOCALIZABLE, "
1281 "`Cabinet` CHAR(255), "
1282 "`VolumeLabel` CHAR(32), "
1283 "`Source` CHAR(72) "
1284 "PRIMARY KEY `DiskId`)" );
1285 ok( r == S_OK, "cannot create Media table: %d\n", r );
1287 r = run_query( hdb, 0, "INSERT INTO `Media` "
1288 "( `DiskId`, `LastSequence`, `DiskPrompt`, `Cabinet`, `VolumeLabel`, `Source` ) "
1289 "VALUES ( 1, 0, '', 'zero.cab', '', '' )" );
1290 ok( r == S_OK, "cannot add file to the Media table: %d\n", r );
1292 r = run_query( hdb, 0, "INSERT INTO `Media` "
1293 "( `DiskId`, `LastSequence`, `DiskPrompt`, `Cabinet`, `VolumeLabel`, `Source` ) "
1294 "VALUES ( 2, 1, '', 'one.cab', '', '' )" );
1295 ok( r == S_OK, "cannot add file to the Media table: %d\n", r );
1297 r = run_query( hdb, 0, "INSERT INTO `Media` "
1298 "( `DiskId`, `LastSequence`, `DiskPrompt`, `Cabinet`, `VolumeLabel`, `Source` ) "
1299 "VALUES ( 3, 2, '', 'two.cab', '', '' )" );
1300 ok( r == S_OK, "cannot add file to the Media table: %d\n", r );
1302 query = "SELECT * FROM `Media`";
1303 r = do_query(hdb, query, &rec);
1304 ok(r == ERROR_SUCCESS, "MsiViewFetch failed: %d\n", r);
1305 ok( check_record( rec, 4, "zero.cab"), "wrong cabinet\n");
1306 MsiCloseHandle( rec );
1308 query = "SELECT * FROM `Media` WHERE `LastSequence` >= 1";
1309 r = do_query(hdb, query, &rec);
1310 ok(r == ERROR_SUCCESS, "MsiViewFetch failed: %d\n", r);
1311 ok( check_record( rec, 4, "one.cab"), "wrong cabinet\n");
1313 r = MsiRecordGetInteger(rec, 1);
1314 ok( 2 == r, "field wrong\n");
1315 r = MsiRecordGetInteger(rec, 2);
1316 ok( 1 == r, "field wrong\n");
1317 MsiCloseHandle( rec );
1319 query = "SELECT `DiskId` FROM `Media` WHERE `LastSequence` >= 1 AND DiskId >= 0";
1320 r = MsiDatabaseOpenView(hdb, query, &view);
1321 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
1323 r = MsiViewExecute(view, 0);
1324 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
1326 r = MsiViewFetch(view, &rec);
1327 ok( r == ERROR_SUCCESS, "failed to fetch view: %d\n", r );
1329 count = MsiRecordGetFieldCount( rec );
1330 ok( count == 1, "Expected 1 record fields, got %d\n", count );
1333 r = MsiRecordGetString( rec, 1, buf, &size );
1334 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
1335 ok( !lstrcmp( buf, "2" ),
1336 "For (row %d, column 1) expected '%d', got %s\n", 0, 2, buf );
1337 MsiCloseHandle( rec );
1339 r = MsiViewFetch(view, &rec);
1340 ok( r == ERROR_SUCCESS, "failed to fetch view: %d\n", r );
1343 r = MsiRecordGetString( rec, 1, buf, &size );
1344 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
1345 ok( !lstrcmp( buf, "3" ),
1346 "For (row %d, column 1) expected '%d', got %s\n", 1, 3, buf );
1347 MsiCloseHandle( rec );
1349 r = MsiViewFetch(view, &rec);
1350 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
1353 MsiCloseHandle(view);
1355 MsiCloseHandle( rec );
1357 MsiCloseHandle( hdb );
1358 DeleteFile(msifile);
1361 static CHAR CURR_DIR[MAX_PATH];
1363 static const CHAR test_data[] = "FirstPrimaryColumn\tSecondPrimaryColumn\tShortInt\tShortIntNullable\tLongInt\tLongIntNullable\tString\tLocalizableString\tLocalizableStringNullable\n"
1364 "s255\ti2\ti2\tI2\ti4\tI4\tS255\tS0\ts0\n"
1365 "TestTable\tFirstPrimaryColumn\n"
1366 "stringage\t5\t2\t\t2147483640\t-2147483640\tanother string\tlocalizable\tduh\n";
1368 static void write_file(const CHAR *filename, const char *data, int data_size)
1372 HANDLE hf = CreateFile(filename, GENERIC_WRITE, 0, NULL,
1373 CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
1375 WriteFile(hf, data, data_size, &size, NULL);
1379 static UINT add_table_to_db(MSIHANDLE hdb, LPCSTR table_data)
1383 write_file("temp_file", table_data, (lstrlen(table_data) - 1) * sizeof(char));
1384 r = MsiDatabaseImportA(hdb, CURR_DIR, "temp_file");
1385 DeleteFileA("temp_file");
1390 static void test_msiimport(void)
1392 MSIHANDLE hdb, view, rec;
1397 GetCurrentDirectoryA(MAX_PATH, CURR_DIR);
1399 r = MsiOpenDatabaseA(msifile, MSIDBOPEN_CREATE, &hdb);
1400 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1402 r = add_table_to_db(hdb, test_data);
1403 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1405 query = "SELECT * FROM `TestTable`";
1406 r = MsiDatabaseOpenView(hdb, query, &view);
1407 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1409 r = MsiViewGetColumnInfo(view, MSICOLINFO_NAMES, &rec);
1410 count = MsiRecordGetFieldCount(rec);
1411 ok(count == 9, "Expected 9, got %d\n", count);
1412 ok(check_record(rec, 1, "FirstPrimaryColumn"), "Expected FirstPrimaryColumn\n");
1413 ok(check_record(rec, 2, "SecondPrimaryColumn"), "Expected SecondPrimaryColumn\n");
1414 ok(check_record(rec, 3, "ShortInt"), "Expected ShortInt\n");
1415 ok(check_record(rec, 4, "ShortIntNullable"), "Expected ShortIntNullalble\n");
1416 ok(check_record(rec, 5, "LongInt"), "Expected LongInt\n");
1417 ok(check_record(rec, 6, "LongIntNullable"), "Expected LongIntNullalble\n");
1418 ok(check_record(rec, 7, "String"), "Expected String\n");
1419 ok(check_record(rec, 8, "LocalizableString"), "Expected LocalizableString\n");
1420 ok(check_record(rec, 9, "LocalizableStringNullable"), "Expected LocalizableStringNullable\n");
1421 MsiCloseHandle(rec);
1423 r = MsiViewGetColumnInfo(view, MSICOLINFO_TYPES, &rec);
1424 count = MsiRecordGetFieldCount(rec);
1425 ok(count == 9, "Expected 9, got %d\n", count);
1426 ok(check_record(rec, 1, "s255"), "Expected s255\n");
1427 ok(check_record(rec, 4, "I2"), "Expected I2\n");
1428 ok(check_record(rec, 6, "I4"), "Expected I4\n");
1429 ok(check_record(rec, 7, "S255"), "Expected S255\n");
1430 ok(check_record(rec, 8, "S0"), "Expected S0\n");
1431 ok(check_record(rec, 9, "s0"), "Expected s0\n");
1434 ok(check_record(rec, 2, "i2"), "Expected i2\n");
1435 ok(check_record(rec, 3, "i2"), "Expected i2\n");
1436 ok(check_record(rec, 5, "i4"), "Expected i4\n");
1438 MsiCloseHandle(rec);
1440 query = "SELECT * FROM `TestTable`";
1441 r = do_query(hdb, query, &rec);
1442 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1443 ok(check_record(rec, 1, "stringage"), "Expected 'stringage'\n");
1444 ok(check_record(rec, 7, "another string"), "Expected 'another string'\n");
1445 ok(check_record(rec, 8, "localizable"), "Expected 'localizable'\n");
1446 ok(check_record(rec, 9, "duh"), "Expected 'duh'\n");
1448 i = MsiRecordGetInteger(rec, 2);
1449 ok(i == 5, "Expected 5, got %d\n", i);
1451 i = MsiRecordGetInteger(rec, 3);
1452 ok(i == 2, "Expected 2, got %d\n", i);
1454 i = MsiRecordGetInteger(rec, 4);
1457 ok(i == 0x80000000, "Expected 0x80000000, got %d\n", i);
1460 i = MsiRecordGetInteger(rec, 5);
1461 ok(i == 2147483640, "Expected 2147483640, got %d\n", i);
1463 i = MsiRecordGetInteger(rec, 6);
1464 ok(i == -2147483640, "Expected -2147483640, got %d\n", i);
1466 MsiCloseHandle(rec);
1467 MsiCloseHandle(view);
1468 MsiCloseHandle(hdb);
1469 DeleteFileA(msifile);
1472 static void test_markers(void)
1479 ok( hdb, "failed to create db\n");
1481 rec = MsiCreateRecord(3);
1482 MsiRecordSetString(rec, 1, "Table");
1483 MsiRecordSetString(rec, 2, "Apples");
1484 MsiRecordSetString(rec, 3, "Oranges");
1486 /* try a legit create */
1487 query = "CREATE TABLE `Table` ( `One` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`)";
1488 r = run_query(hdb, 0, query);
1489 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1490 MsiCloseHandle(rec);
1492 /* try table name as marker */
1493 rec = MsiCreateRecord(1);
1494 MsiRecordSetString(rec, 1, "Fable");
1495 query = "CREATE TABLE `?` ( `One` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`)";
1496 r = run_query(hdb, rec, query);
1497 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1499 /* verify that we just created a table called '?', not 'Fable' */
1500 r = try_query(hdb, "SELECT * from `Fable`");
1501 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1503 r = try_query(hdb, "SELECT * from `?`");
1504 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1506 /* try table name as marker without backticks */
1507 MsiRecordSetString(rec, 1, "Mable");
1508 query = "CREATE TABLE ? ( `One` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`)";
1509 r = run_query(hdb, rec, query);
1510 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1512 /* try one column name as marker */
1513 MsiRecordSetString(rec, 1, "One");
1514 query = "CREATE TABLE `Mable` ( `?` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`)";
1515 r = run_query(hdb, rec, query);
1516 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1517 MsiCloseHandle(rec);
1519 /* try column names as markers */
1520 rec = MsiCreateRecord(2);
1521 MsiRecordSetString(rec, 1, "One");
1522 MsiRecordSetString(rec, 2, "Two");
1523 query = "CREATE TABLE `Mable` ( `?` SHORT NOT NULL, `?` CHAR(255) PRIMARY KEY `One`)";
1524 r = run_query(hdb, rec, query);
1525 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1526 MsiCloseHandle(rec);
1528 /* try names with backticks */
1529 rec = MsiCreateRecord(3);
1530 MsiRecordSetString(rec, 1, "One");
1531 MsiRecordSetString(rec, 2, "Two");
1532 MsiRecordSetString(rec, 3, "One");
1533 query = "CREATE TABLE `Mable` ( `?` SHORT NOT NULL, `?` CHAR(255) PRIMARY KEY `?`)";
1534 r = run_query(hdb, rec, query);
1535 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1537 /* try names with backticks, minus definitions */
1538 query = "CREATE TABLE `Mable` ( `?`, `?` PRIMARY KEY `?`)";
1539 r = run_query(hdb, rec, query);
1540 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1542 /* try names without backticks */
1543 query = "CREATE TABLE `Mable` ( ? SHORT NOT NULL, ? CHAR(255) PRIMARY KEY ?)";
1544 r = run_query(hdb, rec, query);
1545 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1546 MsiCloseHandle(rec);
1548 /* try one long marker */
1549 rec = MsiCreateRecord(1);
1550 MsiRecordSetString(rec, 1, "`One` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`");
1551 query = "CREATE TABLE `Mable` ( ? )";
1552 r = run_query(hdb, rec, query);
1553 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1554 MsiCloseHandle(rec);
1556 /* try all names as markers */
1557 rec = MsiCreateRecord(4);
1558 MsiRecordSetString(rec, 1, "Mable");
1559 MsiRecordSetString(rec, 2, "One");
1560 MsiRecordSetString(rec, 3, "Two");
1561 MsiRecordSetString(rec, 4, "One");
1562 query = "CREATE TABLE `?` ( `?` SHORT NOT NULL, `?` CHAR(255) PRIMARY KEY `?`)";
1563 r = run_query(hdb, rec, query);
1564 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1565 MsiCloseHandle(rec);
1567 /* try a legit insert */
1568 query = "INSERT INTO `Table` ( `One`, `Two` ) VALUES ( 5, 'hello' )";
1569 r = run_query(hdb, 0, query);
1570 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1572 r = try_query(hdb, "SELECT * from `Table`");
1573 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1575 /* try values as markers */
1576 rec = MsiCreateRecord(2);
1577 MsiRecordSetInteger(rec, 1, 4);
1578 MsiRecordSetString(rec, 2, "hi");
1579 query = "INSERT INTO `Table` ( `One`, `Two` ) VALUES ( ?, '?' )";
1580 r = run_query(hdb, rec, query);
1581 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1582 MsiCloseHandle(rec);
1584 /* try column names and values as markers */
1585 rec = MsiCreateRecord(4);
1586 MsiRecordSetString(rec, 1, "One");
1587 MsiRecordSetString(rec, 2, "Two");
1588 MsiRecordSetInteger(rec, 3, 5);
1589 MsiRecordSetString(rec, 4, "hi");
1590 query = "INSERT INTO `Table` ( `?`, `?` ) VALUES ( ?, '?' )";
1591 r = run_query(hdb, rec, query);
1592 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1593 MsiCloseHandle(rec);
1595 /* try column names as markers */
1596 rec = MsiCreateRecord(2);
1597 MsiRecordSetString(rec, 1, "One");
1598 MsiRecordSetString(rec, 2, "Two");
1599 query = "INSERT INTO `Table` ( `?`, `?` ) VALUES ( 3, 'yellow' )";
1600 r = run_query(hdb, rec, query);
1601 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1602 MsiCloseHandle(rec);
1604 /* try table name as a marker */
1605 rec = MsiCreateRecord(1);
1606 MsiRecordSetString(rec, 1, "Table");
1607 query = "INSERT INTO `?` ( `One`, `Two` ) VALUES ( 2, 'green' )";
1608 r = run_query(hdb, rec, query);
1609 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1610 MsiCloseHandle(rec);
1612 /* try table name and values as markers */
1613 rec = MsiCreateRecord(3);
1614 MsiRecordSetString(rec, 1, "Table");
1615 MsiRecordSetInteger(rec, 2, 10);
1616 MsiRecordSetString(rec, 3, "haha");
1617 query = "INSERT INTO `?` ( `One`, `Two` ) VALUES ( ?, '?' )";
1618 r = run_query(hdb, rec, query);
1619 ok(r == ERROR_FUNCTION_FAILED, "Expected ERROR_FUNCTION_FAILED, got %d\n", r);
1620 MsiCloseHandle(rec);
1622 /* try all markers */
1623 rec = MsiCreateRecord(5);
1624 MsiRecordSetString(rec, 1, "Table");
1625 MsiRecordSetString(rec, 1, "One");
1626 MsiRecordSetString(rec, 1, "Two");
1627 MsiRecordSetInteger(rec, 2, 10);
1628 MsiRecordSetString(rec, 3, "haha");
1629 query = "INSERT INTO `?` ( `?`, `?` ) VALUES ( ?, '?' )";
1630 r = run_query(hdb, rec, query);
1631 ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1632 MsiCloseHandle(rec);
1634 /* insert an integer as a string */
1635 rec = MsiCreateRecord(2);
1636 MsiRecordSetString(rec, 1, "11");
1637 MsiRecordSetString(rec, 2, "hi");
1638 query = "INSERT INTO `Table` ( `One`, `Two` ) VALUES ( ?, '?' )";
1639 r = run_query(hdb, rec, query);
1640 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1641 MsiCloseHandle(rec);
1643 /* leave off the '' for the string */
1644 rec = MsiCreateRecord(2);
1645 MsiRecordSetInteger(rec, 1, 12);
1646 MsiRecordSetString(rec, 2, "hi");
1647 query = "INSERT INTO `Table` ( `One`, `Two` ) VALUES ( ?, ? )";
1648 r = run_query(hdb, rec, query);
1649 ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1650 MsiCloseHandle(rec);
1652 MsiCloseHandle(hdb);
1653 DeleteFileA(msifile);
1656 #define MY_NVIEWS 4000 /* Largest installer I've seen uses < 2k */
1657 static void test_handle_limit(void)
1661 MSIHANDLE hviews[MY_NVIEWS];
1664 /* create an empty db */
1666 ok( hdb, "failed to create db\n");
1668 memset(hviews, 0, sizeof(hviews));
1670 for (i=0; i<MY_NVIEWS; i++) {
1671 static char szQueryBuf[256] = "SELECT * from `_Tables`";
1672 hviews[i] = 0xdeadbeeb;
1673 r = MsiDatabaseOpenView(hdb, szQueryBuf, &hviews[i]);
1674 if( r != ERROR_SUCCESS || hviews[i] == 0xdeadbeeb ||
1675 hviews[i] == 0 || (i && (hviews[i] == hviews[i-1])))
1679 ok( i == MY_NVIEWS, "problem opening views\n");
1681 for (i=0; i<MY_NVIEWS; i++) {
1682 if (hviews[i] != 0 && hviews[i] != 0xdeadbeeb) {
1683 r = MsiCloseHandle(hviews[i]);
1684 if (r != ERROR_SUCCESS)
1689 ok( i == MY_NVIEWS, "problem closing views\n");
1691 r = MsiCloseHandle(hdb);
1692 ok( r == ERROR_SUCCESS, "failed to close database\n");
1695 static void generate_transform(void)
1697 MSIHANDLE hdb1, hdb2;
1701 /* start with two identical databases */
1702 CopyFile(msifile2, msifile, FALSE);
1704 r = MsiOpenDatabase(msifile, MSIDBOPEN_TRANSACT, &hdb1 );
1705 ok( r == ERROR_SUCCESS , "Failed to create database\n" );
1707 r = MsiDatabaseCommit( hdb1 );
1708 ok( r == ERROR_SUCCESS , "Failed to commit database\n" );
1710 r = MsiOpenDatabase(msifile2, MSIDBOPEN_READONLY, &hdb2 );
1711 ok( r == ERROR_SUCCESS , "Failed to create database\n" );
1713 /* the transform between two identical database should be empty */
1714 r = MsiDatabaseGenerateTransform(hdb1, hdb2, NULL, 0, 0);
1716 ok( r == ERROR_NO_DATA, "return code %d, should be ERROR_NO_DATA\n", r );
1719 query = "CREATE TABLE `AAR` ( `BAR` SHORT NOT NULL, `CAR` CHAR(255) PRIMARY KEY `CAR`)";
1720 r = run_query(hdb1, 0, query);
1721 ok(r == ERROR_SUCCESS, "failed to add table\n");
1723 query = "INSERT INTO `AAR` ( `BAR`, `CAR` ) VALUES ( 1, 'vw' )";
1724 r = run_query(hdb1, 0, query);
1725 ok(r == ERROR_SUCCESS, "failed to add row 1\n");
1727 query = "INSERT INTO `AAR` ( `BAR`, `CAR` ) VALUES ( 2, 'bmw' )";
1728 r = run_query(hdb1, 0, query);
1729 ok(r == ERROR_SUCCESS, "failed to add row 2\n");
1731 query = "UPDATE `MOO` SET `OOO` = 'c' WHERE `NOO` = 1";
1732 r = run_query(hdb1, 0, query);
1733 ok(r == ERROR_SUCCESS, "failed to modify row\n");
1735 query = "DELETE FROM `MOO` WHERE `NOO` = 3";
1736 r = run_query(hdb1, 0, query);
1737 ok(r == ERROR_SUCCESS, "failed to delete row\n");
1739 /* database needs to be committed */
1740 MsiDatabaseCommit(hdb1);
1742 r = MsiDatabaseGenerateTransform(hdb1, hdb2, mstfile, 0, 0);
1743 ok( r == ERROR_SUCCESS, "return code %d, should be ERROR_SUCCESS\n", r );
1745 MsiCloseHandle( hdb1 );
1746 MsiCloseHandle( hdb2 );
1749 /* data for generating a transform */
1751 /* tables transform names - encoded as they would be in an msi database file */
1752 static const WCHAR name1[] = { 0x4840, 0x3a8a, 0x481b, 0 }; /* AAR */
1753 static const WCHAR name2[] = { 0x4840, 0x3b3f, 0x43f2, 0x4438, 0x45b1, 0 }; /* _Columns */
1754 static const WCHAR name3[] = { 0x4840, 0x3f7f, 0x4164, 0x422f, 0x4836, 0 }; /* _Tables */
1755 static const WCHAR name4[] = { 0x4840, 0x3f3f, 0x4577, 0x446c, 0x3b6a, 0x45e4, 0x4824, 0 }; /* _StringData */
1756 static const WCHAR name5[] = { 0x4840, 0x3f3f, 0x4577, 0x446c, 0x3e6a, 0x44b2, 0x482f, 0 }; /* _StringPool */
1757 static const WCHAR name6[] = { 0x4840, 0x3e16, 0x4818, 0}; /* MOO */
1759 /* data in each table */
1760 static const WCHAR data1[] = { /* AAR */
1761 0x0201, 0x0005, 0x8001, /* 0x0201 = add row (1), two shorts */
1762 0x0201, 0x0006, 0x8002,
1764 static const WCHAR data2[] = { /* _Columns */
1765 0x0401, 0x0002, 0x0000, 0x0003, 0xbdff, /* 0x0401 = add row (1), 4 shorts */
1766 0x0401, 0x0002, 0x0000, 0x0004, 0x8502,
1768 static const WCHAR data3[] = { /* _Tables */
1769 0x0101, 0x0002, /* 0x0101 = add row (1), 1 short */
1771 static const char data4[] = /* _StringData */
1772 "cAARCARBARvwbmw"; /* all the strings squashed together */
1773 static const WCHAR data5[] = { /* _StringPool */
1775 0, 0, /* string 0 '' */
1776 1, 1, /* string 1 'c' */
1777 3, 3, /* string 2 'AAR' */
1778 3, 1, /* string 3 'CAR' */
1779 3, 1, /* string 4 'BAR' */
1780 2, 1, /* string 5 'vw' */
1781 3, 1, /* string 6 'bmw' */
1783 /* update row, 0x0002 is a bitmask of present column data, keys are excluded */
1784 static const WCHAR data6[] = { /* MOO */
1785 0x0002, 0x8001, 0x0001, /* update row */
1786 0x0000, 0x8003, /* delete row */
1789 static const struct {
1793 } table_transform_data[] =
1795 { name1, data1, sizeof data1 },
1796 { name2, data2, sizeof data2 },
1797 { name3, data3, sizeof data3 },
1798 { name4, data4, sizeof data4 - 1 },
1799 { name5, data5, sizeof data5 },
1800 { name6, data6, sizeof data6 },
1803 #define NUM_TRANSFORM_TABLES (sizeof table_transform_data/sizeof table_transform_data[0])
1805 static void generate_transform_manual(void)
1807 IStorage *stg = NULL;
1812 const DWORD mode = STGM_CREATE|STGM_READWRITE|STGM_DIRECT|STGM_SHARE_EXCLUSIVE;
1814 const CLSID CLSID_MsiTransform = { 0xc1082,0,0,{0xc0,0,0,0,0,0,0,0x46}};
1816 MultiByteToWideChar(CP_ACP, 0, mstfile, -1, name, 0x20);
1818 r = StgCreateDocfile(name, mode, 0, &stg);
1819 ok(r == S_OK, "failed to create storage\n");
1823 r = IStorage_SetClass( stg, &CLSID_MsiTransform );
1824 ok(r == S_OK, "failed to set storage type\n");
1826 for (i=0; i<NUM_TRANSFORM_TABLES; i++)
1828 r = IStorage_CreateStream( stg, table_transform_data[i].name,
1829 STGM_WRITE | STGM_SHARE_EXCLUSIVE, 0, 0, &stm );
1832 ok(0, "failed to create stream\n");
1836 r = IStream_Write( stm, table_transform_data[i].data,
1837 table_transform_data[i].size, &count );
1838 if (FAILED(r) || count != table_transform_data[i].size)
1839 ok(0, "failed to write stream\n");
1840 IStream_Release(stm);
1843 IStorage_Release(stg);
1846 static void test_try_transform(void)
1848 MSIHANDLE hdb, hrec;
1852 DeleteFile(msifile);
1853 DeleteFile(msifile2);
1854 DeleteFile(mstfile);
1856 /* create an empty database */
1857 r = MsiOpenDatabase(msifile2, MSIDBOPEN_CREATE, &hdb );
1858 ok( r == ERROR_SUCCESS , "Failed to create database\n" );
1860 query = "CREATE TABLE `MOO` ( `NOO` SHORT NOT NULL, `OOO` CHAR(255) PRIMARY KEY `NOO`)";
1861 r = run_query(hdb, 0, query);
1862 ok(r == ERROR_SUCCESS, "failed to add table\n");
1864 query = "INSERT INTO `MOO` ( `NOO`, `OOO` ) VALUES ( 1, 'a' )";
1865 r = run_query(hdb, 0, query);
1866 ok(r == ERROR_SUCCESS, "failed to add row\n");
1868 query = "INSERT INTO `MOO` ( `NOO`, `OOO` ) VALUES ( 2, 'b' )";
1869 r = run_query(hdb, 0, query);
1870 ok(r == ERROR_SUCCESS, "failed to add row\n");
1872 query = "INSERT INTO `MOO` ( `NOO`, `OOO` ) VALUES ( 3, 'c' )";
1873 r = run_query(hdb, 0, query);
1874 ok(r == ERROR_SUCCESS, "failed to add row\n");
1876 r = MsiDatabaseCommit( hdb );
1877 ok( r == ERROR_SUCCESS , "Failed to commit database\n" );
1879 MsiCloseHandle( hdb );
1882 * Both these generate an equivilent transform,
1883 * but the first doesn't work in Wine yet
1884 * because MsiDatabaseGenerateTransform is unimplemented.
1887 generate_transform();
1889 generate_transform_manual();
1891 r = MsiOpenDatabase(msifile2, MSIDBOPEN_DIRECT, &hdb );
1892 ok( r == ERROR_SUCCESS , "Failed to create database\n" );
1894 r = MsiDatabaseApplyTransform( hdb, mstfile, 0 );
1895 ok( r == ERROR_SUCCESS, "return code %d, should be ERROR_SUCCESS\n", r );
1897 MsiDatabaseCommit( hdb );
1899 /* check new values */
1901 query = "select `BAR`,`CAR` from `AAR` where `BAR` = 1 AND `CAR` = 'vw'";
1902 r = do_query(hdb, query, &hrec);
1903 ok(r == ERROR_SUCCESS, "select query failed\n");
1904 MsiCloseHandle(hrec);
1906 query = "select `BAR`,`CAR` from `AAR` where `BAR` = 2 AND `CAR` = 'bmw'";
1908 r = do_query(hdb, query, &hrec);
1909 ok(r == ERROR_SUCCESS, "select query failed\n");
1910 MsiCloseHandle(hrec);
1912 /* check updated values */
1914 query = "select `NOO`,`OOO` from `MOO` where `NOO` = 1 AND `OOO` = 'c'";
1915 r = do_query(hdb, query, &hrec);
1916 ok(r == ERROR_SUCCESS, "select query failed\n");
1917 MsiCloseHandle(hrec);
1919 /* check unchanged value */
1921 query = "select `NOO`,`OOO` from `MOO` where `NOO` = 2 AND `OOO` = 'b'";
1922 r = do_query(hdb, query, &hrec);
1923 ok(r == ERROR_SUCCESS, "select query failed\n");
1924 MsiCloseHandle(hrec);
1926 /* check deleted value */
1928 query = "select * from `MOO` where `NOO` = 3";
1929 r = do_query(hdb, query, &hrec);
1930 ok(r == ERROR_NO_MORE_ITEMS, "select query failed\n");
1931 if (hrec) MsiCloseHandle(hrec);
1933 MsiCloseHandle( hdb );
1935 DeleteFile(msifile);
1936 DeleteFile(msifile2);
1937 DeleteFile(mstfile);
1942 const CHAR one[MAX_PATH];
1943 const CHAR two[MAX_PATH];
1946 struct join_res_4col
1948 const CHAR one[MAX_PATH];
1949 const CHAR two[MAX_PATH];
1950 const CHAR three[MAX_PATH];
1951 const CHAR four[MAX_PATH];
1954 static const struct join_res join_res_first[] =
1956 { "alveolar", "procerus" },
1957 { "septum", "procerus" },
1958 { "septum", "nasalis" },
1959 { "ramus", "nasalis" },
1960 { "malar", "mentalis" },
1963 static const struct join_res join_res_second[] =
1965 { "nasal", "septum" },
1966 { "mandible", "ramus" },
1969 static const struct join_res join_res_third[] =
1971 { "msvcp.dll", "abcdefgh" },
1972 { "msvcr.dll", "ijklmnop" },
1975 static const struct join_res join_res_fourth[] =
1977 { "msvcp.dll.01234", "single.dll.31415" },
1980 static const struct join_res join_res_fifth[] =
1982 { "malar", "procerus" },
1985 static const struct join_res join_res_sixth[] =
1987 { "malar", "procerus" },
1988 { "malar", "procerus" },
1989 { "malar", "nasalis" },
1990 { "malar", "nasalis" },
1991 { "malar", "nasalis" },
1992 { "malar", "mentalis" },
1995 static const struct join_res join_res_seventh[] =
1997 { "malar", "nasalis" },
1998 { "malar", "nasalis" },
1999 { "malar", "nasalis" },
2002 static const struct join_res_4col join_res_eighth[] =
2004 { "msvcp.dll", "msvcp.dll.01234", "msvcp.dll.01234", "abcdefgh" },
2005 { "msvcr.dll", "msvcr.dll.56789", "msvcp.dll.01234", "abcdefgh" },
2006 { "msvcp.dll", "msvcp.dll.01234", "msvcr.dll.56789", "ijklmnop" },
2007 { "msvcr.dll", "msvcr.dll.56789", "msvcr.dll.56789", "ijklmnop" },
2008 { "msvcp.dll", "msvcp.dll.01234", "single.dll.31415", "msvcp.dll" },
2009 { "msvcr.dll", "msvcr.dll.56789", "single.dll.31415", "msvcp.dll" },
2012 static void test_join(void)
2014 MSIHANDLE hdb, hview, hrec;
2021 ok( hdb, "failed to create db\n");
2023 r = create_component_table( hdb );
2024 ok( r == ERROR_SUCCESS, "cannot create Component table: %d\n", r );
2026 r = add_component_entry( hdb, "'zygomatic', 'malar', 'INSTALLDIR', 0, '', ''" );
2027 ok( r == ERROR_SUCCESS, "cannot add component: %d\n", r );
2029 r = add_component_entry( hdb, "'maxilla', 'alveolar', 'INSTALLDIR', 0, '', ''" );
2030 ok( r == ERROR_SUCCESS, "cannot add component: %d\n", r );
2032 r = add_component_entry( hdb, "'nasal', 'septum', 'INSTALLDIR', 0, '', ''" );
2033 ok( r == ERROR_SUCCESS, "cannot add component: %d\n", r );
2035 r = add_component_entry( hdb, "'mandible', 'ramus', 'INSTALLDIR', 0, '', ''" );
2036 ok( r == ERROR_SUCCESS, "cannot add component: %d\n", r );
2038 r = create_feature_components_table( hdb );
2039 ok( r == ERROR_SUCCESS, "cannot create FeatureComponents table: %d\n", r );
2041 r = add_feature_components_entry( hdb, "'procerus', 'maxilla'" );
2042 ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2044 r = add_feature_components_entry( hdb, "'procerus', 'nasal'" );
2045 ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2047 r = add_feature_components_entry( hdb, "'nasalis', 'nasal'" );
2048 ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2050 r = add_feature_components_entry( hdb, "'nasalis', 'mandible'" );
2051 ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2053 r = add_feature_components_entry( hdb, "'nasalis', 'notacomponent'" );
2054 ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2056 r = add_feature_components_entry( hdb, "'mentalis', 'zygomatic'" );
2057 ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2059 r = create_std_dlls_table( hdb );
2060 ok( r == ERROR_SUCCESS, "cannot create StdDlls table: %d\n", r );
2062 r = add_std_dlls_entry( hdb, "'msvcp.dll', 'msvcp.dll.01234'" );
2063 ok( r == ERROR_SUCCESS, "cannot add std dlls: %d\n", r );
2065 r = add_std_dlls_entry( hdb, "'msvcr.dll', 'msvcr.dll.56789'" );
2066 ok( r == ERROR_SUCCESS, "cannot add std dlls: %d\n", r );
2068 r = create_binary_table( hdb );
2069 ok( r == ERROR_SUCCESS, "cannot create Binary table: %d\n", r );
2071 r = add_binary_entry( hdb, "'msvcp.dll.01234', 'abcdefgh'" );
2072 ok( r == ERROR_SUCCESS, "cannot add binary: %d\n", r );
2074 r = add_binary_entry( hdb, "'msvcr.dll.56789', 'ijklmnop'" );
2075 ok( r == ERROR_SUCCESS, "cannot add binary: %d\n", r );
2077 r = add_binary_entry( hdb, "'single.dll.31415', 'msvcp.dll'" );
2078 ok( r == ERROR_SUCCESS, "cannot add binary: %d\n", r );
2080 query = "SELECT `Component`.`ComponentId`, `FeatureComponents`.`Feature_` "
2081 "FROM `Component`, `FeatureComponents` "
2082 "WHERE `Component`.`Component` = `FeatureComponents`.`Component_` "
2083 "ORDER BY `Feature_`";
2084 r = MsiDatabaseOpenView(hdb, query, &hview);
2085 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2087 r = MsiViewExecute(hview, 0);
2088 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2091 while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2093 count = MsiRecordGetFieldCount( hrec );
2094 ok( count == 2, "Expected 2 record fields, got %d\n", count );
2097 r = MsiRecordGetString( hrec, 1, buf, &size );
2098 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2099 if (i == 2 || i == 3) todo_wine
2101 ok( !lstrcmp( buf, join_res_first[i].one ),
2102 "For (row %d, column 1) expected '%s', got %s\n", i, join_res_first[i].one, buf );
2106 r = MsiRecordGetString( hrec, 2, buf, &size );
2107 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2108 if (i == 3) todo_wine
2110 ok( !lstrcmp( buf, join_res_first[i].two ),
2111 "For (row %d, column 2) expected '%s', got %s\n", i, join_res_first[i].two, buf );
2115 MsiCloseHandle(hrec);
2120 ok( i == 5, "Expected 5 rows, got %d\n", i );
2123 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2125 MsiViewClose(hview);
2126 MsiCloseHandle(hview);
2128 query = "SELECT DISTINCT Component, ComponentId FROM FeatureComponents, Component "
2129 "WHERE FeatureComponents.Component_=Component.Component "
2130 "AND (Feature_='nasalis') ORDER BY Feature_";
2131 r = MsiDatabaseOpenView(hdb, query, &hview);
2134 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2137 r = MsiViewExecute(hview, 0);
2140 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2144 while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2146 count = MsiRecordGetFieldCount( hrec );
2147 ok( count == 2, "Expected 2 record fields, got %d\n", count );
2150 r = MsiRecordGetString( hrec, 1, buf, &size );
2151 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2152 ok( !lstrcmp( buf, join_res_second[i].one ),
2153 "For (row %d, column 1) expected '%s', got %s\n", i, join_res_second[i].one, buf );
2156 r = MsiRecordGetString( hrec, 2, buf, &size );
2157 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2158 ok( !lstrcmp( buf, join_res_second[i].two ),
2159 "For (row %d, column 2) expected '%s', got %s\n", i, join_res_second[i].two, buf );
2162 MsiCloseHandle(hrec);
2167 ok( i == 2, "Expected 2 rows, got %d\n", i );
2172 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2175 MsiViewClose(hview);
2176 MsiCloseHandle(hview);
2178 query = "SELECT `StdDlls`.`File`, `Binary`.`Data` "
2179 "FROM `StdDlls`, `Binary` "
2180 "WHERE `StdDlls`.`Binary_` = `Binary`.`Name` "
2182 r = MsiDatabaseOpenView(hdb, query, &hview);
2183 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2185 r = MsiViewExecute(hview, 0);
2186 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2189 while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2191 count = MsiRecordGetFieldCount( hrec );
2192 ok( count == 2, "Expected 2 record fields, got %d\n", count );
2195 r = MsiRecordGetString( hrec, 1, buf, &size );
2196 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2197 ok( !lstrcmp( buf, join_res_third[i].one ),
2198 "For (row %d, column 1) expected '%s', got %s\n", i, join_res_third[i].one, buf );
2201 r = MsiRecordGetString( hrec, 2, buf, &size );
2202 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2203 ok( !lstrcmp( buf, join_res_third[i].two ),
2204 "For (row %d, column 2) expected '%s', got %s\n", i, join_res_third[i].two, buf );
2207 MsiCloseHandle(hrec);
2210 ok( i == 2, "Expected 2 rows, got %d\n", i );
2212 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2214 MsiViewClose(hview);
2215 MsiCloseHandle(hview);
2217 query = "SELECT `StdDlls`.`Binary_`, `Binary`.`Name` "
2218 "FROM `StdDlls`, `Binary` "
2219 "WHERE `StdDlls`.`File` = `Binary`.`Data` "
2221 r = MsiDatabaseOpenView(hdb, query, &hview);
2222 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2224 r = MsiViewExecute(hview, 0);
2225 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2228 while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2230 count = MsiRecordGetFieldCount( hrec );
2231 ok( count == 2, "Expected 2 record fields, got %d\n", count );
2234 r = MsiRecordGetString( hrec, 1, buf, &size );
2235 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2236 ok( !lstrcmp( buf, join_res_fourth[i].one ),
2237 "For (row %d, column 1) expected '%s', got %s\n", i, join_res_fourth[i].one, buf );
2240 r = MsiRecordGetString( hrec, 2, buf, &size );
2241 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2242 ok( !lstrcmp( buf, join_res_fourth[i].two ),
2243 "For (row %d, column 2) expected '%s', got %s\n", i, join_res_fourth[i].two, buf );
2246 MsiCloseHandle(hrec);
2249 ok( i == 1, "Expected 1 rows, got %d\n", i );
2251 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2253 MsiViewClose(hview);
2254 MsiCloseHandle(hview);
2256 query = "SELECT `Component`.`ComponentId`, `FeatureComponents`.`Feature_` "
2257 "FROM `Component`, `FeatureComponents` "
2258 "WHERE `Component`.`Component` = 'zygomatic' "
2259 "AND `FeatureComponents`.`Component_` = 'maxilla' "
2260 "ORDER BY `Feature_`";
2261 r = MsiDatabaseOpenView(hdb, query, &hview);
2264 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2267 r = MsiViewExecute(hview, 0);
2270 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2274 while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2276 count = MsiRecordGetFieldCount( hrec );
2277 ok( count == 2, "Expected 2 record fields, got %d\n", count );
2280 r = MsiRecordGetString( hrec, 1, buf, &size );
2281 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2282 ok( !lstrcmp( buf, join_res_fifth[i].one ),
2283 "For (row %d, column 1) expected '%s', got %s\n", i, join_res_fifth[i].one, buf );
2286 r = MsiRecordGetString( hrec, 2, buf, &size );
2287 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2288 ok( !lstrcmp( buf, join_res_fifth[i].two ),
2289 "For (row %d, column 2) expected '%s', got %s\n", i, join_res_fifth[i].two, buf );
2292 MsiCloseHandle(hrec);
2297 ok( i == 1, "Expected 1 rows, got %d\n", i );
2302 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2305 MsiViewClose(hview);
2306 MsiCloseHandle(hview);
2308 query = "SELECT `Component`.`ComponentId`, `FeatureComponents`.`Feature_` "
2309 "FROM `Component`, `FeatureComponents` "
2310 "WHERE `Component` = 'zygomatic' "
2311 "ORDER BY `Feature_`";
2312 r = MsiDatabaseOpenView(hdb, query, &hview);
2315 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2318 r = MsiViewExecute(hview, 0);
2321 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2325 while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2327 count = MsiRecordGetFieldCount( hrec );
2328 ok( count == 2, "Expected 2 record fields, got %d\n", count );
2331 r = MsiRecordGetString( hrec, 1, buf, &size );
2332 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2333 ok( !lstrcmp( buf, join_res_sixth[i].one ),
2334 "For (row %d, column 1) expected '%s', got %s\n", i, join_res_sixth[i].one, buf );
2337 r = MsiRecordGetString( hrec, 2, buf, &size );
2338 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2339 ok( !lstrcmp( buf, join_res_sixth[i].two ),
2340 "For (row %d, column 2) expected '%s', got %s\n", i, join_res_sixth[i].two, buf );
2343 MsiCloseHandle(hrec);
2348 ok( i == 6, "Expected 6 rows, got %d\n", i );
2353 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2356 MsiViewClose(hview);
2357 MsiCloseHandle(hview);
2359 query = "SELECT `Component`.`ComponentId`, `FeatureComponents`.`Feature_` "
2360 "FROM `Component`, `FeatureComponents` "
2361 "WHERE `Component` = 'zygomatic' "
2362 "AND `Feature_` = 'nasalis' "
2363 "ORDER BY `Feature_`";
2364 r = MsiDatabaseOpenView(hdb, query, &hview);
2367 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2370 r = MsiViewExecute(hview, 0);
2373 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2377 while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2379 count = MsiRecordGetFieldCount( hrec );
2380 ok( count == 2, "Expected 2 record fields, got %d\n", count );
2383 r = MsiRecordGetString( hrec, 1, buf, &size );
2384 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2385 ok( !lstrcmp( buf, join_res_seventh[i].one ),
2386 "For (row %d, column 1) expected '%s', got %s\n", i, join_res_seventh[i].one, buf );
2389 r = MsiRecordGetString( hrec, 2, buf, &size );
2390 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2391 ok( !lstrcmp( buf, join_res_seventh[i].two ),
2392 "For (row %d, column 2) expected '%s', got %s\n", i, join_res_seventh[i].two, buf );
2395 MsiCloseHandle(hrec);
2400 ok( i == 3, "Expected 3 rows, got %d\n", i );
2405 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2408 MsiViewClose(hview);
2409 MsiCloseHandle(hview);
2411 query = "SELECT `StdDlls`.`File`, `Binary`.`Data` "
2412 "FROM `StdDlls`, `Binary` ";
2413 r = MsiDatabaseOpenView(hdb, query, &hview);
2416 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2419 r = MsiViewExecute(hview, 0);
2422 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2426 while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2428 count = MsiRecordGetFieldCount( hrec );
2429 ok( count == 2, "Expected 2 record fields, got %d\n", count );
2432 r = MsiRecordGetString( hrec, 1, buf, &size );
2433 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2434 ok( !lstrcmp( buf, join_res_eighth[i].one ),
2435 "For (row %d, column 1) expected '%s', got %s\n", i, join_res_eighth[i].one, buf );
2438 r = MsiRecordGetString( hrec, 2, buf, &size );
2439 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2440 ok( !lstrcmp( buf, join_res_eighth[i].four ),
2441 "For (row %d, column 2) expected '%s', got %s\n", i, join_res_eighth[i].four, buf );
2444 MsiCloseHandle(hrec);
2449 ok( i == 6, "Expected 6 rows, got %d\n", i );
2450 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2453 MsiViewClose(hview);
2454 MsiCloseHandle(hview);
2456 query = "SELECT * FROM `StdDlls`, `Binary` ";
2457 r = MsiDatabaseOpenView(hdb, query, &hview);
2460 ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2463 r = MsiViewExecute(hview, 0);
2466 ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2470 while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2472 count = MsiRecordGetFieldCount( hrec );
2473 ok( count == 4, "Expected 4 record fields, got %d\n", count );
2476 r = MsiRecordGetString( hrec, 1, buf, &size );
2477 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2478 ok( !lstrcmp( buf, join_res_eighth[i].one ),
2479 "For (row %d, column 1) expected '%s', got %s\n", i, join_res_eighth[i].one, buf );
2482 r = MsiRecordGetString( hrec, 2, buf, &size );
2483 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2484 ok( !lstrcmp( buf, join_res_eighth[i].two ),
2485 "For (row %d, column 2) expected '%s', got %s\n", i, join_res_eighth[i].two, buf );
2488 r = MsiRecordGetString( hrec, 3, buf, &size );
2489 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2490 ok( !lstrcmp( buf, join_res_eighth[i].three ),
2491 "For (row %d, column 3) expected '%s', go %s\n", i, join_res_eighth[i].three, buf );
2494 r = MsiRecordGetString( hrec, 4, buf, &size );
2495 ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2496 ok( !lstrcmp( buf, join_res_eighth[i].four ),
2497 "For (row %d, column 4) expected '%s', got %s\n", i, join_res_eighth[i].four, buf );
2500 MsiCloseHandle(hrec);
2505 ok( i == 6, "Expected 6 rows, got %d\n", i );
2506 ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2509 MsiViewClose(hview);
2510 MsiCloseHandle(hview);
2512 MsiCloseHandle(hdb);
2513 DeleteFile(msifile);
2516 static void test_temporary_table(void)
2519 MSIHANDLE hdb = 0, view = 0, rec;
2525 cond = MsiDatabaseIsTablePersistent(0, NULL);
2526 ok( cond == MSICONDITION_ERROR, "wrong return condition\n");
2529 ok( hdb, "failed to create db\n");
2531 cond = MsiDatabaseIsTablePersistent(hdb, NULL);
2532 ok( cond == MSICONDITION_ERROR, "wrong return condition\n");
2535 cond = MsiDatabaseIsTablePersistent(hdb, "_Tables");
2536 ok( cond == MSICONDITION_NONE, "wrong return condition\n");
2538 cond = MsiDatabaseIsTablePersistent(hdb, "_Columns");
2539 ok( cond == MSICONDITION_NONE, "wrong return condition\n");
2541 cond = MsiDatabaseIsTablePersistent(hdb, "_Streams");
2542 ok( cond == MSICONDITION_NONE, "wrong return condition\n");
2545 query = "CREATE TABLE `P` ( `B` SHORT NOT NULL, `C` CHAR(255) PRIMARY KEY `C`)";
2546 r = run_query(hdb, 0, query);
2547 ok(r == ERROR_SUCCESS, "failed to add table\n");
2549 cond = MsiDatabaseIsTablePersistent(hdb, "P");
2550 todo_wine ok( cond == MSICONDITION_TRUE, "wrong return condition\n");
2552 query = "CREATE TABLE `P2` ( `B` SHORT NOT NULL, `C` CHAR(255) PRIMARY KEY `C`) HOLD";
2553 r = run_query(hdb, 0, query);
2554 ok(r == ERROR_SUCCESS, "failed to add table\n");
2557 cond = MsiDatabaseIsTablePersistent(hdb, "P");
2558 ok( cond == MSICONDITION_TRUE, "wrong return condition\n");
2561 query = "CREATE TABLE `T` ( `B` SHORT NOT NULL TEMPORARY, `C` CHAR(255) TEMPORARY PRIMARY KEY `C`) HOLD";
2562 r = run_query(hdb, 0, query);
2563 ok(r == ERROR_SUCCESS, "failed to add table\n");
2565 cond = MsiDatabaseIsTablePersistent(hdb, "T");
2566 ok( cond == MSICONDITION_FALSE, "wrong return condition\n");
2568 query = "CREATE TABLE `T2` ( `B` SHORT NOT NULL TEMPORARY, `C` CHAR(255) TEMPORARY PRIMARY KEY `C`)";
2569 r = run_query(hdb, 0, query);
2570 ok(r == ERROR_SUCCESS, "failed to add table\n");
2573 cond = MsiDatabaseIsTablePersistent(hdb, "T2");
2574 ok( cond == MSICONDITION_NONE, "wrong return condition\n");
2577 query = "CREATE TABLE `T3` ( `B` SHORT NOT NULL TEMPORARY, `C` CHAR(255) PRIMARY KEY `C`)";
2578 r = run_query(hdb, 0, query);
2579 ok(r == ERROR_SUCCESS, "failed to add table\n");
2582 cond = MsiDatabaseIsTablePersistent(hdb, "T3");
2583 ok( cond == MSICONDITION_TRUE, "wrong return condition\n");
2585 query = "CREATE TABLE `T4` ( `B` SHORT NOT NULL, `C` CHAR(255) TEMPORARY PRIMARY KEY `C`)";
2586 r = run_query(hdb, 0, query);
2587 ok(r == ERROR_FUNCTION_FAILED, "failed to add table\n");
2589 cond = MsiDatabaseIsTablePersistent(hdb, "T4");
2590 ok( cond == MSICONDITION_NONE, "wrong return condition\n");
2593 query = "CREATE TABLE `T5` ( `B` SHORT NOT NULL TEMP, `C` CHAR(255) TEMP PRIMARY KEY `C`) HOLD";
2594 r = run_query(hdb, 0, query);
2595 ok(r == ERROR_BAD_QUERY_SYNTAX, "failed to add table\n");
2597 query = "select * from `T`";
2598 r = MsiDatabaseOpenView(hdb, query, &view);
2599 ok(r == ERROR_SUCCESS, "failed to query table\n");
2600 r = MsiViewGetColumnInfo(view, MSICOLINFO_TYPES, &rec);
2601 ok(r == ERROR_SUCCESS, "failed to get column info\n");
2604 r = MsiRecordGetString(rec, 1, buf, &sz);
2605 ok(r == ERROR_SUCCESS, "failed to get string\n");
2606 todo_wine ok( 0 == strcmp("G255", buf), "wrong column type\n");
2609 r = MsiRecordGetString(rec, 2, buf, &sz);
2610 ok(r == ERROR_SUCCESS, "failed to get string\n");
2611 todo_wine ok( 0 == strcmp("j2", buf), "wrong column type\n");
2613 MsiCloseHandle( rec );
2614 MsiCloseHandle( view );
2616 /* query the table data */
2618 r = do_query(hdb, "select * from `_Tables` where `Name` = 'T'", &rec);
2619 ok( r == ERROR_SUCCESS, "temporary table exists in _Tables\n");
2620 MsiCloseHandle( rec );
2623 /* query the column data */
2625 r = do_query(hdb, "select * from `_Columns` where `Table` = 'T' AND `Name` = 'B'", &rec);
2626 ok( r == ERROR_NO_MORE_ITEMS, "temporary table exists in _Columns\n");
2627 if (rec) MsiCloseHandle( rec );
2629 r = do_query(hdb, "select * from `_Columns` where `Table` = 'T' AND `Name` = 'C'", &rec);
2630 ok( r == ERROR_NO_MORE_ITEMS, "temporary table exists in _Columns\n");
2631 if (rec) MsiCloseHandle( rec );
2634 MsiCloseHandle( hdb );
2636 DeleteFile(msifile);
2639 static void test_alter(void)
2647 ok( hdb, "failed to create db\n");
2649 query = "CREATE TABLE `T` ( `B` SHORT NOT NULL TEMPORARY, `C` CHAR(255) TEMPORARY PRIMARY KEY `C`) HOLD";
2650 r = run_query(hdb, 0, query);
2651 ok(r == ERROR_SUCCESS, "failed to add table\n");
2653 cond = MsiDatabaseIsTablePersistent(hdb, "T");
2654 ok( cond == MSICONDITION_FALSE, "wrong return condition\n");
2657 query = "ALTER TABLE `T` HOLD";
2658 r = run_query(hdb, 0, query);
2659 ok(r == ERROR_SUCCESS, "failed to hold table %d\n", r);
2661 query = "ALTER TABLE `T` FREE";
2662 r = run_query(hdb, 0, query);
2663 ok(r == ERROR_SUCCESS, "failed to free table\n");
2665 query = "ALTER TABLE `T` FREE";
2666 r = run_query(hdb, 0, query);
2667 ok(r == ERROR_SUCCESS, "failed to free table\n");
2670 query = "ALTER TABLE `T` FREE";
2671 r = run_query(hdb, 0, query);
2672 ok(r == ERROR_BAD_QUERY_SYNTAX, "failed to free table\n");
2674 query = "ALTER TABLE `T` HOLD";
2675 r = run_query(hdb, 0, query);
2676 ok(r == ERROR_BAD_QUERY_SYNTAX, "failed to hold table %d\n", r);
2678 MsiCloseHandle( hdb );
2680 DeleteFile(msifile);
2687 test_msidecomposedesc();
2688 test_msibadqueries();
2690 test_viewgetcolumninfo();
2698 test_handle_limit();
2699 test_try_transform();
2701 test_temporary_table();