dlls/msi/tests/db.c

   1 /*
   2  * Copyright (C) 2005 Mike McCormack for CodeWeavers
   3  *
   4  * A test program for MSI database files.
   5  *
   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.
  10  *
  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.
  15  *
  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
  19  */
  20
  21 #define COBJMACROS
  22
  23 #include <stdio.h>
  24
  25 #include <windows.h>
  26 #include <msi.h>
  27 #include <msiquery.h>
  28
  29 #include <objidl.h>
  30
  31 #include "wine/test.h"
  32
  33 static const char *msifile = "winetest.msi";
  34 static const char *msifile2 = "winetst2.msi";
  35 static const char *mstfile = "winetst.mst";
  36
  37 static void test_msidatabase(void)
  38 {
  39     MSIHANDLE hdb = 0, hdb2 = 0;
  40     UINT res;
  41
  42     DeleteFile(msifile);
  43
  44     res = MsiOpenDatabase( msifile, msifile2, &hdb );
  45     ok( res == ERROR_OPEN_FAILED, "expected failure\n");
  46
  47     res = MsiOpenDatabase( msifile, (LPSTR) 0xff, &hdb );
  48     ok( res == ERROR_INVALID_PARAMETER, "expected failure\n");
  49
  50     res = MsiCloseHandle( hdb );
  51     ok( res == ERROR_SUCCESS , "Failed to close database\n" );
  52
  53     /* create an empty database */
  54     res = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb );
  55     ok( res == ERROR_SUCCESS , "Failed to create database\n" );
  56
  57     res = MsiDatabaseCommit( hdb );
  58     ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
  59
  60     ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile ), "database should exist\n");
  61
  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" );
  66
  67     ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile2 ), "database should exist\n");
  68
  69     res = MsiDatabaseCommit( hdb2 );
  70     ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
  71
  72     res = MsiCloseHandle( hdb2 );
  73     ok( res == ERROR_SUCCESS , "Failed to close database\n" );
  74
  75     res = MsiOpenDatabase( msifile, msifile2, &hdb2 );
  76     ok( res == ERROR_SUCCESS , "Failed to open database\n" );
  77
  78     res = MsiCloseHandle( hdb2 );
  79     ok( res == ERROR_SUCCESS , "Failed to close database\n" );
  80
  81     ok( INVALID_FILE_ATTRIBUTES == GetFileAttributes( msifile2 ), "uncommitted database should not exist\n");
  82
  83     res = MsiOpenDatabase( msifile, msifile2, &hdb2 );
  84     ok( res == ERROR_SUCCESS , "Failed to close database\n" );
  85
  86     res = MsiDatabaseCommit( hdb2 );
  87     ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
  88
  89     res = MsiCloseHandle( hdb2 );
  90     ok( res == ERROR_SUCCESS , "Failed to close database\n" );
  91
  92     ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile2 ), "committed database should exist\n");
  93
  94     res = MsiOpenDatabase( msifile, MSIDBOPEN_READONLY, &hdb );
  95     ok( res == ERROR_SUCCESS , "Failed to open database\n" );
  96
  97     res = MsiCloseHandle( hdb );
  98     ok( res == ERROR_SUCCESS , "Failed to close database\n" );
  99
 100     res = MsiOpenDatabase( msifile, MSIDBOPEN_DIRECT, &hdb );
 101     ok( res == ERROR_SUCCESS , "Failed to open database\n" );
 102
 103     res = MsiCloseHandle( hdb );
 104     ok( res == ERROR_SUCCESS , "Failed to close database\n" );
 105
 106     res = MsiOpenDatabase( msifile, MSIDBOPEN_TRANSACT, &hdb );
 107     ok( res == ERROR_SUCCESS , "Failed to open database\n" );
 108
 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");
 112
 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" );
 116
 117     ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile ), "database should exist\n");
 118
 119     res = MsiCloseHandle( hdb );
 120     ok( res == ERROR_SUCCESS , "Failed to close database\n" );
 121
 122     ok( INVALID_FILE_ATTRIBUTES == GetFileAttributes( msifile ), "database should exist\n");
 123
 124     res = MsiOpenDatabase( msifile, MSIDBOPEN_CREATE, &hdb );
 125     ok( res == ERROR_SUCCESS , "Failed to open database\n" );
 126
 127     res = MsiDatabaseCommit( hdb );
 128     ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
 129
 130     ok( INVALID_FILE_ATTRIBUTES != GetFileAttributes( msifile ), "database should exist\n");
 131
 132     res = MsiCloseHandle( hdb );
 133     ok( res == ERROR_SUCCESS , "Failed to close database\n" );
 134
 135     res = DeleteFile( msifile2 );
 136     ok( res == TRUE, "Failed to delete database\n" );
 137
 138     res = DeleteFile( msifile );
 139     ok( res == TRUE, "Failed to delete database\n" );
 140 }
 141
 142 static UINT do_query(MSIHANDLE hdb, const char *query, MSIHANDLE *phrec)
 143 {
 144     MSIHANDLE hview = 0;
 145     UINT r, ret;
 146
 147     /* open a select query */
 148     r = MsiDatabaseOpenView(hdb, query, &hview);
 149     if (r != ERROR_SUCCESS)
 150         return r;
 151     r = MsiViewExecute(hview, 0);
 152     if (r != ERROR_SUCCESS)
 153         return r;
 154     ret = MsiViewFetch(hview, phrec);
 155     r = MsiViewClose(hview);
 156     if (r != ERROR_SUCCESS)
 157         return r;
 158     r = MsiCloseHandle(hview);
 159     if (r != ERROR_SUCCESS)
 160         return r;
 161     return ret;
 162 }
 163
 164 static UINT run_query( MSIHANDLE hdb, MSIHANDLE hrec, const char *query )
 165 {
 166     MSIHANDLE hview = 0;
 167     UINT r;
 168
 169     r = MsiDatabaseOpenView(hdb, query, &hview);
 170     if( r != ERROR_SUCCESS )
 171         return r;
 172
 173     r = MsiViewExecute(hview, hrec);
 174     if( r == ERROR_SUCCESS )
 175         r = MsiViewClose(hview);
 176     MsiCloseHandle(hview);
 177     return r;
 178 }
 179
 180 static UINT create_component_table( MSIHANDLE hdb )
 181 {
 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`)" );
 191 }
 192
 193 static UINT create_feature_components_table( MSIHANDLE hdb )
 194 {
 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_` )" );
 200 }
 201
 202 static UINT create_std_dlls_table( MSIHANDLE hdb )
 203 {
 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` )" );
 209 }
 210
 211 static UINT create_binary_table( MSIHANDLE hdb )
 212 {
 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` )" );
 218 }
 219
 220 static UINT add_component_entry( MSIHANDLE hdb, const char *values )
 221 {
 222     char insert[] = "INSERT INTO `Component`  "
 223             "(`Component`, `ComponentId`, `Directory_`, `Attributes`, `Condition`, `KeyPath`) "
 224             "VALUES( %s )";
 225     char *query;
 226     UINT sz, r;
 227
 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);
 233     return r;
 234 }
 235
 236 static UINT add_feature_components_entry( MSIHANDLE hdb, const char *values )
 237 {
 238     char insert[] = "INSERT INTO `FeatureComponents` "
 239             "(`Feature_`, `Component_`) "
 240             "VALUES( %s )";
 241     char *query;
 242     UINT sz, r;
 243
 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);
 249     return r;
 250 }
 251
 252 static UINT add_std_dlls_entry( MSIHANDLE hdb, const char *values )
 253 {
 254     char insert[] = "INSERT INTO `StdDlls` "
 255             "(`File`, `Binary_`) "
 256             "VALUES( %s )";
 257     char *query;
 258     UINT sz, r;
 259
 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);
 265     return r;
 266 }
 267
 268 static UINT add_binary_entry( MSIHANDLE hdb, const char *values )
 269 {
 270     char insert[] = "INSERT INTO `Binary` "
 271             "(`Name`, `Data`) "
 272             "VALUES( %s )";
 273     char *query;
 274     UINT sz, r;
 275
 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);
 281     return r;
 282 }
 283
 284 static void test_msiinsert(void)
 285 {
 286     MSIHANDLE hdb = 0, hview = 0, hrec = 0;
 287     UINT r;
 288     const char *query;
 289     char buf[80];
 290     DWORD sz;
 291
 292     DeleteFile(msifile);
 293
 294     /* just MsiOpenDatabase should not create a file */
 295     r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
 296     ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
 297
 298     /* create a table */
 299     query = "CREATE TABLE `phone` ( "
 300             "`id` INT, `name` CHAR(32), `number` CHAR(32) "
 301             "PRIMARY KEY `id`)";
 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");
 310
 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");
 322
 323     query = "SELECT * FROM `phone` WHERE `id` = 1";
 324     r = do_query(hdb, query, &hrec);
 325     ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
 326
 327     /* check the record contains what we put in it */
 328     r = MsiRecordGetFieldCount(hrec);
 329     ok(r == 3, "record count wrong\n");
 330
 331     todo_wine {
 332     r = MsiRecordIsNull(hrec, 0);
 333     ok(r == FALSE, "field 0 not null\n");
 334     }
 335
 336     r = MsiRecordGetInteger(hrec, 1);
 337     ok(r == 1, "field 1 contents wrong\n");
 338     sz = sizeof buf;
 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");
 342     sz = sizeof buf;
 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");
 346
 347     r = MsiCloseHandle(hrec);
 348     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
 349
 350     /* open a select query */
 351     hrec = 100;
 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");
 356
 357     r = MsiCloseHandle(hrec);
 358     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
 359
 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");
 363
 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");
 367
 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");
 371
 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");
 375
 376     /* now try a few bad INSERT xqueries */
 377     query = "INSERT INTO `phone` ( `id`, `name`, `number` )"
 378         "VALUES(?, ?)";
 379     r = MsiDatabaseOpenView(hdb, query, &hview);
 380     ok(r == ERROR_BAD_QUERY_SYNTAX, "MsiDatabaseOpenView failed\n");
 381
 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");
 390
 391     /* insert another value, using a record and wildcards */
 392     query = "INSERT INTO `phone` ( `id`, `name`, `number` )"
 393         "VALUES(?, ?, ?)";
 394     r = MsiDatabaseOpenView(hdb, query, &hview);
 395     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
 396
 397     if (r == ERROR_SUCCESS)
 398     {
 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");
 405     }
 406     r = MsiCloseHandle(hrec);
 407     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
 408
 409     r = MsiViewFetch(0, NULL);
 410     ok(r == ERROR_INVALID_PARAMETER, "MsiViewFetch failed\n");
 411
 412     r = MsiDatabaseCommit(hdb);
 413     ok(r == ERROR_SUCCESS, "MsiDatabaseCommit failed\n");
 414
 415     r = MsiCloseHandle(hdb);
 416     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
 417
 418     r = DeleteFile(msifile);
 419     ok(r == TRUE, "file didn't exist after commit\n");
 420 }
 421
 422 typedef UINT (WINAPI *fnMsiDecomposeDescriptorA)(LPCSTR, LPCSTR, LPSTR, LPSTR, DWORD *);
 423 static fnMsiDecomposeDescriptorA pMsiDecomposeDescriptorA;
 424
 425 static void test_msidecomposedesc(void)
 426 {
 427     char prod[MAX_FEATURE_CHARS+1], comp[MAX_FEATURE_CHARS+1], feature[MAX_FEATURE_CHARS+1];
 428     const char *desc;
 429     UINT r;
 430     DWORD len;
 431     HMODULE hmod;
 432
 433     hmod = GetModuleHandle("msi.dll");
 434     pMsiDecomposeDescriptorA = (fnMsiDecomposeDescriptorA)
 435         GetProcAddress(hmod, "MsiDecomposeDescriptorA");
 436     if (!pMsiDecomposeDescriptorA)
 437         return;
 438
 439     /* test a valid feature descriptor */
 440     desc = "']gAVn-}f(ZXfeAR6.jiFollowTheWhiteRabbit>3w2x^IGfe?CxI5heAvk.";
 441     len = 0;
 442     r = pMsiDecomposeDescriptorA(desc, prod, feature, comp, &len);
 443     ok(r == ERROR_SUCCESS, "returned an error\n");
 444     ok(len == strlen(desc), "length was wrong\n");
 445     ok(strcmp(prod,"{90110409-6000-11D3-8CFE-0150048383C9}")==0, "product wrong\n");
 446     ok(strcmp(feature,"FollowTheWhiteRabbit")==0, "feature wrong\n");
 447     ok(strcmp(comp,"{A7CD68DB-EF74-49C8-FBB2-A7C463B2AC24}")==0,"component wrong\n");
 448
 449     /* test an invalid feature descriptor with too many characters */
 450     desc = "']gAVn-}f(ZXfeAR6.ji"
 451            "ThisWillFailIfTheresMoreThanAGuidsChars>"
 452            "3w2x^IGfe?CxI5heAvk.";
 453     len = 0;
 454     r = pMsiDecomposeDescriptorA(desc, prod, feature, comp, &len);
 455     ok(r == ERROR_INVALID_PARAMETER, "returned wrong error\n");
 456
 457     /*
 458      * Test a valid feature descriptor with the
 459      * maximum number of characters and some trailing characters.
 460      */
 461     desc = "']gAVn-}f(ZXfeAR6.ji"
 462            "ThisWillWorkIfTheresLTEThanAGuidsChars>"
 463            "3w2x^IGfe?CxI5heAvk."
 464            "extra";
 465     len = 0;
 466     r = pMsiDecomposeDescriptorA(desc, prod, feature, comp, &len);
 467     ok(r == ERROR_SUCCESS, "returned wrong error\n");
 468     ok(len == (strlen(desc) - strlen("extra")), "length wrong\n");
 469
 470     len = 0;
 471     r = pMsiDecomposeDescriptorA(desc, prod, feature, NULL, &len);
 472     ok(r == ERROR_SUCCESS, "returned wrong error\n");
 473     ok(len == (strlen(desc) - strlen("extra")), "length wrong\n");
 474
 475     len = 0;
 476     r = pMsiDecomposeDescriptorA(desc, prod, NULL, NULL, &len);
 477     ok(r == ERROR_SUCCESS, "returned wrong error\n");
 478     ok(len == (strlen(desc) - strlen("extra")), "length wrong\n");
 479
 480     len = 0;
 481     r = pMsiDecomposeDescriptorA(desc, NULL, NULL, NULL, &len);
 482     ok(r == ERROR_SUCCESS, "returned wrong error\n");
 483     ok(len == (strlen(desc) - strlen("extra")), "length wrong\n");
 484
 485     len = 0;
 486     r = pMsiDecomposeDescriptorA(NULL, NULL, NULL, NULL, &len);
 487     ok(r == ERROR_INVALID_PARAMETER, "returned wrong error\n");
 488     ok(len == 0, "length wrong\n");
 489 }
 490
 491 static UINT try_query_param( MSIHANDLE hdb, LPCSTR szQuery, MSIHANDLE hrec )
 492 {
 493     MSIHANDLE htab = 0;
 494     UINT res;
 495
 496     res = MsiDatabaseOpenView( hdb, szQuery, &htab );
 497     if(res == ERROR_SUCCESS )
 498     {
 499         UINT r;
 500
 501         r = MsiViewExecute( htab, hrec );
 502         if(r != ERROR_SUCCESS )
 503             res = r;
 504
 505         r = MsiViewClose( htab );
 506         if(r != ERROR_SUCCESS )
 507             res = r;
 508
 509         r = MsiCloseHandle( htab );
 510         if(r != ERROR_SUCCESS )
 511             res = r;
 512     }
 513     return res;
 514 }
 515
 516 static UINT try_query( MSIHANDLE hdb, LPCSTR szQuery )
 517 {
 518     return try_query_param( hdb, szQuery, 0 );
 519 }
 520
 521 static UINT try_insert_query( MSIHANDLE hdb, LPCSTR szQuery )
 522 {
 523     MSIHANDLE hrec = 0;
 524     UINT r;
 525
 526     hrec = MsiCreateRecord( 1 );
 527     MsiRecordSetString( hrec, 1, "Hello");
 528
 529     r = try_query_param( hdb, szQuery, hrec );
 530
 531     MsiCloseHandle( hrec );
 532     return r;
 533 }
 534
 535 static void test_msibadqueries(void)
 536 {
 537     MSIHANDLE hdb = 0;
 538     UINT r;
 539
 540     DeleteFile(msifile);
 541
 542     /* just MsiOpenDatabase should not create a file */
 543     r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
 544     ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
 545
 546     r = MsiDatabaseCommit( hdb );
 547     ok(r == ERROR_SUCCESS , "Failed to commit database\n");
 548
 549     r = MsiCloseHandle( hdb );
 550     ok(r == ERROR_SUCCESS , "Failed to close database\n");
 551
 552     /* open it readonly */
 553     r = MsiOpenDatabase(msifile, MSIDBOPEN_READONLY, &hdb );
 554     ok(r == ERROR_SUCCESS , "Failed to open database r/o\n");
 555
 556     /* add a table to it */
 557     r = try_query( hdb, "select * from _Tables");
 558     ok(r == ERROR_SUCCESS , "query 1 failed\n");
 559
 560     r = MsiCloseHandle( hdb );
 561     ok(r == ERROR_SUCCESS , "Failed to close database r/o\n");
 562
 563     /* open it read/write */
 564     r = MsiOpenDatabase(msifile, MSIDBOPEN_TRANSACT, &hdb );
 565     ok(r == ERROR_SUCCESS , "Failed to open database r/w\n");
 566
 567     /* a bunch of test queries that fail with the native MSI */
 568
 569     r = try_query( hdb, "CREATE TABLE");
 570     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2a return code\n");
 571
 572     r = try_query( hdb, "CREATE TABLE `a`");
 573     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2b return code\n");
 574
 575     r = try_query( hdb, "CREATE TABLE `a` ()");
 576     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2c return code\n");
 577
 578     r = try_query( hdb, "CREATE TABLE `a` (`b`)");
 579     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2d return code\n");
 580
 581     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) )");
 582     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2e return code\n");
 583
 584     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL)");
 585     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2f return code\n");
 586
 587     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY)");
 588     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2g return code\n");
 589
 590     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY)");
 591     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2h return code\n");
 592
 593     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY)");
 594     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2i return code\n");
 595
 596     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY 'b')");
 597     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2j return code\n");
 598
 599     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY `b')");
 600     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2k return code\n");
 601
 602     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY `b')");
 603     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2l return code\n");
 604
 605     r = try_query( hdb, "CREATE TABLE `a` (`b` CHA(72) NOT NULL PRIMARY KEY `b`)");
 606     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2m return code\n");
 607
 608     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(-1) NOT NULL PRIMARY KEY `b`)");
 609     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2n return code\n");
 610
 611     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(720) NOT NULL PRIMARY KEY `b`)");
 612     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2o return code\n");
 613
 614     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL KEY `b`)");
 615     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2p return code\n");
 616
 617     r = try_query( hdb, "CREATE TABLE `a` (`` CHAR(72) NOT NULL PRIMARY KEY `b`)");
 618     ok(r == ERROR_BAD_QUERY_SYNTAX , "invalid query 2p return code\n");
 619
 620     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY `b`)");
 621     ok(r == ERROR_SUCCESS , "valid query 2z failed\n");
 622
 623     r = try_query( hdb, "CREATE TABLE `a` (`b` CHAR(72) NOT NULL PRIMARY KEY `b`)");
 624     ok(r == ERROR_BAD_QUERY_SYNTAX , "created same table again\n");
 625
 626     r = try_query( hdb, "CREATE TABLE `aa` (`b` CHAR(72) NOT NULL, `c` "
 627           "CHAR(72), `d` CHAR(255) NOT NULL LOCALIZABLE PRIMARY KEY `b`)");
 628     ok(r == ERROR_SUCCESS , "query 4 failed\n");
 629
 630     r = MsiDatabaseCommit( hdb );
 631     ok(r == ERROR_SUCCESS , "Failed to commit database after write\n");
 632
 633     r = try_query( hdb, "CREATE TABLE `blah` (`foo` CHAR(72) NOT NULL "
 634                           "PRIMARY KEY `foo`)");
 635     ok(r == ERROR_SUCCESS , "query 4 failed\n");
 636
 637     r = try_insert_query( hdb, "insert into a  ( `b` ) VALUES ( ? )");
 638     ok(r == ERROR_SUCCESS , "failed to insert record in db\n");
 639
 640     r = MsiDatabaseCommit( hdb );
 641     ok(r == ERROR_SUCCESS , "Failed to commit database after write\n");
 642
 643     r = try_query( hdb, "CREATE TABLE `boo` (`foo` CHAR(72) NOT NULL "
 644                           "PRIMARY KEY `ba`)");
 645     ok(r != ERROR_SUCCESS , "query 5 succeeded\n");
 646
 647     r = try_query( hdb,"CREATE TABLE `bee` (`foo` CHAR(72) NOT NULL )");
 648     ok(r != ERROR_SUCCESS , "query 6 succeeded\n");
 649
 650     r = try_query( hdb, "CREATE TABLE `temp` (`t` CHAR(72) NOT NULL "
 651                           "PRIMARY KEY `t`)");
 652     ok(r == ERROR_SUCCESS , "query 7 failed\n");
 653
 654     r = try_query( hdb, "CREATE TABLE `c` (`b` CHAR NOT NULL PRIMARY KEY `b`)");
 655     ok(r == ERROR_SUCCESS , "query 8 failed\n");
 656
 657     r = try_query( hdb, "select * from c");
 658     ok(r == ERROR_SUCCESS , "query failed\n");
 659
 660     r = try_query( hdb, "select * from c where b = 'x");
 661     todo_wine ok(r == ERROR_BAD_QUERY_SYNTAX, "query failed\n");
 662
 663     r = try_query( hdb, "select * from 'c'");
 664     ok(r == ERROR_BAD_QUERY_SYNTAX, "query failed\n");
 665
 666     r = try_query( hdb, "select * from ''");
 667     ok(r == ERROR_BAD_QUERY_SYNTAX, "query failed\n");
 668
 669     r = try_query( hdb, "select * from c where b = x");
 670     ok(r == ERROR_BAD_QUERY_SYNTAX, "query failed\n");
 671
 672     r = try_query( hdb, "select * from c where b = \"x\"");
 673     ok(r == ERROR_BAD_QUERY_SYNTAX, "query failed\n");
 674
 675     r = try_query( hdb, "select * from c where b = 'x'");
 676     ok(r == ERROR_SUCCESS, "query failed\n");
 677
 678     r = try_query( hdb, "select * from c where b = '\"x'");
 679     ok(r == ERROR_SUCCESS, "query failed\n");
 680
 681     if (0)  /* FIXME: this query causes trouble with other tests */
 682     {
 683         r = try_query( hdb, "select * from c where b = '\\\'x'");
 684         ok(r == ERROR_BAD_QUERY_SYNTAX, "query failed\n");
 685     }
 686
 687     r = try_query( hdb, "select * from 'c'");
 688     ok(r == ERROR_BAD_QUERY_SYNTAX, "query failed\n");
 689
 690     r = MsiCloseHandle( hdb );
 691     ok(r == ERROR_SUCCESS , "Failed to close database transact\n");
 692
 693     r = DeleteFile( msifile );
 694     ok(r == TRUE, "file didn't exist after commit\n");
 695 }
 696
 697 static void test_viewmodify(void)
 698 {
 699     MSIHANDLE hdb = 0, hview = 0, hrec = 0;
 700     UINT r;
 701     const char *query;
 702     char buffer[0x100];
 703     DWORD sz;
 704
 705     DeleteFile(msifile);
 706
 707     /* just MsiOpenDatabase should not create a file */
 708     r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
 709     ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
 710
 711     query = "CREATE TABLE `phone` ( "
 712             "`id` INT, `name` CHAR(32), `number` CHAR(32) "
 713             "PRIMARY KEY `id`)";
 714     r = run_query( hdb, 0, query );
 715     ok(r == ERROR_SUCCESS, "query failed\n");
 716
 717     /* check what the error function reports without doing anything */
 718     sz = 0;
 719     /* passing NULL as the 3rd param make function to crash on older platforms */
 720     r = MsiViewGetError( 0, NULL, &sz );
 721     ok(r == MSIDBERROR_INVALIDARG, "MsiViewGetError return\n");
 722
 723     /* open a view */
 724     query = "SELECT * FROM `phone`";
 725     r = MsiDatabaseOpenView(hdb, query, &hview);
 726     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
 727
 728     /* see what happens with a good hview and bad args */
 729     r = MsiViewGetError( hview, NULL, NULL );
 730     ok(r == MSIDBERROR_INVALIDARG || r == MSIDBERROR_NOERROR,
 731        "MsiViewGetError returns %u (expected -3)\n", r);
 732     r = MsiViewGetError( hview, buffer, NULL );
 733     ok(r == MSIDBERROR_INVALIDARG, "MsiViewGetError return\n");
 734
 735     /* see what happens with a zero length buffer */
 736     sz = 0;
 737     buffer[0] = 'x';
 738     r = MsiViewGetError( hview, buffer, &sz );
 739     ok(r == MSIDBERROR_MOREDATA, "MsiViewGetError return\n");
 740     ok(buffer[0] == 'x', "buffer cleared\n");
 741     ok(sz == 0, "size not zero\n");
 742
 743     /* ok this one is strange */
 744     sz = 0;
 745     r = MsiViewGetError( hview, NULL, &sz );
 746     ok(r == MSIDBERROR_NOERROR, "MsiViewGetError return\n");
 747     ok(sz == 0, "size not zero\n");
 748
 749     /* see if it really has an error */
 750     sz = sizeof buffer;
 751     buffer[0] = 'x';
 752     r = MsiViewGetError( hview, buffer, &sz );
 753     ok(r == MSIDBERROR_NOERROR, "MsiViewGetError return\n");
 754     ok(buffer[0] == 0, "buffer not cleared\n");
 755     ok(sz == 0, "size not zero\n");
 756
 757     r = MsiViewExecute(hview, 0);
 758     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
 759
 760     /* try some invalid records */
 761     r = MsiViewModify(hview, MSIMODIFY_INSERT, 0 );
 762     ok(r == ERROR_INVALID_HANDLE, "MsiViewModify failed\n");
 763     r = MsiViewModify(hview, -1, 0 );
 764     ok(r == ERROR_INVALID_HANDLE, "MsiViewModify failed\n");
 765
 766     /* try an small record */
 767     hrec = MsiCreateRecord(1);
 768     r = MsiViewModify(hview, -1, hrec );
 769     ok(r == ERROR_INVALID_DATA, "MsiViewModify failed\n");
 770
 771     r = MsiCloseHandle(hrec);
 772     ok(r == ERROR_SUCCESS, "failed to close record\n");
 773
 774     /* insert a valid record */
 775     hrec = MsiCreateRecord(3);
 776
 777     r = MsiRecordSetInteger(hrec, 1, 1);
 778     ok(r == ERROR_SUCCESS, "failed to set integer\n");
 779     r = MsiRecordSetString(hrec, 2, "bob");
 780     ok(r == ERROR_SUCCESS, "failed to set string\n");
 781     r = MsiRecordSetString(hrec, 3, "7654321");
 782     ok(r == ERROR_SUCCESS, "failed to set string\n");
 783
 784     r = MsiViewExecute(hview, 0);
 785     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
 786     r = MsiViewModify(hview, MSIMODIFY_INSERT_TEMPORARY, hrec );
 787     ok(r == ERROR_SUCCESS, "MsiViewModify failed\n");
 788
 789     /* insert the same thing again */
 790     r = MsiViewExecute(hview, 0);
 791     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
 792
 793     /* should fail ... */
 794     todo_wine {
 795     r = MsiViewModify(hview, MSIMODIFY_INSERT_TEMPORARY, hrec );
 796     ok(r == ERROR_FUNCTION_FAILED, "MsiViewModify failed\n");
 797     }
 798
 799     r = MsiCloseHandle(hrec);
 800     ok(r == ERROR_SUCCESS, "failed to close record\n");
 801
 802     r = MsiViewClose(hview);
 803     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
 804     r = MsiCloseHandle(hview);
 805     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
 806
 807     query = "SELECT * FROM `phone`";
 808     r = MsiDatabaseOpenView(hdb, query, &hview);
 809     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
 810
 811     r = MsiViewExecute(hview, 0);
 812     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
 813
 814     r = MsiViewFetch(hview, &hrec);
 815     ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
 816
 817     r = MsiRecordGetInteger(hrec, 1);
 818     ok(r == 1, "Expected 1, got %d\n", r);
 819
 820     sz = sizeof(buffer);
 821     r = MsiRecordGetString(hrec, 2, buffer, &sz);
 822     ok(r == ERROR_SUCCESS, "MsiRecordGetString failed\n");
 823     ok(!lstrcmp(buffer, "bob"), "Expected bob, got %s\n", buffer);
 824
 825     sz = sizeof(buffer);
 826     r = MsiRecordGetString(hrec, 3, buffer, &sz);
 827     ok(r == ERROR_SUCCESS, "MsiRecordGetString failed\n");
 828     ok(!lstrcmp(buffer, "7654321"), "Expected 7654321, got %s\n", buffer);
 829
 830     /* update the view, non-primary key */
 831     r = MsiRecordSetString(hrec, 3, "3141592");
 832     ok(r == ERROR_SUCCESS, "MsiRecordSetString failed\n");
 833
 834     r = MsiViewModify(hview, MSIMODIFY_UPDATE, hrec);
 835     ok(r == ERROR_SUCCESS, "MsiViewModify failed\n");
 836
 837     /* do it again */
 838     r = MsiViewModify(hview, MSIMODIFY_UPDATE, hrec);
 839     ok(r == ERROR_SUCCESS, "MsiViewModify failed: %d\n", r);
 840
 841     /* update the view, primary key */
 842     r = MsiRecordSetInteger(hrec, 1, 5);
 843     ok(r == ERROR_SUCCESS, "MsiRecordSetInteger failed\n");
 844
 845     r = MsiViewModify(hview, MSIMODIFY_UPDATE, hrec);
 846     todo_wine
 847     {
 848         ok(r == ERROR_FUNCTION_FAILED, "MsiViewModify failed\n");
 849     }
 850
 851     r = MsiCloseHandle(hrec);
 852     ok(r == ERROR_SUCCESS, "failed to close record\n");
 853
 854     r = MsiViewClose(hview);
 855     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
 856     r = MsiCloseHandle(hview);
 857     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
 858
 859     query = "SELECT * FROM `phone`";
 860     r = MsiDatabaseOpenView(hdb, query, &hview);
 861     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
 862
 863     r = MsiViewExecute(hview, 0);
 864     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
 865
 866     r = MsiViewFetch(hview, &hrec);
 867     ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
 868
 869     r = MsiRecordGetInteger(hrec, 1);
 870     ok(r == 1, "Expected 1, got %d\n", r);
 871
 872     sz = sizeof(buffer);
 873     r = MsiRecordGetString(hrec, 2, buffer, &sz);
 874     ok(r == ERROR_SUCCESS, "MsiRecordGetString failed\n");
 875     ok(!lstrcmp(buffer, "bob"), "Expected bob, got %s\n", buffer);
 876
 877     sz = sizeof(buffer);
 878     r = MsiRecordGetString(hrec, 3, buffer, &sz);
 879     ok(r == ERROR_SUCCESS, "MsiRecordGetString failed\n");
 880     ok(!lstrcmp(buffer, "3141592"), "Expected 3141592, got %s\n", buffer);
 881
 882     r = MsiCloseHandle(hrec);
 883     ok(r == ERROR_SUCCESS, "failed to close record\n");
 884
 885     /* use a record that doesn't come from a view fetch */
 886     hrec = MsiCreateRecord(3);
 887     ok(hrec != 0, "MsiCreateRecord failed\n");
 888
 889     r = MsiRecordSetInteger(hrec, 1, 3);
 890     ok(r == ERROR_SUCCESS, "failed to set integer\n");
 891     r = MsiRecordSetString(hrec, 2, "jane");
 892     ok(r == ERROR_SUCCESS, "failed to set string\n");
 893     r = MsiRecordSetString(hrec, 3, "112358");
 894     ok(r == ERROR_SUCCESS, "failed to set string\n");
 895
 896     r = MsiViewModify(hview, MSIMODIFY_UPDATE, hrec);
 897     todo_wine
 898     {
 899         ok(r == ERROR_FUNCTION_FAILED, "Expected ERROR_FUNCTION_FAILED, got %d\n", r);
 900     }
 901
 902     r = MsiCloseHandle(hrec);
 903     ok(r == ERROR_SUCCESS, "failed to close record\n");
 904
 905     /* use a record that doesn't come from a view fetch, primary key matches */
 906     hrec = MsiCreateRecord(3);
 907     ok(hrec != 0, "MsiCreateRecord failed\n");
 908
 909     r = MsiRecordSetInteger(hrec, 1, 1);
 910     ok(r == ERROR_SUCCESS, "failed to set integer\n");
 911     r = MsiRecordSetString(hrec, 2, "jane");
 912     ok(r == ERROR_SUCCESS, "failed to set string\n");
 913     r = MsiRecordSetString(hrec, 3, "112358");
 914     ok(r == ERROR_SUCCESS, "failed to set string\n");
 915
 916     r = MsiViewModify(hview, MSIMODIFY_UPDATE, hrec);
 917     todo_wine
 918     {
 919         ok(r == ERROR_FUNCTION_FAILED, "MsiViewModify failed\n");
 920     }
 921
 922     r = MsiCloseHandle(hrec);
 923     ok(r == ERROR_SUCCESS, "failed to close record\n");
 924
 925     hrec = MsiCreateRecord(3);
 926
 927     r = MsiRecordSetInteger(hrec, 1, 2);
 928     ok(r == ERROR_SUCCESS, "failed to set integer\n");
 929     r = MsiRecordSetString(hrec, 2, "nick");
 930     ok(r == ERROR_SUCCESS, "failed to set string\n");
 931     r = MsiRecordSetString(hrec, 3, "141421");
 932     ok(r == ERROR_SUCCESS, "failed to set string\n");
 933
 934     r = MsiViewExecute(hview, 0);
 935     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
 936     r = MsiViewModify(hview, MSIMODIFY_INSERT_TEMPORARY, hrec );
 937     ok(r == ERROR_SUCCESS, "MsiViewModify failed\n");
 938
 939     r = MsiViewClose(hview);
 940     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
 941     r = MsiCloseHandle(hview);
 942     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
 943
 944     query = "SELECT * FROM `phone` WHERE `id` = 1";
 945     r = MsiDatabaseOpenView(hdb, query, &hview);
 946     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
 947     r = MsiViewExecute(hview, 0);
 948     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
 949     r = MsiViewFetch(hview, &hrec);
 950     ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
 951
 952     /* change the id to match the second row */
 953     r = MsiRecordSetInteger(hrec, 1, 2);
 954     ok(r == ERROR_SUCCESS, "failed to set integer\n");
 955     r = MsiRecordSetString(hrec, 2, "jerry");
 956     ok(r == ERROR_SUCCESS, "failed to set string\n");
 957
 958     r = MsiViewModify(hview, MSIMODIFY_UPDATE, hrec);
 959     ok(r == ERROR_FUNCTION_FAILED, "MsiViewModify failed\n");
 960
 961     r = MsiCloseHandle(hrec);
 962     ok(r == ERROR_SUCCESS, "failed to close record\n");
 963     r = MsiViewClose(hview);
 964     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
 965     r = MsiCloseHandle(hview);
 966     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
 967
 968     /* broader search */
 969     query = "SELECT * FROM `phone` ORDER BY `id`";
 970     r = MsiDatabaseOpenView(hdb, query, &hview);
 971     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
 972     r = MsiViewExecute(hview, 0);
 973     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
 974     r = MsiViewFetch(hview, &hrec);
 975     ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
 976
 977     /* change the id to match the second row */
 978     r = MsiRecordSetInteger(hrec, 1, 2);
 979     ok(r == ERROR_SUCCESS, "failed to set integer\n");
 980     r = MsiRecordSetString(hrec, 2, "jerry");
 981     ok(r == ERROR_SUCCESS, "failed to set string\n");
 982
 983     r = MsiViewModify(hview, MSIMODIFY_UPDATE, hrec);
 984     ok(r == ERROR_FUNCTION_FAILED, "MsiViewModify failed\n");
 985
 986     r = MsiCloseHandle(hrec);
 987     ok(r == ERROR_SUCCESS, "failed to close record\n");
 988     r = MsiViewClose(hview);
 989     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
 990     r = MsiCloseHandle(hview);
 991     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
 992
 993     r = MsiCloseHandle( hdb );
 994     ok(r == ERROR_SUCCESS, "MsiOpenDatabase close failed\n");
 995 }
 996
 997 static MSIHANDLE create_db(void)
 998 {
 999     MSIHANDLE hdb = 0;
1000     UINT res;
1001
1002     DeleteFile(msifile);
1003
1004     /* create an empty database */
1005     res = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb );
1006     ok( res == ERROR_SUCCESS , "Failed to create database\n" );
1007     if( res != ERROR_SUCCESS )
1008         return hdb;
1009
1010     res = MsiDatabaseCommit( hdb );
1011     ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
1012
1013     return hdb;
1014 }
1015
1016 static void test_getcolinfo(void)
1017 {
1018     MSIHANDLE hdb, hview = 0, rec = 0;
1019     UINT r;
1020     DWORD sz;
1021     char buffer[0x20];
1022
1023     /* create an empty db */
1024     hdb = create_db();
1025     ok( hdb, "failed to create db\n");
1026
1027     /* tables should be present */
1028     r = MsiDatabaseOpenView(hdb, "select * from _Tables", &hview);
1029     ok( r == ERROR_SUCCESS, "failed to open query\n");
1030
1031     r = MsiViewExecute(hview, 0);
1032     ok( r == ERROR_SUCCESS, "failed to execute query\n");
1033
1034     /* check that NAMES works */
1035     rec = 0;
1036     r = MsiViewGetColumnInfo( hview, MSICOLINFO_NAMES, &rec );
1037     ok( r == ERROR_SUCCESS, "failed to get names\n");
1038     sz = sizeof buffer;
1039     r = MsiRecordGetString(rec, 1, buffer, &sz );
1040     ok( r == ERROR_SUCCESS, "failed to get string\n");
1041     ok( !strcmp(buffer,"Name"), "_Tables has wrong column name\n");
1042     r = MsiCloseHandle( rec );
1043     ok( r == ERROR_SUCCESS, "failed to close record handle\n");
1044
1045     /* check that TYPES works */
1046     rec = 0;
1047     r = MsiViewGetColumnInfo( hview, MSICOLINFO_TYPES, &rec );
1048     ok( r == ERROR_SUCCESS, "failed to get names\n");
1049     sz = sizeof buffer;
1050     r = MsiRecordGetString(rec, 1, buffer, &sz );
1051     ok( r == ERROR_SUCCESS, "failed to get string\n");
1052     ok( !strcmp(buffer,"s64"), "_Tables has wrong column type\n");
1053     r = MsiCloseHandle( rec );
1054     ok( r == ERROR_SUCCESS, "failed to close record handle\n");
1055
1056     /* check that invalid values fail */
1057     rec = 0;
1058     r = MsiViewGetColumnInfo( hview, 100, &rec );
1059     ok( r == ERROR_INVALID_PARAMETER, "wrong error code\n");
1060     ok( rec == 0, "returned a record\n");
1061
1062     r = MsiViewGetColumnInfo( hview, MSICOLINFO_TYPES, NULL );
1063     ok( r == ERROR_INVALID_PARAMETER, "wrong error code\n");
1064
1065     r = MsiViewGetColumnInfo( 0, MSICOLINFO_TYPES, &rec );
1066     ok( r == ERROR_INVALID_HANDLE, "wrong error code\n");
1067
1068     r = MsiViewClose(hview);
1069     ok( r == ERROR_SUCCESS, "failed to close view\n");
1070     r = MsiCloseHandle(hview);
1071     ok( r == ERROR_SUCCESS, "failed to close view handle\n");
1072     r = MsiCloseHandle(hdb);
1073     ok( r == ERROR_SUCCESS, "failed to close database\n");
1074 }
1075
1076 static MSIHANDLE get_column_info(MSIHANDLE hdb, const char *query, MSICOLINFO type)
1077 {
1078     MSIHANDLE hview = 0, rec = 0;
1079     UINT r;
1080
1081     r = MsiDatabaseOpenView(hdb, query, &hview);
1082     if( r != ERROR_SUCCESS )
1083         return r;
1084
1085     r = MsiViewExecute(hview, 0);
1086     if( r == ERROR_SUCCESS )
1087     {
1088         MsiViewGetColumnInfo( hview, type, &rec );
1089         MsiViewClose(hview);
1090     }
1091     MsiCloseHandle(hview);
1092     return rec;
1093 }
1094
1095 static UINT get_columns_table_type(MSIHANDLE hdb, const char *table, UINT field)
1096 {
1097     MSIHANDLE hview = 0, rec = 0;
1098     UINT r, type = 0;
1099     char query[0x100];
1100
1101     sprintf(query, "select * from `_Columns` where  `Table` = '%s'", table );
1102
1103     r = MsiDatabaseOpenView(hdb, query, &hview);
1104     if( r != ERROR_SUCCESS )
1105         return r;
1106
1107     r = MsiViewExecute(hview, 0);
1108     if( r == ERROR_SUCCESS )
1109     {
1110         while (1)
1111         {
1112             r = MsiViewFetch( hview, &rec );
1113             if( r != ERROR_SUCCESS)
1114                 break;
1115             r = MsiRecordGetInteger( rec, 2 );
1116             if (r == field)
1117                 type = MsiRecordGetInteger( rec, 4 );
1118             MsiCloseHandle( rec );
1119         }
1120
1121         MsiViewClose(hview);
1122     }
1123     MsiCloseHandle(hview);
1124     return type;
1125 }
1126
1127 static BOOL check_record( MSIHANDLE rec, UINT field, LPCSTR val )
1128 {
1129     CHAR buffer[0x20];
1130     UINT r;
1131     DWORD sz;
1132
1133     sz = sizeof buffer;
1134     r = MsiRecordGetString( rec, field, buffer, &sz );
1135     return (r == ERROR_SUCCESS ) && !strcmp(val, buffer);
1136 }
1137
1138 static void test_viewgetcolumninfo(void)
1139 {
1140     MSIHANDLE hdb = 0, rec;
1141     UINT r;
1142
1143     hdb = create_db();
1144     ok( hdb, "failed to create db\n");
1145
1146     r = run_query( hdb, 0,
1147             "CREATE TABLE `Properties` "
1148             "( `Property` CHAR(255), `Value` CHAR(1)  PRIMARY KEY `Property`)" );
1149     ok( r == ERROR_SUCCESS , "Failed to create table\n" );
1150
1151     /* check the column types */
1152     rec = get_column_info( hdb, "select * from `Properties`", MSICOLINFO_TYPES );
1153     ok( rec, "failed to get column info record\n" );
1154
1155     ok( check_record( rec, 1, "S255"), "wrong record type\n");
1156     ok( check_record( rec, 2, "S1"), "wrong record type\n");
1157
1158     MsiCloseHandle( rec );
1159
1160     /* check the type in _Columns */
1161     ok( 0x3dff == get_columns_table_type(hdb, "Properties", 1 ), "_columns table wrong\n");
1162     ok( 0x1d01 == get_columns_table_type(hdb, "Properties", 2 ), "_columns table wrong\n");
1163
1164     /* now try the names */
1165     rec = get_column_info( hdb, "select * from `Properties`", MSICOLINFO_NAMES );
1166     ok( rec, "failed to get column info record\n" );
1167
1168     ok( check_record( rec, 1, "Property"), "wrong record type\n");
1169     ok( check_record( rec, 2, "Value"), "wrong record type\n");
1170
1171     MsiCloseHandle( rec );
1172
1173     r = run_query( hdb, 0,
1174             "CREATE TABLE `Binary` "
1175             "( `Name` CHAR(255), `Data` OBJECT  PRIMARY KEY `Name`)" );
1176     ok( r == ERROR_SUCCESS , "Failed to create table\n" );
1177
1178     /* check the column types */
1179     rec = get_column_info( hdb, "select * from `Binary`", MSICOLINFO_TYPES );
1180     ok( rec, "failed to get column info record\n" );
1181
1182     ok( check_record( rec, 1, "S255"), "wrong record type\n");
1183     ok( check_record( rec, 2, "V0"), "wrong record type\n");
1184
1185     MsiCloseHandle( rec );
1186
1187     /* check the type in _Columns */
1188     ok( 0x3dff == get_columns_table_type(hdb, "Binary", 1 ), "_columns table wrong\n");
1189     ok( 0x1900 == get_columns_table_type(hdb, "Binary", 2 ), "_columns table wrong\n");
1190
1191     /* now try the names */
1192     rec = get_column_info( hdb, "select * from `Binary`", MSICOLINFO_NAMES );
1193     ok( rec, "failed to get column info record\n" );
1194
1195     ok( check_record( rec, 1, "Name"), "wrong record type\n");
1196     ok( check_record( rec, 2, "Data"), "wrong record type\n");
1197     MsiCloseHandle( rec );
1198
1199     r = run_query( hdb, 0,
1200             "CREATE TABLE `UIText` "
1201             "( `Key` CHAR(72) NOT NULL, `Text` CHAR(255) LOCALIZABLE PRIMARY KEY `Key`)" );
1202     ok( r == ERROR_SUCCESS , "Failed to create table\n" );
1203
1204     ok( 0x2d48 == get_columns_table_type(hdb, "UIText", 1 ), "_columns table wrong\n");
1205     ok( 0x1fff == get_columns_table_type(hdb, "UIText", 2 ), "_columns table wrong\n");
1206
1207     rec = get_column_info( hdb, "select * from `UIText`", MSICOLINFO_NAMES );
1208     ok( rec, "failed to get column info record\n" );
1209     ok( check_record( rec, 1, "Key"), "wrong record type\n");
1210     ok( check_record( rec, 2, "Text"), "wrong record type\n");
1211     MsiCloseHandle( rec );
1212
1213     rec = get_column_info( hdb, "select * from `UIText`", MSICOLINFO_TYPES );
1214     ok( rec, "failed to get column info record\n" );
1215     ok( check_record( rec, 1, "s72"), "wrong record type\n");
1216     ok( check_record( rec, 2, "L255"), "wrong record type\n");
1217     MsiCloseHandle( rec );
1218
1219     MsiCloseHandle( hdb );
1220 }
1221
1222 static void test_msiexport(void)
1223 {
1224     MSIHANDLE hdb = 0, hview = 0;
1225     UINT r;
1226     const char *query;
1227     char path[MAX_PATH];
1228     const char file[] = "phone.txt";
1229     HANDLE handle;
1230     char buffer[0x100];
1231     DWORD length;
1232     const char expected[] =
1233         "id\tname\tnumber\r\n"
1234         "I2\tS32\tS32\r\n"
1235         "phone\tid\r\n"
1236         "1\tAbe\t8675309\r\n";
1237
1238     DeleteFile(msifile);
1239
1240     /* just MsiOpenDatabase should not create a file */
1241     r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
1242     ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
1243
1244     /* create a table */
1245     query = "CREATE TABLE `phone` ( "
1246             "`id` INT, `name` CHAR(32), `number` CHAR(32) "
1247             "PRIMARY KEY `id`)";
1248     r = MsiDatabaseOpenView(hdb, query, &hview);
1249     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
1250     r = MsiViewExecute(hview, 0);
1251     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
1252     r = MsiViewClose(hview);
1253     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
1254     r = MsiCloseHandle(hview);
1255     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
1256
1257     /* insert a value into it */
1258     query = "INSERT INTO `phone` ( `id`, `name`, `number` )"
1259         "VALUES('1', 'Abe', '8675309')";
1260     r = MsiDatabaseOpenView(hdb, query, &hview);
1261     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
1262     r = MsiViewExecute(hview, 0);
1263     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
1264     r = MsiViewClose(hview);
1265     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
1266     r = MsiCloseHandle(hview);
1267     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
1268
1269     GetCurrentDirectory(MAX_PATH, path);
1270
1271     r = MsiDatabaseExport(hdb, "phone", path, file);
1272     ok(r == ERROR_SUCCESS, "MsiDatabaseExport failed\n");
1273
1274     MsiCloseHandle(hdb);
1275
1276     lstrcat(path, "\\");
1277     lstrcat(path, file);
1278
1279     /* check the data that was written */
1280     length = 0;
1281     memset(buffer, 0, sizeof buffer);
1282     handle = CreateFile(path, GENERIC_READ, 0, NULL, OPEN_EXISTING, 0, NULL);
1283     if (handle != INVALID_HANDLE_VALUE)
1284     {
1285         ReadFile(handle, buffer, sizeof buffer, &length, NULL);
1286         CloseHandle(handle);
1287         DeleteFile(path);
1288     }
1289     else
1290         ok(0, "failed to open file %s\n", path);
1291
1292     ok( length == strlen(expected), "length of data wrong\n");
1293     ok( !lstrcmp(buffer, expected), "data doesn't match\n");
1294     DeleteFile(msifile);
1295 }
1296
1297 static void test_longstrings(void)
1298 {
1299     const char insert_query[] =
1300         "INSERT INTO `strings` ( `id`, `val` ) VALUES('1', 'Z')";
1301     char *str;
1302     MSIHANDLE hdb = 0, hview = 0, hrec = 0;
1303     DWORD len;
1304     UINT r;
1305     const DWORD STRING_LENGTH = 0x10005;
1306
1307     DeleteFile(msifile);
1308     /* just MsiOpenDatabase should not create a file */
1309     r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
1310     ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
1311
1312     /* create a table */
1313     r = try_query( hdb,
1314         "CREATE TABLE `strings` ( `id` INT, `val` CHAR(0) PRIMARY KEY `id`)");
1315     ok(r == ERROR_SUCCESS, "query failed\n");
1316
1317     /* try a insert a very long string */
1318     str = HeapAlloc(GetProcessHeap(), 0, STRING_LENGTH+sizeof insert_query);
1319     len = strchr(insert_query, 'Z') - insert_query;
1320     strcpy(str, insert_query);
1321     memset(str+len, 'Z', STRING_LENGTH);
1322     strcpy(str+len+STRING_LENGTH, insert_query+len+1);
1323     r = try_query( hdb, str );
1324     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
1325
1326     HeapFree(GetProcessHeap(), 0, str);
1327
1328     MsiDatabaseCommit(hdb);
1329     ok(r == ERROR_SUCCESS, "MsiDatabaseCommit failed\n");
1330     MsiCloseHandle(hdb);
1331
1332     r = MsiOpenDatabase(msifile, MSIDBOPEN_READONLY, &hdb);
1333     ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
1334
1335     r = MsiDatabaseOpenView(hdb, "select * from `strings` where `id` = 1", &hview);
1336     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
1337
1338     r = MsiViewExecute(hview, 0);
1339     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
1340
1341     r = MsiViewFetch(hview, &hrec);
1342     ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
1343
1344     MsiCloseHandle(hview);
1345
1346     r = MsiRecordGetString(hrec, 2, NULL, &len);
1347     ok(r == ERROR_SUCCESS, "MsiViewFetch failed\n");
1348     ok(len == STRING_LENGTH, "string length wrong\n");
1349
1350     MsiCloseHandle(hrec);
1351     MsiCloseHandle(hdb);
1352     DeleteFile(msifile);
1353 }
1354
1355 static void create_file(const CHAR *name)
1356 {
1357     HANDLE file;
1358     DWORD written;
1359
1360     file = CreateFileA(name, GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, 0, NULL);
1361     ok(file != INVALID_HANDLE_VALUE, "Failure to open file %s\n", name);
1362     WriteFile(file, name, strlen(name), &written, NULL);
1363     WriteFile(file, "\n", strlen("\n"), &written, NULL);
1364     CloseHandle(file);
1365 }
1366
1367 static void test_streamtable(void)
1368 {
1369     MSIHANDLE hdb = 0, rec, view;
1370     char file[MAX_PATH];
1371     char buf[MAX_PATH];
1372     DWORD size;
1373     UINT r;
1374
1375     hdb = create_db();
1376     ok( hdb, "failed to create db\n");
1377
1378     r = run_query( hdb, 0,
1379             "CREATE TABLE `Properties` "
1380             "( `Property` CHAR(255), `Value` CHAR(1)  PRIMARY KEY `Property`)" );
1381     ok( r == ERROR_SUCCESS , "Failed to create table\n" );
1382
1383     r = run_query( hdb, 0,
1384             "INSERT INTO `Properties` "
1385             "( `Value`, `Property` ) VALUES ( 'Prop', 'value' )" );
1386     ok( r == ERROR_SUCCESS, "Failed to add to table\n" );
1387
1388     r = MsiDatabaseCommit( hdb );
1389     ok( r == ERROR_SUCCESS , "Failed to commit database\n" );
1390
1391     MsiCloseHandle( hdb );
1392
1393     r = MsiOpenDatabase(msifile, MSIDBOPEN_TRANSACT, &hdb );
1394     ok( r == ERROR_SUCCESS , "Failed to open database\n" );
1395
1396     /* check the column types */
1397     rec = get_column_info( hdb, "select * from `_Streams`", MSICOLINFO_TYPES );
1398     ok( rec, "failed to get column info record\n" );
1399
1400     ok( check_record( rec, 1, "s62"), "wrong record type\n");
1401     ok( check_record( rec, 2, "V0"), "wrong record type\n");
1402
1403     MsiCloseHandle( rec );
1404
1405     /* now try the names */
1406     rec = get_column_info( hdb, "select * from `_Streams`", MSICOLINFO_NAMES );
1407     ok( rec, "failed to get column info record\n" );
1408
1409     ok( check_record( rec, 1, "Name"), "wrong record type\n");
1410     ok( check_record( rec, 2, "Data"), "wrong record type\n");
1411
1412     MsiCloseHandle( rec );
1413
1414     /* insert a file into the _Streams table */
1415     create_file( "test.txt" );
1416
1417     rec = MsiCreateRecord( 2 );
1418     MsiRecordSetString( rec, 1, "data" );
1419
1420     r = MsiRecordSetStream( rec, 2, "test.txt" );
1421     ok( r == ERROR_SUCCESS, "Failed to add stream data to the record: %d\n", r);
1422
1423     DeleteFile("test.txt");
1424
1425     r = MsiDatabaseOpenView( hdb,
1426             "INSERT INTO `_Streams` ( `Name`, `Data` ) VALUES ( ?, ? )", &view );
1427     ok( r == ERROR_SUCCESS, "Failed to open database view: %d\n", r);
1428
1429     r = MsiViewExecute( view, rec );
1430     ok( r == ERROR_SUCCESS, "Failed to execute view: %d\n", r);
1431
1432     MsiCloseHandle( rec );
1433     MsiCloseHandle( view );
1434
1435     r = MsiDatabaseOpenView( hdb,
1436             "SELECT `Name`, `Data` FROM `_Streams`", &view );
1437     ok( r == ERROR_SUCCESS, "Failed to open database view: %d\n", r);
1438
1439     r = MsiViewExecute( view, 0 );
1440     ok( r == ERROR_SUCCESS, "Failed to execute view: %d\n", r);
1441
1442     r = MsiViewFetch( view, &rec );
1443     ok( r == ERROR_SUCCESS, "Failed to fetch record: %d\n", r);
1444
1445     size = MAX_PATH;
1446     r = MsiRecordGetString( rec, 1, file, &size );
1447     ok( r == ERROR_SUCCESS, "Failed to get string: %d\n", r);
1448     ok( !lstrcmp(file, "data"), "Expected 'data', got %s\n", file);
1449
1450     size = MAX_PATH;
1451     memset(buf, 0, MAX_PATH);
1452     r = MsiRecordReadStream( rec, 2, buf, &size );
1453     ok( r == ERROR_SUCCESS, "Failed to get stream: %d\n", r);
1454     ok( !lstrcmp(buf, "test.txt\n"), "Expected 'test.txt\\n', got %s\n", buf);
1455
1456     MsiCloseHandle( rec );
1457
1458     r = MsiViewFetch( view, &rec );
1459     ok( r == ERROR_NO_MORE_ITEMS, "Expected ERROR_NO_MORE_ITEMS, got %d\n", r);
1460
1461     MsiCloseHandle( view );
1462     MsiCloseHandle( hdb );
1463     DeleteFile(msifile);
1464 }
1465
1466 static void test_where(void)
1467 {
1468     MSIHANDLE hdb = 0, rec, view;
1469     LPCSTR query;
1470     UINT r;
1471     DWORD size;
1472     CHAR buf[MAX_PATH];
1473     UINT count;
1474
1475     hdb = create_db();
1476     ok( hdb, "failed to create db\n");
1477
1478     r = run_query( hdb, 0,
1479             "CREATE TABLE `Media` ("
1480             "`DiskId` SHORT NOT NULL, "
1481             "`LastSequence` LONG, "
1482             "`DiskPrompt` CHAR(64) LOCALIZABLE, "
1483             "`Cabinet` CHAR(255), "
1484             "`VolumeLabel` CHAR(32), "
1485             "`Source` CHAR(72) "
1486             "PRIMARY KEY `DiskId`)" );
1487     ok( r == S_OK, "cannot create Media table: %d\n", r );
1488
1489     r = run_query( hdb, 0, "INSERT INTO `Media` "
1490             "( `DiskId`, `LastSequence`, `DiskPrompt`, `Cabinet`, `VolumeLabel`, `Source` ) "
1491             "VALUES ( 1, 0, '', 'zero.cab', '', '' )" );
1492     ok( r == S_OK, "cannot add file to the Media table: %d\n", r );
1493
1494     r = run_query( hdb, 0, "INSERT INTO `Media` "
1495             "( `DiskId`, `LastSequence`, `DiskPrompt`, `Cabinet`, `VolumeLabel`, `Source` ) "
1496             "VALUES ( 2, 1, '', 'one.cab', '', '' )" );
1497     ok( r == S_OK, "cannot add file to the Media table: %d\n", r );
1498
1499     r = run_query( hdb, 0, "INSERT INTO `Media` "
1500             "( `DiskId`, `LastSequence`, `DiskPrompt`, `Cabinet`, `VolumeLabel`, `Source` ) "
1501             "VALUES ( 3, 2, '', 'two.cab', '', '' )" );
1502     ok( r == S_OK, "cannot add file to the Media table: %d\n", r );
1503
1504     query = "SELECT * FROM `Media`";
1505     r = do_query(hdb, query, &rec);
1506     ok(r == ERROR_SUCCESS, "MsiViewFetch failed: %d\n", r);
1507     ok( check_record( rec, 4, "zero.cab"), "wrong cabinet\n");
1508     MsiCloseHandle( rec );
1509
1510     query = "SELECT * FROM `Media` WHERE `LastSequence` >= 1";
1511     r = do_query(hdb, query, &rec);
1512     ok(r == ERROR_SUCCESS, "MsiViewFetch failed: %d\n", r);
1513     ok( check_record( rec, 4, "one.cab"), "wrong cabinet\n");
1514
1515     r = MsiRecordGetInteger(rec, 1);
1516     ok( 2 == r, "field wrong\n");
1517     r = MsiRecordGetInteger(rec, 2);
1518     ok( 1 == r, "field wrong\n");
1519     MsiCloseHandle( rec );
1520
1521     query = "SELECT `DiskId` FROM `Media` WHERE `LastSequence` >= 1 AND DiskId >= 0";
1522     r = MsiDatabaseOpenView(hdb, query, &view);
1523     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
1524
1525     r = MsiViewExecute(view, 0);
1526     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
1527
1528     r = MsiViewFetch(view, &rec);
1529     ok( r == ERROR_SUCCESS, "failed to fetch view: %d\n", r );
1530
1531     count = MsiRecordGetFieldCount( rec );
1532     ok( count == 1, "Expected 1 record fields, got %d\n", count );
1533
1534     size = MAX_PATH;
1535     r = MsiRecordGetString( rec, 1, buf, &size );
1536     ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
1537     ok( !lstrcmp( buf, "2" ),
1538         "For (row %d, column 1) expected '%d', got %s\n", 0, 2, buf );
1539     MsiCloseHandle( rec );
1540
1541     r = MsiViewFetch(view, &rec);
1542     ok( r == ERROR_SUCCESS, "failed to fetch view: %d\n", r );
1543
1544     size = MAX_PATH;
1545     r = MsiRecordGetString( rec, 1, buf, &size );
1546     ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
1547     ok( !lstrcmp( buf, "3" ),
1548         "For (row %d, column 1) expected '%d', got %s\n", 1, 3, buf );
1549     MsiCloseHandle( rec );
1550
1551     r = MsiViewFetch(view, &rec);
1552     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
1553
1554     MsiViewClose(view);
1555     MsiCloseHandle(view);
1556
1557     MsiCloseHandle( rec );
1558
1559     rec = 0;
1560     query = "SELECT * FROM `Media` WHERE `DiskPrompt` IS NULL";
1561     r = do_query(hdb, query, &rec);
1562     ok( r == ERROR_SUCCESS, "query failed: %d\n", r );
1563     MsiCloseHandle( rec );
1564
1565     MsiCloseHandle( hdb );
1566     DeleteFile(msifile);
1567 }
1568
1569 static CHAR CURR_DIR[MAX_PATH];
1570
1571 static const CHAR test_data[] = "FirstPrimaryColumn\tSecondPrimaryColumn\tShortInt\tShortIntNullable\tLongInt\tLongIntNullable\tString\tLocalizableString\tLocalizableStringNullable\n"
1572                                 "s255\ti2\ti2\tI2\ti4\tI4\tS255\tS0\ts0\n"
1573                                 "TestTable\tFirstPrimaryColumn\n"
1574                                 "stringage\t5\t2\t\t2147483640\t-2147483640\tanother string\tlocalizable\tduh\n";
1575
1576 static const CHAR two_primary[] = "PrimaryOne\tPrimaryTwo\n"
1577                                   "s255\ts255\n"
1578                                   "TwoPrimary\tPrimaryOne\tPrimaryTwo\n"
1579                                   "papaya\tleaf\n"
1580                                   "papaya\tflower\n";
1581
1582 static void write_file(const CHAR *filename, const char *data, int data_size)
1583 {
1584     DWORD size;
1585
1586     HANDLE hf = CreateFile(filename, GENERIC_WRITE, 0, NULL,
1587                            CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
1588
1589     WriteFile(hf, data, data_size, &size, NULL);
1590     CloseHandle(hf);
1591 }
1592
1593 static UINT add_table_to_db(MSIHANDLE hdb, LPCSTR table_data)
1594 {
1595     UINT r;
1596
1597     write_file("temp_file", table_data, (lstrlen(table_data) - 1) * sizeof(char));
1598     r = MsiDatabaseImportA(hdb, CURR_DIR, "temp_file");
1599     DeleteFileA("temp_file");
1600
1601     return r;
1602 }
1603
1604 static void test_msiimport(void)
1605 {
1606     MSIHANDLE hdb, view, rec;
1607     LPCSTR query;
1608     UINT r, count;
1609     signed int i;
1610
1611     GetCurrentDirectoryA(MAX_PATH, CURR_DIR);
1612
1613     r = MsiOpenDatabaseA(msifile, MSIDBOPEN_CREATE, &hdb);
1614     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1615
1616     r = add_table_to_db(hdb, test_data);
1617     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1618
1619     r = add_table_to_db(hdb, two_primary);
1620     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1621
1622     query = "SELECT * FROM `TestTable`";
1623     r = MsiDatabaseOpenView(hdb, query, &view);
1624     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1625
1626     r = MsiViewGetColumnInfo(view, MSICOLINFO_NAMES, &rec);
1627     count = MsiRecordGetFieldCount(rec);
1628     ok(count == 9, "Expected 9, got %d\n", count);
1629     ok(check_record(rec, 1, "FirstPrimaryColumn"), "Expected FirstPrimaryColumn\n");
1630     ok(check_record(rec, 2, "SecondPrimaryColumn"), "Expected SecondPrimaryColumn\n");
1631     ok(check_record(rec, 3, "ShortInt"), "Expected ShortInt\n");
1632     ok(check_record(rec, 4, "ShortIntNullable"), "Expected ShortIntNullalble\n");
1633     ok(check_record(rec, 5, "LongInt"), "Expected LongInt\n");
1634     ok(check_record(rec, 6, "LongIntNullable"), "Expected LongIntNullalble\n");
1635     ok(check_record(rec, 7, "String"), "Expected String\n");
1636     ok(check_record(rec, 8, "LocalizableString"), "Expected LocalizableString\n");
1637     ok(check_record(rec, 9, "LocalizableStringNullable"), "Expected LocalizableStringNullable\n");
1638     MsiCloseHandle(rec);
1639
1640     r = MsiViewGetColumnInfo(view, MSICOLINFO_TYPES, &rec);
1641     count = MsiRecordGetFieldCount(rec);
1642     ok(count == 9, "Expected 9, got %d\n", count);
1643     ok(check_record(rec, 1, "s255"), "Expected s255\n");
1644     ok(check_record(rec, 2, "i2"), "Expected i2\n");
1645     ok(check_record(rec, 3, "i2"), "Expected i2\n");
1646     ok(check_record(rec, 4, "I2"), "Expected I2\n");
1647     ok(check_record(rec, 5, "i4"), "Expected i4\n");
1648     ok(check_record(rec, 6, "I4"), "Expected I4\n");
1649     ok(check_record(rec, 7, "S255"), "Expected S255\n");
1650     ok(check_record(rec, 8, "S0"), "Expected S0\n");
1651     ok(check_record(rec, 9, "s0"), "Expected s0\n");
1652     MsiCloseHandle(rec);
1653
1654     query = "SELECT * FROM `TestTable`";
1655     r = do_query(hdb, query, &rec);
1656     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1657     ok(check_record(rec, 1, "stringage"), "Expected 'stringage'\n");
1658     ok(check_record(rec, 7, "another string"), "Expected 'another string'\n");
1659     ok(check_record(rec, 8, "localizable"), "Expected 'localizable'\n");
1660     ok(check_record(rec, 9, "duh"), "Expected 'duh'\n");
1661
1662     i = MsiRecordGetInteger(rec, 2);
1663     ok(i == 5, "Expected 5, got %d\n", i);
1664
1665     i = MsiRecordGetInteger(rec, 3);
1666     ok(i == 2, "Expected 2, got %d\n", i);
1667
1668     i = MsiRecordGetInteger(rec, 4);
1669     ok(i == MSI_NULL_INTEGER, "Expected MSI_NULL_INTEGER, got %d\n", i);
1670
1671     i = MsiRecordGetInteger(rec, 5);
1672     ok(i == 2147483640, "Expected 2147483640, got %d\n", i);
1673
1674     i = MsiRecordGetInteger(rec, 6);
1675     ok(i == -2147483640, "Expected -2147483640, got %d\n", i);
1676
1677     MsiCloseHandle(rec);
1678     MsiCloseHandle(view);
1679
1680     query = "SELECT * FROM `TwoPrimary`";
1681     r = MsiDatabaseOpenView(hdb, query, &view);
1682     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1683
1684     r = MsiViewGetColumnInfo(view, MSICOLINFO_NAMES, &rec);
1685     count = MsiRecordGetFieldCount(rec);
1686     ok(count == 2, "Expected 2, got %d\n", count);
1687     ok(check_record(rec, 1, "PrimaryOne"), "Expected PrimaryOne\n");
1688     ok(check_record(rec, 2, "PrimaryTwo"), "Expected PrimaryTwo\n");
1689
1690     MsiCloseHandle(rec);
1691
1692     r = MsiViewGetColumnInfo(view, MSICOLINFO_TYPES, &rec);
1693     count = MsiRecordGetFieldCount(rec);
1694     ok(count == 2, "Expected 2, got %d\n", count);
1695     ok(check_record(rec, 1, "s255"), "Expected s255\n");
1696     ok(check_record(rec, 2, "s255"), "Expected s255\n");
1697     MsiCloseHandle(rec);
1698
1699     r = MsiViewExecute(view, 0);
1700     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1701
1702     r = MsiViewFetch(view, &rec);
1703     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1704
1705     ok(check_record(rec, 1, "papaya"), "Expected 'papaya'\n");
1706     ok(check_record(rec, 2, "leaf"), "Expected 'leaf'\n");
1707
1708     MsiCloseHandle(rec);
1709
1710     r = MsiViewFetch(view, &rec);
1711     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1712
1713     ok(check_record(rec, 1, "papaya"), "Expected 'papaya'\n");
1714     ok(check_record(rec, 2, "flower"), "Expected 'flower'\n");
1715
1716     MsiCloseHandle(rec);
1717
1718     r = MsiViewFetch(view, &rec);
1719     ok(r == ERROR_NO_MORE_ITEMS, "Expected ERROR_NO_MORE_ITEMS, got %d\n", r);
1720
1721     r = MsiViewClose(view);
1722     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1723
1724     MsiCloseHandle(view);
1725     MsiCloseHandle(hdb);
1726     DeleteFileA(msifile);
1727 }
1728
1729 static void test_markers(void)
1730 {
1731     MSIHANDLE hdb, rec;
1732     LPCSTR query;
1733     UINT r;
1734
1735     hdb = create_db();
1736     ok( hdb, "failed to create db\n");
1737
1738     rec = MsiCreateRecord(3);
1739     MsiRecordSetString(rec, 1, "Table");
1740     MsiRecordSetString(rec, 2, "Apples");
1741     MsiRecordSetString(rec, 3, "Oranges");
1742
1743     /* try a legit create */
1744     query = "CREATE TABLE `Table` ( `One` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`)";
1745     r = run_query(hdb, 0, query);
1746     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1747     MsiCloseHandle(rec);
1748
1749     /* try table name as marker */
1750     rec = MsiCreateRecord(1);
1751     MsiRecordSetString(rec, 1, "Fable");
1752     query = "CREATE TABLE `?` ( `One` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`)";
1753     r = run_query(hdb, rec, query);
1754     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1755
1756     /* verify that we just created a table called '?', not 'Fable' */
1757     r = try_query(hdb, "SELECT * from `Fable`");
1758     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1759
1760     r = try_query(hdb, "SELECT * from `?`");
1761     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1762
1763     /* try table name as marker without backticks */
1764     MsiRecordSetString(rec, 1, "Mable");
1765     query = "CREATE TABLE ? ( `One` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`)";
1766     r = run_query(hdb, rec, query);
1767     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1768
1769     /* try one column name as marker */
1770     MsiRecordSetString(rec, 1, "One");
1771     query = "CREATE TABLE `Mable` ( `?` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`)";
1772     r = run_query(hdb, rec, query);
1773     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1774     MsiCloseHandle(rec);
1775
1776     /* try column names as markers */
1777     rec = MsiCreateRecord(2);
1778     MsiRecordSetString(rec, 1, "One");
1779     MsiRecordSetString(rec, 2, "Two");
1780     query = "CREATE TABLE `Mable` ( `?` SHORT NOT NULL, `?` CHAR(255) PRIMARY KEY `One`)";
1781     r = run_query(hdb, rec, query);
1782     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1783     MsiCloseHandle(rec);
1784
1785     /* try names with backticks */
1786     rec = MsiCreateRecord(3);
1787     MsiRecordSetString(rec, 1, "One");
1788     MsiRecordSetString(rec, 2, "Two");
1789     MsiRecordSetString(rec, 3, "One");
1790     query = "CREATE TABLE `Mable` ( `?` SHORT NOT NULL, `?` CHAR(255) PRIMARY KEY `?`)";
1791     r = run_query(hdb, rec, query);
1792     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1793
1794     /* try names with backticks, minus definitions */
1795     query = "CREATE TABLE `Mable` ( `?`, `?` PRIMARY KEY `?`)";
1796     r = run_query(hdb, rec, query);
1797     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1798
1799     /* try names without backticks */
1800     query = "CREATE TABLE `Mable` ( ? SHORT NOT NULL, ? CHAR(255) PRIMARY KEY ?)";
1801     r = run_query(hdb, rec, query);
1802     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1803     MsiCloseHandle(rec);
1804
1805     /* try one long marker */
1806     rec = MsiCreateRecord(1);
1807     MsiRecordSetString(rec, 1, "`One` SHORT NOT NULL, `Two` CHAR(255) PRIMARY KEY `One`");
1808     query = "CREATE TABLE `Mable` ( ? )";
1809     r = run_query(hdb, rec, query);
1810     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1811     MsiCloseHandle(rec);
1812
1813     /* try all names as markers */
1814     rec = MsiCreateRecord(4);
1815     MsiRecordSetString(rec, 1, "Mable");
1816     MsiRecordSetString(rec, 2, "One");
1817     MsiRecordSetString(rec, 3, "Two");
1818     MsiRecordSetString(rec, 4, "One");
1819     query = "CREATE TABLE `?` ( `?` SHORT NOT NULL, `?` CHAR(255) PRIMARY KEY `?`)";
1820     r = run_query(hdb, rec, query);
1821     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1822     MsiCloseHandle(rec);
1823
1824     /* try a legit insert */
1825     query = "INSERT INTO `Table` ( `One`, `Two` ) VALUES ( 5, 'hello' )";
1826     r = run_query(hdb, 0, query);
1827     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1828
1829     r = try_query(hdb, "SELECT * from `Table`");
1830     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1831
1832     /* try values as markers */
1833     rec = MsiCreateRecord(2);
1834     MsiRecordSetInteger(rec, 1, 4);
1835     MsiRecordSetString(rec, 2, "hi");
1836     query = "INSERT INTO `Table` ( `One`, `Two` ) VALUES ( ?, '?' )";
1837     r = run_query(hdb, rec, query);
1838     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1839     MsiCloseHandle(rec);
1840
1841     /* try column names and values as markers */
1842     rec = MsiCreateRecord(4);
1843     MsiRecordSetString(rec, 1, "One");
1844     MsiRecordSetString(rec, 2, "Two");
1845     MsiRecordSetInteger(rec, 3, 5);
1846     MsiRecordSetString(rec, 4, "hi");
1847     query = "INSERT INTO `Table` ( `?`, `?` ) VALUES ( ?, '?' )";
1848     r = run_query(hdb, rec, query);
1849     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1850     MsiCloseHandle(rec);
1851
1852     /* try column names as markers */
1853     rec = MsiCreateRecord(2);
1854     MsiRecordSetString(rec, 1, "One");
1855     MsiRecordSetString(rec, 2, "Two");
1856     query = "INSERT INTO `Table` ( `?`, `?` ) VALUES ( 3, 'yellow' )";
1857     r = run_query(hdb, rec, query);
1858     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1859     MsiCloseHandle(rec);
1860
1861     /* try table name as a marker */
1862     rec = MsiCreateRecord(1);
1863     MsiRecordSetString(rec, 1, "Table");
1864     query = "INSERT INTO `?` ( `One`, `Two` ) VALUES ( 2, 'green' )";
1865     r = run_query(hdb, rec, query);
1866     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1867     MsiCloseHandle(rec);
1868
1869     /* try table name and values as markers */
1870     rec = MsiCreateRecord(3);
1871     MsiRecordSetString(rec, 1, "Table");
1872     MsiRecordSetInteger(rec, 2, 10);
1873     MsiRecordSetString(rec, 3, "haha");
1874     query = "INSERT INTO `?` ( `One`, `Two` ) VALUES ( ?, '?' )";
1875     r = run_query(hdb, rec, query);
1876     ok(r == ERROR_FUNCTION_FAILED, "Expected ERROR_FUNCTION_FAILED, got %d\n", r);
1877     MsiCloseHandle(rec);
1878
1879     /* try all markers */
1880     rec = MsiCreateRecord(5);
1881     MsiRecordSetString(rec, 1, "Table");
1882     MsiRecordSetString(rec, 1, "One");
1883     MsiRecordSetString(rec, 1, "Two");
1884     MsiRecordSetInteger(rec, 2, 10);
1885     MsiRecordSetString(rec, 3, "haha");
1886     query = "INSERT INTO `?` ( `?`, `?` ) VALUES ( ?, '?' )";
1887     r = run_query(hdb, rec, query);
1888     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
1889     MsiCloseHandle(rec);
1890
1891     /* insert an integer as a string */
1892     rec = MsiCreateRecord(2);
1893     MsiRecordSetString(rec, 1, "11");
1894     MsiRecordSetString(rec, 2, "hi");
1895     query = "INSERT INTO `Table` ( `One`, `Two` ) VALUES ( ?, '?' )";
1896     r = run_query(hdb, rec, query);
1897     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1898     MsiCloseHandle(rec);
1899
1900     /* leave off the '' for the string */
1901     rec = MsiCreateRecord(2);
1902     MsiRecordSetInteger(rec, 1, 12);
1903     MsiRecordSetString(rec, 2, "hi");
1904     query = "INSERT INTO `Table` ( `One`, `Two` ) VALUES ( ?, ? )";
1905     r = run_query(hdb, rec, query);
1906     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
1907     MsiCloseHandle(rec);
1908
1909     MsiCloseHandle(hdb);
1910     DeleteFileA(msifile);
1911 }
1912
1913 #define MY_NVIEWS 4000    /* Largest installer I've seen uses < 2k */
1914 static void test_handle_limit(void)
1915 {
1916     int i;
1917     MSIHANDLE hdb;
1918     MSIHANDLE hviews[MY_NVIEWS];
1919     UINT r;
1920
1921     /* create an empty db */
1922     hdb = create_db();
1923     ok( hdb, "failed to create db\n");
1924
1925     memset(hviews, 0, sizeof(hviews));
1926
1927     for (i=0; i<MY_NVIEWS; i++) {
1928         static char szQueryBuf[256] = "SELECT * from `_Tables`";
1929         hviews[i] = 0xdeadbeeb;
1930         r = MsiDatabaseOpenView(hdb, szQueryBuf, &hviews[i]);
1931         if( r != ERROR_SUCCESS || hviews[i] == 0xdeadbeeb ||
1932             hviews[i] == 0 || (i && (hviews[i] == hviews[i-1])))
1933             break;
1934     }
1935
1936     ok( i == MY_NVIEWS, "problem opening views\n");
1937
1938     for (i=0; i<MY_NVIEWS; i++) {
1939         if (hviews[i] != 0 && hviews[i] != 0xdeadbeeb) {
1940             r = MsiCloseHandle(hviews[i]);
1941             if (r != ERROR_SUCCESS)
1942                 break;
1943         }
1944     }
1945
1946     ok( i == MY_NVIEWS, "problem closing views\n");
1947
1948     r = MsiCloseHandle(hdb);
1949     ok( r == ERROR_SUCCESS, "failed to close database\n");
1950 }
1951
1952 static void generate_transform(void)
1953 {
1954     MSIHANDLE hdb1, hdb2, hrec;
1955     LPCSTR query;
1956     UINT r;
1957
1958     /* start with two identical databases */
1959     CopyFile(msifile2, msifile, FALSE);
1960
1961     r = MsiOpenDatabase(msifile, MSIDBOPEN_TRANSACT, &hdb1 );
1962     ok( r == ERROR_SUCCESS , "Failed to create database\n" );
1963
1964     r = MsiDatabaseCommit( hdb1 );
1965     ok( r == ERROR_SUCCESS , "Failed to commit database\n" );
1966
1967     r = MsiOpenDatabase(msifile2, MSIDBOPEN_READONLY, &hdb2 );
1968     ok( r == ERROR_SUCCESS , "Failed to create database\n" );
1969
1970     /* the transform between two identical database should be empty */
1971     r = MsiDatabaseGenerateTransform(hdb1, hdb2, NULL, 0, 0);
1972     todo_wine {
1973     ok( r == ERROR_NO_DATA, "return code %d, should be ERROR_NO_DATA\n", r );
1974     }
1975
1976     query = "CREATE TABLE `AAR` ( `BAR` SHORT NOT NULL, `CAR` CHAR(255) PRIMARY KEY `CAR`)";
1977     r = run_query(hdb1, 0, query);
1978     ok(r == ERROR_SUCCESS, "failed to add table\n");
1979
1980     query = "INSERT INTO `AAR` ( `BAR`, `CAR` ) VALUES ( 1, 'vw' )";
1981     r = run_query(hdb1, 0, query);
1982     ok(r == ERROR_SUCCESS, "failed to add row 1\n");
1983
1984     query = "INSERT INTO `AAR` ( `BAR`, `CAR` ) VALUES ( 2, 'bmw' )";
1985     r = run_query(hdb1, 0, query);
1986     ok(r == ERROR_SUCCESS, "failed to add row 2\n");
1987
1988     query = "UPDATE `MOO` SET `OOO` = 'c' WHERE `NOO` = 1";
1989     r = run_query(hdb1, 0, query);
1990     ok(r == ERROR_SUCCESS, "failed to modify row\n");
1991
1992     query = "DELETE FROM `MOO` WHERE `NOO` = 3";
1993     r = run_query(hdb1, 0, query);
1994     ok(r == ERROR_SUCCESS, "failed to delete row\n");
1995
1996     hrec = MsiCreateRecord(2);
1997     r = MsiRecordSetInteger(hrec, 1, 1);
1998     ok(r == ERROR_SUCCESS, "failed to set integer\n");
1999
2000     write_file("testdata.bin", "naengmyon", 9);
2001     r = MsiRecordSetStream(hrec, 2, "testdata.bin");
2002     ok(r == ERROR_SUCCESS, "failed to set stream\n");
2003
2004     query = "INSERT INTO `BINARY` ( `ID`, `BLOB` ) VALUES ( ?, ? )";
2005     r = run_query(hdb1, hrec, query);
2006     ok(r == ERROR_SUCCESS, "failed to add row with blob\n");
2007
2008     MsiCloseHandle(hrec);
2009
2010     query = "ALTER TABLE `MOO` ADD `COW` INTEGER";
2011     r = run_query(hdb1, 0, query);
2012     ok(r == ERROR_SUCCESS, "failed to add column\n");
2013
2014     query = "ALTER TABLE `MOO` ADD `PIG` INTEGER";
2015     r = run_query(hdb1, 0, query);
2016     ok(r == ERROR_SUCCESS, "failed to add column\n");
2017
2018     query = "UPDATE `MOO` SET `PIG` = 5 WHERE `NOO` = 1";
2019     r = run_query(hdb1, 0, query);
2020     ok(r == ERROR_SUCCESS, "failed to modify row\n");
2021
2022     query = "CREATE TABLE `Property` ( `Property` CHAR(72) NOT NULL, "
2023             "`Value` CHAR(0) PRIMARY KEY `Property`)";
2024     r = run_query(hdb1, 0, query);
2025     ok(r == ERROR_SUCCESS, "failed to add property table\n");
2026
2027     query = "INSERT INTO `Property` ( `Property`, `Value` ) VALUES ( 'prop', 'val' )";
2028     r = run_query(hdb1, 0, query);
2029     ok(r == ERROR_SUCCESS, "failed to add property\n");
2030
2031     /* database needs to be committed */
2032     MsiDatabaseCommit(hdb1);
2033
2034     r = MsiDatabaseGenerateTransform(hdb1, hdb2, mstfile, 0, 0);
2035     ok( r == ERROR_SUCCESS, "return code %d, should be ERROR_SUCCESS\n", r );
2036
2037     MsiCloseHandle( hdb1 );
2038     MsiCloseHandle( hdb2 );
2039
2040     DeleteFile("testdata.bin");
2041 }
2042
2043 /* data for generating a transform */
2044
2045 /* tables transform names - encoded as they would be in an msi database file */
2046 static const WCHAR name1[] = { 0x4840, 0x3a8a, 0x481b, 0 }; /* AAR */
2047 static const WCHAR name2[] = { 0x4840, 0x3b3f, 0x43f2, 0x4438, 0x45b1, 0 }; /* _Columns */
2048 static const WCHAR name3[] = { 0x4840, 0x3f7f, 0x4164, 0x422f, 0x4836, 0 }; /* _Tables */
2049 static const WCHAR name4[] = { 0x4840, 0x3f3f, 0x4577, 0x446c, 0x3b6a, 0x45e4, 0x4824, 0 }; /* _StringData */
2050 static const WCHAR name5[] = { 0x4840, 0x3f3f, 0x4577, 0x446c, 0x3e6a, 0x44b2, 0x482f, 0 }; /* _StringPool */
2051 static const WCHAR name6[] = { 0x4840, 0x3e16, 0x4818, 0}; /* MOO */
2052 static const WCHAR name7[] = { 0x4840, 0x3c8b, 0x3a97, 0x409b, 0 }; /* BINARY */
2053 static const WCHAR name8[] = { 0x3c8b, 0x3a97, 0x409b, 0x387e, 0 }; /* BINARY.1 */
2054 static const WCHAR name9[] = { 0x4840, 0x4559, 0x44f2, 0x4568, 0x4737, 0 }; /* Property */
2055
2056 /* data in each table */
2057 static const WCHAR data1[] = { /* AAR */
2058     0x0201, 0x0008, 0x8001,  /* 0x0201 = add row (1), two shorts */
2059     0x0201, 0x0009, 0x8002,
2060 };
2061 static const WCHAR data2[] = { /* _Columns */
2062     0x0401, 0x0001, 0x8003, 0x0002, 0x9502,
2063     0x0401, 0x0001, 0x8004, 0x0003, 0x9502,
2064     0x0401, 0x0005, 0x0000, 0x0006, 0xbdff,  /* 0x0401 = add row (1), 4 shorts */
2065     0x0401, 0x0005, 0x0000, 0x0007, 0x8502,
2066     0x0401, 0x000a, 0x0000, 0x000a, 0xad48,
2067     0x0401, 0x000a, 0x0000, 0x000b, 0x9d00,
2068 };
2069 static const WCHAR data3[] = { /* _Tables */
2070     0x0101, 0x0005, /* 0x0101 = add row (1), 1 short */
2071     0x0101, 0x000a,
2072 };
2073 static const char data4[] = /* _StringData */
2074     "MOOCOWPIGcAARCARBARvwbmwPropertyValuepropval";  /* all the strings squashed together */
2075 static const WCHAR data5[] = { /* _StringPool */
2076 /*  len, refs */
2077     0,   0,    /* string 0 ''    */
2078     3,   2,    /* string 1 'MOO' */
2079     3,   1,    /* string 2 'COW' */
2080     3,   1,    /* string 3 'PIG' */
2081     1,   1,    /* string 4 'c'   */
2082     3,   3,    /* string 5 'AAR' */
2083     3,   1,    /* string 6 'CAR' */
2084     3,   1,    /* string 7 'BAR' */
2085     2,   1,    /* string 8 'vw'  */
2086     3,   1,    /* string 9 'bmw' */
2087     8,   4,    /* string 10 'Property' */
2088     5,   1,    /* string 11 'Value' */
2089     4,   1,    /* string 12 'prop' */
2090     3,   1,    /* string 13 'val' */
2091 };
2092 /* update row, 0x0002 is a bitmask of present column data, keys are excluded */
2093 static const WCHAR data6[] = { /* MOO */
2094     0x000a, 0x8001, 0x0004, 0x8005, /* update row */
2095     0x0000, 0x8003,         /* delete row */
2096 };
2097
2098 static const WCHAR data7[] = { /* BINARY */
2099     0x0201, 0x8001, 0x0001,
2100 };
2101
2102 static const char data8[] =  /* stream data for the BINARY table */
2103     "naengmyon";
2104
2105 static const WCHAR data9[] = { /* Property */
2106     0x0201, 0x000c, 0x000d,
2107 };
2108
2109 static const struct {
2110     LPCWSTR name;
2111     const void *data;
2112     DWORD size;
2113 } table_transform_data[] =
2114 {
2115     { name1, data1, sizeof data1 },
2116     { name2, data2, sizeof data2 },
2117     { name3, data3, sizeof data3 },
2118     { name4, data4, sizeof data4 - 1 },
2119     { name5, data5, sizeof data5 },
2120     { name6, data6, sizeof data6 },
2121     { name7, data7, sizeof data7 },
2122     { name8, data8, sizeof data8 - 1 },
2123     { name9, data9, sizeof data9 },
2124 };
2125
2126 #define NUM_TRANSFORM_TABLES (sizeof table_transform_data/sizeof table_transform_data[0])
2127
2128 static void generate_transform_manual(void)
2129 {
2130     IStorage *stg = NULL;
2131     IStream *stm;
2132     WCHAR name[0x20];
2133     HRESULT r;
2134     DWORD i, count;
2135     const DWORD mode = STGM_CREATE|STGM_READWRITE|STGM_DIRECT|STGM_SHARE_EXCLUSIVE;
2136
2137     const CLSID CLSID_MsiTransform = { 0xc1082,0,0,{0xc0,0,0,0,0,0,0,0x46}};
2138
2139     MultiByteToWideChar(CP_ACP, 0, mstfile, -1, name, 0x20);
2140
2141     r = StgCreateDocfile(name, mode, 0, &stg);
2142     ok(r == S_OK, "failed to create storage\n");
2143     if (!stg)
2144         return;
2145
2146     r = IStorage_SetClass( stg, &CLSID_MsiTransform );
2147     ok(r == S_OK, "failed to set storage type\n");
2148
2149     for (i=0; i<NUM_TRANSFORM_TABLES; i++)
2150     {
2151         r = IStorage_CreateStream( stg, table_transform_data[i].name,
2152                             STGM_WRITE | STGM_SHARE_EXCLUSIVE, 0, 0, &stm );
2153         if (FAILED(r))
2154         {
2155             ok(0, "failed to create stream %08x\n", r);
2156             continue;
2157         }
2158
2159         r = IStream_Write( stm, table_transform_data[i].data,
2160                           table_transform_data[i].size, &count );
2161         if (FAILED(r) || count != table_transform_data[i].size)
2162             ok(0, "failed to write stream\n");
2163         IStream_Release(stm);
2164     }
2165
2166     IStorage_Release(stg);
2167 }
2168
2169 static UINT set_summary_info(MSIHANDLE hdb)
2170 {
2171     UINT res;
2172     MSIHANDLE suminfo;
2173
2174     /* build summmary info */
2175     res = MsiGetSummaryInformation(hdb, NULL, 7, &suminfo);
2176     ok( res == ERROR_SUCCESS , "Failed to open summaryinfo\n" );
2177
2178     res = MsiSummaryInfoSetProperty(suminfo,2, VT_LPSTR, 0,NULL,
2179                         "Installation Database");
2180     ok( res == ERROR_SUCCESS , "Failed to set summary info\n" );
2181
2182     res = MsiSummaryInfoSetProperty(suminfo,3, VT_LPSTR, 0,NULL,
2183                         "Installation Database");
2184     ok( res == ERROR_SUCCESS , "Failed to set summary info\n" );
2185
2186     res = MsiSummaryInfoSetProperty(suminfo,4, VT_LPSTR, 0,NULL,
2187                         "Wine Hackers");
2188     ok( res == ERROR_SUCCESS , "Failed to set summary info\n" );
2189
2190     res = MsiSummaryInfoSetProperty(suminfo,7, VT_LPSTR, 0,NULL,
2191                     ";1033");
2192     ok( res == ERROR_SUCCESS , "Failed to set summary info\n" );
2193
2194     res = MsiSummaryInfoSetProperty(suminfo,9, VT_LPSTR, 0,NULL,
2195                     "{913B8D18-FBB6-4CAC-A239-C74C11E3FA74}");
2196     ok( res == ERROR_SUCCESS , "Failed to set summary info\n" );
2197
2198     res = MsiSummaryInfoSetProperty(suminfo, 14, VT_I4, 100, NULL, NULL);
2199     ok( res == ERROR_SUCCESS , "Failed to set summary info\n" );
2200
2201     res = MsiSummaryInfoSetProperty(suminfo, 15, VT_I4, 0, NULL, NULL);
2202     ok( res == ERROR_SUCCESS , "Failed to set summary info\n" );
2203
2204     res = MsiSummaryInfoPersist(suminfo);
2205     ok( res == ERROR_SUCCESS , "Failed to make summary info persist\n" );
2206
2207     res = MsiCloseHandle( suminfo);
2208     ok( res == ERROR_SUCCESS , "Failed to close suminfo\n" );
2209
2210     return res;
2211 }
2212
2213 static MSIHANDLE create_package_db(LPCSTR filename)
2214 {
2215     MSIHANDLE hdb = 0;
2216     UINT res;
2217
2218     DeleteFile(msifile);
2219
2220     /* create an empty database */
2221     res = MsiOpenDatabase(filename, MSIDBOPEN_CREATE, &hdb );
2222     ok( res == ERROR_SUCCESS , "Failed to create database\n" );
2223     if( res != ERROR_SUCCESS )
2224         return hdb;
2225
2226     res = MsiDatabaseCommit( hdb );
2227     ok( res == ERROR_SUCCESS , "Failed to commit database\n" );
2228
2229     res = set_summary_info(hdb);
2230
2231     res = run_query( hdb, 0,
2232             "CREATE TABLE `Directory` ( "
2233             "`Directory` CHAR(255) NOT NULL, "
2234             "`Directory_Parent` CHAR(255), "
2235             "`DefaultDir` CHAR(255) NOT NULL "
2236             "PRIMARY KEY `Directory`)" );
2237     ok( res == ERROR_SUCCESS , "Failed to create directory table\n" );
2238
2239     return hdb;
2240 }
2241
2242 static void test_try_transform(void)
2243 {
2244     MSIHANDLE hdb, hview, hrec, hpkg;
2245     LPCSTR query;
2246     UINT r;
2247     DWORD sz;
2248     char buffer[MAX_PATH];
2249
2250     DeleteFile(msifile);
2251     DeleteFile(msifile2);
2252     DeleteFile(mstfile);
2253
2254     /* create the database */
2255     hdb = create_package_db(msifile2);
2256     ok(hdb, "Failed to create package db\n");
2257
2258     query = "CREATE TABLE `MOO` ( `NOO` SHORT NOT NULL, `OOO` CHAR(255) PRIMARY KEY `NOO`)";
2259     r = run_query(hdb, 0, query);
2260     ok(r == ERROR_SUCCESS, "failed to add table\n");
2261
2262     query = "INSERT INTO `MOO` ( `NOO`, `OOO` ) VALUES ( 1, 'a' )";
2263     r = run_query(hdb, 0, query);
2264     ok(r == ERROR_SUCCESS, "failed to add row\n");
2265
2266     query = "INSERT INTO `MOO` ( `NOO`, `OOO` ) VALUES ( 2, 'b' )";
2267     r = run_query(hdb, 0, query);
2268     ok(r == ERROR_SUCCESS, "failed to add row\n");
2269
2270     query = "INSERT INTO `MOO` ( `NOO`, `OOO` ) VALUES ( 3, 'c' )";
2271     r = run_query(hdb, 0, query);
2272     ok(r == ERROR_SUCCESS, "failed to add row\n");
2273
2274     query = "CREATE TABLE `BINARY` ( `ID` SHORT NOT NULL, `BLOB` OBJECT PRIMARY KEY `ID`)";
2275     r = run_query(hdb, 0, query);
2276     ok(r == ERROR_SUCCESS, "failed to add table\n");
2277
2278     hrec = MsiCreateRecord(2);
2279     r = MsiRecordSetInteger(hrec, 1, 2);
2280     ok(r == ERROR_SUCCESS, "failed to set integer\n");
2281
2282     write_file("testdata.bin", "lamyon", 6);
2283     r = MsiRecordSetStream(hrec, 2, "testdata.bin");
2284     ok(r == ERROR_SUCCESS, "failed to set stream\n");
2285
2286     query = "INSERT INTO `BINARY` ( `ID`, `BLOB` ) VALUES ( ?, ? )";
2287     r = run_query(hdb, hrec, query);
2288     ok(r == ERROR_SUCCESS, "failed to add row with blob\n");
2289
2290     MsiCloseHandle(hrec);
2291
2292     r = MsiDatabaseCommit( hdb );
2293     ok( r == ERROR_SUCCESS , "Failed to commit database\n" );
2294
2295     MsiCloseHandle( hdb );
2296     DeleteFileA("testdata.bin");
2297
2298     /*
2299      * Both these generate an equivilent transform,
2300      *  but the first doesn't work in Wine yet
2301      *  because MsiDatabaseGenerateTransform is unimplemented.
2302      */
2303     if (0)
2304         generate_transform();
2305     else
2306         generate_transform_manual();
2307
2308     r = MsiOpenDatabase(msifile2, MSIDBOPEN_DIRECT, &hdb );
2309     ok( r == ERROR_SUCCESS , "Failed to create database\n" );
2310
2311     r = MsiDatabaseApplyTransform( hdb, mstfile, 0 );
2312     ok( r == ERROR_SUCCESS, "return code %d, should be ERROR_SUCCESS\n", r );
2313
2314     MsiDatabaseCommit( hdb );
2315
2316     /* check new values */
2317     hrec = 0;
2318     query = "select `BAR`,`CAR` from `AAR` where `BAR` = 1 AND `CAR` = 'vw'";
2319     r = do_query(hdb, query, &hrec);
2320     ok(r == ERROR_SUCCESS, "select query failed\n");
2321     MsiCloseHandle(hrec);
2322
2323     query = "select `BAR`,`CAR` from `AAR` where `BAR` = 2 AND `CAR` = 'bmw'";
2324     hrec = 0;
2325     r = do_query(hdb, query, &hrec);
2326     ok(r == ERROR_SUCCESS, "select query failed\n");
2327     MsiCloseHandle(hrec);
2328
2329     /* check updated values */
2330     hrec = 0;
2331     query = "select `NOO`,`OOO` from `MOO` where `NOO` = 1 AND `OOO` = 'c'";
2332     r = do_query(hdb, query, &hrec);
2333     ok(r == ERROR_SUCCESS, "select query failed\n");
2334     MsiCloseHandle(hrec);
2335
2336     /* check unchanged value */
2337     hrec = 0;
2338     query = "select `NOO`,`OOO` from `MOO` where `NOO` = 2 AND `OOO` = 'b'";
2339     r = do_query(hdb, query, &hrec);
2340     ok(r == ERROR_SUCCESS, "select query failed\n");
2341     MsiCloseHandle(hrec);
2342
2343     /* check deleted value */
2344     hrec = 0;
2345     query = "select * from `MOO` where `NOO` = 3";
2346     r = do_query(hdb, query, &hrec);
2347     ok(r == ERROR_NO_MORE_ITEMS, "select query failed\n");
2348     if (hrec) MsiCloseHandle(hrec);
2349
2350     /* check added stream */
2351     hrec = 0;
2352     query = "select `BLOB` from `BINARY` where `ID` = 1";
2353     r = do_query(hdb, query, &hrec);
2354     ok(r == ERROR_SUCCESS, "select query failed\n");
2355
2356     /* check the contents of the stream */
2357     sz = sizeof buffer;
2358     r = MsiRecordReadStream( hrec, 1, buffer, &sz );
2359     ok(r == ERROR_SUCCESS, "read stream failed\n");
2360     ok(!memcmp(buffer, "naengmyon", 9), "stream data was wrong\n");
2361     ok(sz == 9, "stream data was wrong size\n");
2362     if (hrec) MsiCloseHandle(hrec);
2363
2364     /* check the validity of the table with a deleted row */
2365     hrec = 0;
2366     query = "select * from `MOO`";
2367     r = MsiDatabaseOpenView(hdb, query, &hview);
2368     ok(r == ERROR_SUCCESS, "open view failed\n");
2369
2370     r = MsiViewExecute(hview, 0);
2371     ok(r == ERROR_SUCCESS, "view execute failed\n");
2372
2373     r = MsiViewFetch(hview, &hrec);
2374     ok(r == ERROR_SUCCESS, "view fetch failed\n");
2375
2376     r = MsiRecordGetInteger(hrec, 1);
2377     ok(r == 1, "Expected 1, got %d\n", r);
2378
2379     sz = sizeof buffer;
2380     r = MsiRecordGetString(hrec, 2, buffer, &sz);
2381     ok(r == ERROR_SUCCESS, "record get string failed\n");
2382     ok(!lstrcmpA(buffer, "c"), "Expected c, got %s\n", buffer);
2383
2384     r = MsiRecordGetInteger(hrec, 3);
2385     ok(r == 0x80000000, "Expected 0x80000000, got %d\n", r);
2386
2387     r = MsiRecordGetInteger(hrec, 4);
2388     ok(r == 5, "Expected 5, got %d\n", r);
2389
2390     MsiCloseHandle(hrec);
2391
2392     r = MsiViewFetch(hview, &hrec);
2393     ok(r == ERROR_SUCCESS, "view fetch failed\n");
2394
2395     r = MsiRecordGetInteger(hrec, 1);
2396     ok(r == 2, "Expected 2, got %d\n", r);
2397
2398     sz = sizeof buffer;
2399     r = MsiRecordGetString(hrec, 2, buffer, &sz);
2400     ok(r == ERROR_SUCCESS, "record get string failed\n");
2401     ok(!lstrcmpA(buffer, "b"), "Expected b, got %s\n", buffer);
2402
2403     r = MsiRecordGetInteger(hrec, 3);
2404     ok(r == 0x80000000, "Expected 0x80000000, got %d\n", r);
2405
2406     r = MsiRecordGetInteger(hrec, 4);
2407     ok(r == 0x80000000, "Expected 0x80000000, got %d\n", r);
2408
2409     MsiCloseHandle(hrec);
2410
2411     r = MsiViewFetch(hview, &hrec);
2412     ok(r == ERROR_NO_MORE_ITEMS, "view fetch succeeded\n");
2413
2414     MsiCloseHandle(hrec);
2415     MsiCloseHandle(hview);
2416     MsiCloseHandle(hdb);
2417
2418     /* check that the property was added */
2419     r = MsiOpenPackage(msifile2, &hpkg);
2420     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
2421
2422     sz = MAX_PATH;
2423     r = MsiGetProperty(hpkg, "prop", buffer, &sz);
2424     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
2425     ok(!lstrcmp(buffer, "val"), "Expected val, got %s\n", buffer);
2426
2427     MsiCloseHandle(hpkg);
2428
2429     DeleteFile(msifile);
2430     DeleteFile(msifile2);
2431     DeleteFile(mstfile);
2432 }
2433
2434 struct join_res
2435 {
2436     const CHAR one[MAX_PATH];
2437     const CHAR two[MAX_PATH];
2438 };
2439
2440 struct join_res_4col
2441 {
2442     const CHAR one[MAX_PATH];
2443     const CHAR two[MAX_PATH];
2444     const CHAR three[MAX_PATH];
2445     const CHAR four[MAX_PATH];
2446 };
2447
2448 static const struct join_res join_res_first[] =
2449 {
2450     { "alveolar", "procerus" },
2451     { "septum", "procerus" },
2452     { "septum", "nasalis" },
2453     { "ramus", "nasalis" },
2454     { "malar", "mentalis" },
2455 };
2456
2457 static const struct join_res join_res_second[] =
2458 {
2459     { "nasal", "septum" },
2460     { "mandible", "ramus" },
2461 };
2462
2463 static const struct join_res join_res_third[] =
2464 {
2465     { "msvcp.dll", "abcdefgh" },
2466     { "msvcr.dll", "ijklmnop" },
2467 };
2468
2469 static const struct join_res join_res_fourth[] =
2470 {
2471     { "msvcp.dll.01234", "single.dll.31415" },
2472 };
2473
2474 static const struct join_res join_res_fifth[] =
2475 {
2476     { "malar", "procerus" },
2477 };
2478
2479 static const struct join_res join_res_sixth[] =
2480 {
2481     { "malar", "procerus" },
2482     { "malar", "procerus" },
2483     { "malar", "nasalis" },
2484     { "malar", "nasalis" },
2485     { "malar", "nasalis" },
2486     { "malar", "mentalis" },
2487 };
2488
2489 static const struct join_res join_res_seventh[] =
2490 {
2491     { "malar", "nasalis" },
2492     { "malar", "nasalis" },
2493     { "malar", "nasalis" },
2494 };
2495
2496 static const struct join_res_4col join_res_eighth[] =
2497 {
2498     { "msvcp.dll", "msvcp.dll.01234", "msvcp.dll.01234", "abcdefgh" },
2499     { "msvcr.dll", "msvcr.dll.56789", "msvcp.dll.01234", "abcdefgh" },
2500     { "msvcp.dll", "msvcp.dll.01234", "msvcr.dll.56789", "ijklmnop" },
2501     { "msvcr.dll", "msvcr.dll.56789", "msvcr.dll.56789", "ijklmnop" },
2502     { "msvcp.dll", "msvcp.dll.01234", "single.dll.31415", "msvcp.dll" },
2503     { "msvcr.dll", "msvcr.dll.56789", "single.dll.31415", "msvcp.dll" },
2504 };
2505
2506 static void test_join(void)
2507 {
2508     MSIHANDLE hdb, hview, hrec;
2509     LPCSTR query;
2510     CHAR buf[MAX_PATH];
2511     UINT r, count;
2512     DWORD size, i;
2513     BOOL data_correct;
2514
2515     hdb = create_db();
2516     ok( hdb, "failed to create db\n");
2517
2518     r = create_component_table( hdb );
2519     ok( r == ERROR_SUCCESS, "cannot create Component table: %d\n", r );
2520
2521     r = add_component_entry( hdb, "'zygomatic', 'malar', 'INSTALLDIR', 0, '', ''" );
2522     ok( r == ERROR_SUCCESS, "cannot add component: %d\n", r );
2523
2524     r = add_component_entry( hdb, "'maxilla', 'alveolar', 'INSTALLDIR', 0, '', ''" );
2525     ok( r == ERROR_SUCCESS, "cannot add component: %d\n", r );
2526
2527     r = add_component_entry( hdb, "'nasal', 'septum', 'INSTALLDIR', 0, '', ''" );
2528     ok( r == ERROR_SUCCESS, "cannot add component: %d\n", r );
2529
2530     r = add_component_entry( hdb, "'mandible', 'ramus', 'INSTALLDIR', 0, '', ''" );
2531     ok( r == ERROR_SUCCESS, "cannot add component: %d\n", r );
2532
2533     r = create_feature_components_table( hdb );
2534     ok( r == ERROR_SUCCESS, "cannot create FeatureComponents table: %d\n", r );
2535
2536     r = add_feature_components_entry( hdb, "'procerus', 'maxilla'" );
2537     ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2538
2539     r = add_feature_components_entry( hdb, "'procerus', 'nasal'" );
2540     ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2541
2542     r = add_feature_components_entry( hdb, "'nasalis', 'nasal'" );
2543     ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2544
2545     r = add_feature_components_entry( hdb, "'nasalis', 'mandible'" );
2546     ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2547
2548     r = add_feature_components_entry( hdb, "'nasalis', 'notacomponent'" );
2549     ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2550
2551     r = add_feature_components_entry( hdb, "'mentalis', 'zygomatic'" );
2552     ok( r == ERROR_SUCCESS, "cannot add feature components: %d\n", r );
2553
2554     r = create_std_dlls_table( hdb );
2555     ok( r == ERROR_SUCCESS, "cannot create StdDlls table: %d\n", r );
2556
2557     r = add_std_dlls_entry( hdb, "'msvcp.dll', 'msvcp.dll.01234'" );
2558     ok( r == ERROR_SUCCESS, "cannot add std dlls: %d\n", r );
2559
2560     r = add_std_dlls_entry( hdb, "'msvcr.dll', 'msvcr.dll.56789'" );
2561     ok( r == ERROR_SUCCESS, "cannot add std dlls: %d\n", r );
2562
2563     r = create_binary_table( hdb );
2564     ok( r == ERROR_SUCCESS, "cannot create Binary table: %d\n", r );
2565
2566     r = add_binary_entry( hdb, "'msvcp.dll.01234', 'abcdefgh'" );
2567     ok( r == ERROR_SUCCESS, "cannot add binary: %d\n", r );
2568
2569     r = add_binary_entry( hdb, "'msvcr.dll.56789', 'ijklmnop'" );
2570     ok( r == ERROR_SUCCESS, "cannot add binary: %d\n", r );
2571
2572     r = add_binary_entry( hdb, "'single.dll.31415', 'msvcp.dll'" );
2573     ok( r == ERROR_SUCCESS, "cannot add binary: %d\n", r );
2574
2575     query = "SELECT `Component`.`ComponentId`, `FeatureComponents`.`Feature_` "
2576             "FROM `Component`, `FeatureComponents` "
2577             "WHERE `Component`.`Component` = `FeatureComponents`.`Component_` "
2578             "ORDER BY `Feature_`";
2579     r = MsiDatabaseOpenView(hdb, query, &hview);
2580     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2581
2582     r = MsiViewExecute(hview, 0);
2583     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2584
2585     i = 0;
2586     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2587     {
2588         count = MsiRecordGetFieldCount( hrec );
2589         ok( count == 2, "Expected 2 record fields, got %d\n", count );
2590
2591         size = MAX_PATH;
2592         r = MsiRecordGetString( hrec, 1, buf, &size );
2593         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2594         ok( !lstrcmp( buf, join_res_first[i].one ),
2595             "For (row %d, column 1) expected '%s', got %s\n", i, join_res_first[i].one, buf );
2596
2597         size = MAX_PATH;
2598         r = MsiRecordGetString( hrec, 2, buf, &size );
2599         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2600         ok( !lstrcmp( buf, join_res_first[i].two ),
2601             "For (row %d, column 2) expected '%s', got %s\n", i, join_res_first[i].two, buf );
2602
2603         i++;
2604         MsiCloseHandle(hrec);
2605     }
2606
2607     ok( i == 5, "Expected 5 rows, got %d\n", i );
2608     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2609
2610     MsiViewClose(hview);
2611     MsiCloseHandle(hview);
2612
2613     /* try a join without a WHERE condition */
2614     query = "SELECT `Component`.`ComponentId`, `FeatureComponents`.`Feature_` "
2615             "FROM `Component`, `FeatureComponents` ";
2616     r = MsiDatabaseOpenView(hdb, query, &hview);
2617     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2618
2619     r = MsiViewExecute(hview, 0);
2620     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2621
2622     i = 0;
2623     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2624     {
2625         i++;
2626         MsiCloseHandle(hrec);
2627     }
2628     ok( i == 24, "Expected 24 rows, got %d\n", i );
2629
2630     MsiViewClose(hview);
2631     MsiCloseHandle(hview);
2632
2633     query = "SELECT DISTINCT Component, ComponentId FROM FeatureComponents, Component "
2634             "WHERE FeatureComponents.Component_=Component.Component "
2635             "AND (Feature_='nasalis') ORDER BY Feature_";
2636     r = MsiDatabaseOpenView(hdb, query, &hview);
2637     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2638
2639     r = MsiViewExecute(hview, 0);
2640     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2641
2642     i = 0;
2643     data_correct = TRUE;
2644     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2645     {
2646         count = MsiRecordGetFieldCount( hrec );
2647         ok( count == 2, "Expected 2 record fields, got %d\n", count );
2648
2649         size = MAX_PATH;
2650         r = MsiRecordGetString( hrec, 1, buf, &size );
2651         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2652         if( lstrcmp( buf, join_res_second[i].one ))
2653             data_correct = FALSE;
2654
2655         size = MAX_PATH;
2656         r = MsiRecordGetString( hrec, 2, buf, &size );
2657         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2658         if( lstrcmp( buf, join_res_second[i].two ))
2659             data_correct = FALSE;
2660
2661         i++;
2662         MsiCloseHandle(hrec);
2663     }
2664
2665     ok( data_correct, "data returned in the wrong order\n");
2666
2667     ok( i == 2, "Expected 2 rows, got %d\n", i );
2668     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2669
2670     MsiViewClose(hview);
2671     MsiCloseHandle(hview);
2672
2673     query = "SELECT `StdDlls`.`File`, `Binary`.`Data` "
2674             "FROM `StdDlls`, `Binary` "
2675             "WHERE `StdDlls`.`Binary_` = `Binary`.`Name` "
2676             "ORDER BY `File`";
2677     r = MsiDatabaseOpenView(hdb, query, &hview);
2678     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2679
2680     r = MsiViewExecute(hview, 0);
2681     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2682
2683     i = 0;
2684     data_correct = TRUE;
2685     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2686     {
2687         count = MsiRecordGetFieldCount( hrec );
2688         ok( count == 2, "Expected 2 record fields, got %d\n", count );
2689
2690         size = MAX_PATH;
2691         r = MsiRecordGetString( hrec, 1, buf, &size );
2692         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2693         if( lstrcmp( buf, join_res_third[i].one ) )
2694             data_correct = FALSE;
2695
2696         size = MAX_PATH;
2697         r = MsiRecordGetString( hrec, 2, buf, &size );
2698         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2699         if( lstrcmp( buf, join_res_third[i].two ) )
2700             data_correct = FALSE;
2701
2702         i++;
2703         MsiCloseHandle(hrec);
2704     }
2705     ok( data_correct, "data returned in the wrong order\n");
2706
2707     ok( i == 2, "Expected 2 rows, got %d\n", i );
2708
2709     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2710
2711     MsiViewClose(hview);
2712     MsiCloseHandle(hview);
2713
2714     query = "SELECT `StdDlls`.`Binary_`, `Binary`.`Name` "
2715             "FROM `StdDlls`, `Binary` "
2716             "WHERE `StdDlls`.`File` = `Binary`.`Data` "
2717             "ORDER BY `Name`";
2718     r = MsiDatabaseOpenView(hdb, query, &hview);
2719     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2720
2721     r = MsiViewExecute(hview, 0);
2722     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2723
2724     i = 0;
2725     data_correct = TRUE;
2726     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2727     {
2728         count = MsiRecordGetFieldCount( hrec );
2729         ok( count == 2, "Expected 2 record fields, got %d\n", count );
2730
2731         size = MAX_PATH;
2732         r = MsiRecordGetString( hrec, 1, buf, &size );
2733         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2734         if( lstrcmp( buf, join_res_fourth[i].one ))
2735             data_correct = FALSE;
2736
2737         size = MAX_PATH;
2738         r = MsiRecordGetString( hrec, 2, buf, &size );
2739         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2740         if( lstrcmp( buf, join_res_fourth[i].two ))
2741             data_correct = FALSE;
2742
2743         i++;
2744         MsiCloseHandle(hrec);
2745     }
2746     ok( data_correct, "data returned in the wrong order\n");
2747
2748     ok( i == 1, "Expected 1 rows, got %d\n", i );
2749     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2750
2751     MsiViewClose(hview);
2752     MsiCloseHandle(hview);
2753
2754     query = "SELECT `Component`.`ComponentId`, `FeatureComponents`.`Feature_` "
2755             "FROM `Component`, `FeatureComponents` "
2756             "WHERE `Component`.`Component` = 'zygomatic' "
2757             "AND `FeatureComponents`.`Component_` = 'maxilla' "
2758             "ORDER BY `Feature_`";
2759     r = MsiDatabaseOpenView(hdb, query, &hview);
2760     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2761
2762     r = MsiViewExecute(hview, 0);
2763     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2764
2765     i = 0;
2766     data_correct = TRUE;
2767     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2768     {
2769         count = MsiRecordGetFieldCount( hrec );
2770         ok( count == 2, "Expected 2 record fields, got %d\n", count );
2771
2772         size = MAX_PATH;
2773         r = MsiRecordGetString( hrec, 1, buf, &size );
2774         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2775         if( lstrcmp( buf, join_res_fifth[i].one ))
2776             data_correct = FALSE;
2777
2778         size = MAX_PATH;
2779         r = MsiRecordGetString( hrec, 2, buf, &size );
2780         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2781         if( lstrcmp( buf, join_res_fifth[i].two ))
2782             data_correct = FALSE;
2783
2784         i++;
2785         MsiCloseHandle(hrec);
2786     }
2787     ok( data_correct, "data returned in the wrong order\n");
2788
2789     ok( i == 1, "Expected 1 rows, got %d\n", i );
2790     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2791
2792     MsiViewClose(hview);
2793     MsiCloseHandle(hview);
2794
2795     query = "SELECT `Component`.`ComponentId`, `FeatureComponents`.`Feature_` "
2796             "FROM `Component`, `FeatureComponents` "
2797             "WHERE `Component` = 'zygomatic' "
2798             "ORDER BY `Feature_`";
2799     r = MsiDatabaseOpenView(hdb, query, &hview);
2800     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2801
2802     r = MsiViewExecute(hview, 0);
2803     todo_wine
2804     {
2805         ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2806     }
2807
2808     i = 0;
2809     data_correct = TRUE;
2810     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2811     {
2812         count = MsiRecordGetFieldCount( hrec );
2813         ok( count == 2, "Expected 2 record fields, got %d\n", count );
2814
2815         size = MAX_PATH;
2816         r = MsiRecordGetString( hrec, 1, buf, &size );
2817         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2818         if( lstrcmp( buf, join_res_sixth[i].one ))
2819             data_correct = FALSE;
2820
2821         size = MAX_PATH;
2822         r = MsiRecordGetString( hrec, 2, buf, &size );
2823         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2824         if( lstrcmp( buf, join_res_sixth[i].two ))
2825             data_correct = FALSE;
2826
2827         i++;
2828         MsiCloseHandle(hrec);
2829     }
2830     ok( data_correct, "data returned in the wrong order\n");
2831
2832     todo_wine
2833     {
2834         ok( i == 6, "Expected 6 rows, got %d\n", i );
2835     }
2836     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2837
2838     MsiViewClose(hview);
2839     MsiCloseHandle(hview);
2840
2841     query = "SELECT `Component`.`ComponentId`, `FeatureComponents`.`Feature_` "
2842             "FROM `Component`, `FeatureComponents` "
2843             "WHERE `Component` = 'zygomatic' "
2844             "AND `Feature_` = 'nasalis' "
2845             "ORDER BY `Feature_`";
2846     r = MsiDatabaseOpenView(hdb, query, &hview);
2847     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2848
2849     r = MsiViewExecute(hview, 0);
2850     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2851
2852     i = 0;
2853     data_correct = TRUE;
2854     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2855     {
2856         count = MsiRecordGetFieldCount( hrec );
2857         ok( count == 2, "Expected 2 record fields, got %d\n", count );
2858
2859         size = MAX_PATH;
2860         r = MsiRecordGetString( hrec, 1, buf, &size );
2861         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2862         if( lstrcmp( buf, join_res_seventh[i].one ))
2863             data_correct = FALSE;
2864
2865         size = MAX_PATH;
2866         r = MsiRecordGetString( hrec, 2, buf, &size );
2867         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2868         if( lstrcmp( buf, join_res_seventh[i].two ))
2869             data_correct = FALSE;
2870
2871         i++;
2872         MsiCloseHandle(hrec);
2873     }
2874
2875     ok( data_correct, "data returned in the wrong order\n");
2876     ok( i == 3, "Expected 3 rows, got %d\n", i );
2877     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2878
2879     MsiViewClose(hview);
2880     MsiCloseHandle(hview);
2881
2882     query = "SELECT `StdDlls`.`File`, `Binary`.`Data` "
2883             "FROM `StdDlls`, `Binary` ";
2884     r = MsiDatabaseOpenView(hdb, query, &hview);
2885     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2886
2887     r = MsiViewExecute(hview, 0);
2888     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2889
2890     i = 0;
2891     data_correct = TRUE;
2892     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2893     {
2894         count = MsiRecordGetFieldCount( hrec );
2895         ok( count == 2, "Expected 2 record fields, got %d\n", count );
2896
2897         size = MAX_PATH;
2898         r = MsiRecordGetString( hrec, 1, buf, &size );
2899         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2900         if( lstrcmp( buf, join_res_eighth[i].one ))
2901             data_correct = FALSE;
2902
2903         size = MAX_PATH;
2904         r = MsiRecordGetString( hrec, 2, buf, &size );
2905         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2906         if( lstrcmp( buf, join_res_eighth[i].four ))
2907             data_correct = FALSE;
2908
2909         i++;
2910         MsiCloseHandle(hrec);
2911     }
2912
2913     todo_wine ok( data_correct, "data returned in the wrong order\n");
2914     ok( i == 6, "Expected 6 rows, got %d\n", i );
2915     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2916
2917     MsiViewClose(hview);
2918     MsiCloseHandle(hview);
2919
2920     query = "SELECT * FROM `StdDlls`, `Binary` ";
2921     r = MsiDatabaseOpenView(hdb, query, &hview);
2922     ok( r == ERROR_SUCCESS, "failed to open view: %d\n", r );
2923
2924     r = MsiViewExecute(hview, 0);
2925     ok( r == ERROR_SUCCESS, "failed to execute view: %d\n", r );
2926
2927     i = 0;
2928     data_correct = TRUE;
2929     while ((r = MsiViewFetch(hview, &hrec)) == ERROR_SUCCESS)
2930     {
2931         count = MsiRecordGetFieldCount( hrec );
2932         ok( count == 4, "Expected 4 record fields, got %d\n", count );
2933
2934         size = MAX_PATH;
2935         r = MsiRecordGetString( hrec, 1, buf, &size );
2936         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2937         if( lstrcmp( buf, join_res_eighth[i].one ))
2938             data_correct = FALSE;
2939
2940         size = MAX_PATH;
2941         r = MsiRecordGetString( hrec, 2, buf, &size );
2942         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2943         if( lstrcmp( buf, join_res_eighth[i].two ))
2944             data_correct = FALSE;
2945
2946         size = MAX_PATH;
2947         r = MsiRecordGetString( hrec, 3, buf, &size );
2948         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2949         if( lstrcmp( buf, join_res_eighth[i].three ))
2950             data_correct = FALSE;
2951
2952         size = MAX_PATH;
2953         r = MsiRecordGetString( hrec, 4, buf, &size );
2954         ok( r == ERROR_SUCCESS, "failed to get record string: %d\n", r );
2955         if( lstrcmp( buf, join_res_eighth[i].four ))
2956             data_correct = FALSE;
2957
2958         i++;
2959         MsiCloseHandle(hrec);
2960     }
2961     todo_wine ok( data_correct, "data returned in the wrong order\n");
2962
2963     ok( i == 6, "Expected 6 rows, got %d\n", i );
2964     ok( r == ERROR_NO_MORE_ITEMS, "expected no more items: %d\n", r );
2965
2966     MsiViewClose(hview);
2967     MsiCloseHandle(hview);
2968
2969     MsiCloseHandle(hdb);
2970     DeleteFile(msifile);
2971 }
2972
2973 static void test_temporary_table(void)
2974 {
2975     MSICONDITION cond;
2976     MSIHANDLE hdb = 0, view = 0, rec;
2977     const char *query;
2978     UINT r;
2979     char buf[0x10];
2980     DWORD sz;
2981
2982     cond = MsiDatabaseIsTablePersistent(0, NULL);
2983     ok( cond == MSICONDITION_ERROR, "wrong return condition\n");
2984
2985     hdb = create_db();
2986     ok( hdb, "failed to create db\n");
2987
2988     cond = MsiDatabaseIsTablePersistent(hdb, NULL);
2989     ok( cond == MSICONDITION_ERROR, "wrong return condition\n");
2990
2991     todo_wine {
2992     cond = MsiDatabaseIsTablePersistent(hdb, "_Tables");
2993     ok( cond == MSICONDITION_NONE, "wrong return condition\n");
2994
2995     cond = MsiDatabaseIsTablePersistent(hdb, "_Columns");
2996     ok( cond == MSICONDITION_NONE, "wrong return condition\n");
2997     }
2998
2999     cond = MsiDatabaseIsTablePersistent(hdb, "_Streams");
3000     ok( cond == MSICONDITION_NONE, "wrong return condition\n");
3001
3002     query = "CREATE TABLE `P` ( `B` SHORT NOT NULL, `C` CHAR(255) PRIMARY KEY `C`)";
3003     r = run_query(hdb, 0, query);
3004     ok(r == ERROR_SUCCESS, "failed to add table\n");
3005
3006     cond = MsiDatabaseIsTablePersistent(hdb, "P");
3007     ok( cond == MSICONDITION_TRUE, "wrong return condition\n");
3008
3009     query = "CREATE TABLE `P2` ( `B` SHORT NOT NULL, `C` CHAR(255) PRIMARY KEY `C`) HOLD";
3010     r = run_query(hdb, 0, query);
3011     ok(r == ERROR_SUCCESS, "failed to add table\n");
3012
3013     cond = MsiDatabaseIsTablePersistent(hdb, "P2");
3014     ok( cond == MSICONDITION_TRUE, "wrong return condition\n");
3015
3016     query = "CREATE TABLE `T` ( `B` SHORT NOT NULL TEMPORARY, `C` CHAR(255) TEMPORARY PRIMARY KEY `C`) HOLD";
3017     r = run_query(hdb, 0, query);
3018     ok(r == ERROR_SUCCESS, "failed to add table\n");
3019
3020     cond = MsiDatabaseIsTablePersistent(hdb, "T");
3021     ok( cond == MSICONDITION_FALSE, "wrong return condition\n");
3022
3023     query = "CREATE TABLE `T2` ( `B` SHORT NOT NULL TEMPORARY, `C` CHAR(255) TEMPORARY PRIMARY KEY `C`)";
3024     r = run_query(hdb, 0, query);
3025     ok(r == ERROR_SUCCESS, "failed to add table\n");
3026
3027     todo_wine {
3028     cond = MsiDatabaseIsTablePersistent(hdb, "T2");
3029     ok( cond == MSICONDITION_NONE, "wrong return condition\n");
3030     }
3031
3032     query = "CREATE TABLE `T3` ( `B` SHORT NOT NULL TEMPORARY, `C` CHAR(255) PRIMARY KEY `C`)";
3033     r = run_query(hdb, 0, query);
3034     ok(r == ERROR_SUCCESS, "failed to add table\n");
3035
3036     cond = MsiDatabaseIsTablePersistent(hdb, "T3");
3037     ok( cond == MSICONDITION_TRUE, "wrong return condition\n");
3038
3039     todo_wine {
3040     query = "CREATE TABLE `T4` ( `B` SHORT NOT NULL, `C` CHAR(255) TEMPORARY PRIMARY KEY `C`)";
3041     r = run_query(hdb, 0, query);
3042     ok(r == ERROR_FUNCTION_FAILED, "failed to add table\n");
3043
3044     cond = MsiDatabaseIsTablePersistent(hdb, "T4");
3045     ok( cond == MSICONDITION_NONE, "wrong return condition\n");
3046     }
3047
3048     query = "CREATE TABLE `T5` ( `B` SHORT NOT NULL TEMP, `C` CHAR(255) TEMP PRIMARY KEY `C`) HOLD";
3049     r = run_query(hdb, 0, query);
3050     ok(r == ERROR_BAD_QUERY_SYNTAX, "failed to add table\n");
3051
3052     query = "select * from `T`";
3053     r = MsiDatabaseOpenView(hdb, query, &view);
3054     ok(r == ERROR_SUCCESS, "failed to query table\n");
3055     r = MsiViewGetColumnInfo(view, MSICOLINFO_TYPES, &rec);
3056     ok(r == ERROR_SUCCESS, "failed to get column info\n");
3057
3058     sz = sizeof buf;
3059     r = MsiRecordGetString(rec, 1, buf, &sz);
3060     ok(r == ERROR_SUCCESS, "failed to get string\n");
3061     todo_wine ok( 0 == strcmp("G255", buf), "wrong column type\n");
3062
3063     sz = sizeof buf;
3064     r = MsiRecordGetString(rec, 2, buf, &sz);
3065     ok(r == ERROR_SUCCESS, "failed to get string\n");
3066     todo_wine ok( 0 == strcmp("j2", buf), "wrong column type\n");
3067
3068     MsiCloseHandle( rec );
3069     MsiCloseHandle( view );
3070
3071     /* query the table data */
3072     rec = 0;
3073     r = do_query(hdb, "select * from `_Tables` where `Name` = 'T'", &rec);
3074     ok( r == ERROR_SUCCESS, "temporary table exists in _Tables\n");
3075     MsiCloseHandle( rec );
3076
3077     /* query the column data */
3078     rec = 0;
3079     r = do_query(hdb, "select * from `_Columns` where `Table` = 'T' AND `Name` = 'B'", &rec);
3080     ok( r == ERROR_NO_MORE_ITEMS, "temporary table exists in _Columns\n");
3081     if (rec) MsiCloseHandle( rec );
3082
3083     r = do_query(hdb, "select * from `_Columns` where `Table` = 'T' AND `Name` = 'C'", &rec);
3084     ok( r == ERROR_NO_MORE_ITEMS, "temporary table exists in _Columns\n");
3085     if (rec) MsiCloseHandle( rec );
3086
3087     MsiCloseHandle( hdb );
3088
3089     DeleteFile(msifile);
3090 }
3091
3092 static void test_alter(void)
3093 {
3094     MSICONDITION cond;
3095     MSIHANDLE hdb = 0;
3096     const char *query;
3097     UINT r;
3098
3099     hdb = create_db();
3100     ok( hdb, "failed to create db\n");
3101
3102     query = "CREATE TABLE `T` ( `B` SHORT NOT NULL TEMPORARY, `C` CHAR(255) TEMPORARY PRIMARY KEY `C`) HOLD";
3103     r = run_query(hdb, 0, query);
3104     ok(r == ERROR_SUCCESS, "failed to add table\n");
3105
3106     cond = MsiDatabaseIsTablePersistent(hdb, "T");
3107     ok( cond == MSICONDITION_FALSE, "wrong return condition\n");
3108
3109     query = "ALTER TABLE `T` HOLD";
3110     r = run_query(hdb, 0, query);
3111     ok(r == ERROR_SUCCESS, "failed to hold table %d\n", r);
3112
3113     query = "ALTER TABLE `T` FREE";
3114     r = run_query(hdb, 0, query);
3115     ok(r == ERROR_SUCCESS, "failed to free table\n");
3116
3117     query = "ALTER TABLE `T` FREE";
3118     r = run_query(hdb, 0, query);
3119     ok(r == ERROR_SUCCESS, "failed to free table\n");
3120
3121     query = "ALTER TABLE `T` FREE";
3122     r = run_query(hdb, 0, query);
3123     ok(r == ERROR_BAD_QUERY_SYNTAX, "failed to free table\n");
3124
3125     query = "ALTER TABLE `T` HOLD";
3126     r = run_query(hdb, 0, query);
3127     ok(r == ERROR_BAD_QUERY_SYNTAX, "failed to hold table %d\n", r);
3128
3129     /* table T is removed */
3130     query = "SELECT * FROM `T`";
3131     r = run_query(hdb, 0, query);
3132     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3133
3134     /* create the table again */
3135     query = "CREATE TABLE `U` ( `A` INTEGER, `B` INTEGER PRIMARY KEY `B`)";
3136     r = run_query(hdb, 0, query);
3137     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3138
3139     /* up the ref count */
3140     query = "ALTER TABLE `U` HOLD";
3141     r = run_query(hdb, 0, query);
3142     ok(r == ERROR_SUCCESS, "failed to free table\n");
3143
3144     /* add column, no data type */
3145     query = "ALTER TABLE `U` ADD `C`";
3146     r = run_query(hdb, 0, query);
3147     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3148
3149     query = "ALTER TABLE `U` ADD `C` INTEGER";
3150     r = run_query(hdb, 0, query);
3151     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3152
3153     /* add column C again */
3154     query = "ALTER TABLE `U` ADD `C` INTEGER";
3155     r = run_query(hdb, 0, query);
3156     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3157
3158     query = "ALTER TABLE `U` ADD `D` INTEGER TEMPORARY";
3159     r = run_query(hdb, 0, query);
3160     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3161
3162     query = "INSERT INTO `U` ( `A`, `B`, `C`, `D` ) VALUES ( 1, 2, 3, 4 )";
3163     r = run_query(hdb, 0, query);
3164     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3165
3166     query = "ALTER TABLE `U` ADD `D` INTEGER TEMPORARY HOLD";
3167     r = run_query(hdb, 0, query);
3168     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3169
3170     query = "INSERT INTO `U` ( `A`, `B`, `C`, `D` ) VALUES ( 5, 6, 7, 8 )";
3171     r = run_query(hdb, 0, query);
3172     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3173
3174     query = "SELECT * FROM `U` WHERE `D` = 8";
3175     r = run_query(hdb, 0, query);
3176     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3177
3178     query = "ALTER TABLE `U` ADD `D` INTEGER TEMPORARY FREE";
3179     r = run_query(hdb, 0, query);
3180     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3181
3182     query = "ALTER COLUMN `D` FREE";
3183     r = run_query(hdb, 0, query);
3184     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3185
3186     /* drop the ref count */
3187     query = "ALTER TABLE `U` FREE";
3188     r = run_query(hdb, 0, query);
3189     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3190
3191     /* table is not empty */
3192     query = "SELECT * FROM `U`";
3193     r = run_query(hdb, 0, query);
3194     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3195
3196     /* column D is removed */
3197     query = "SELECT * FROM `U` WHERE `D` = 8";
3198     r = run_query(hdb, 0, query);
3199     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3200
3201     query = "INSERT INTO `U` ( `A`, `B`, `C`, `D` ) VALUES ( 9, 10, 11, 12 )";
3202     r = run_query(hdb, 0, query);
3203     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3204
3205     /* add the column again */
3206     query = "ALTER TABLE `U` ADD `E` INTEGER TEMPORARY HOLD";
3207     r = run_query(hdb, 0, query);
3208     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3209
3210     /* up the ref count */
3211     query = "ALTER TABLE `U` HOLD";
3212     r = run_query(hdb, 0, query);
3213     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3214
3215     query = "INSERT INTO `U` ( `A`, `B`, `C`, `E` ) VALUES ( 13, 14, 15, 16 )";
3216     r = run_query(hdb, 0, query);
3217     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3218
3219     query = "SELECT * FROM `U` WHERE `E` = 16";
3220     r = run_query(hdb, 0, query);
3221     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3222
3223     /* drop the ref count */
3224     query = "ALTER TABLE `U` FREE";
3225     r = run_query(hdb, 0, query);
3226     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3227
3228     query = "INSERT INTO `U` ( `A`, `B`, `C`, `E` ) VALUES ( 17, 18, 19, 20 )";
3229     r = run_query(hdb, 0, query);
3230     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3231
3232     query = "SELECT * FROM `U` WHERE `E` = 20";
3233     r = run_query(hdb, 0, query);
3234     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3235
3236     /* drop the ref count */
3237     query = "ALTER TABLE `U` FREE";
3238     r = run_query(hdb, 0, query);
3239     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3240
3241     /* table still exists */
3242     query = "SELECT * FROM `U`";
3243     r = run_query(hdb, 0, query);
3244     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3245
3246     /* col E is removed */
3247     query = "SELECT * FROM `U` WHERE `E` = 20";
3248     r = run_query(hdb, 0, query);
3249     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3250
3251     query = "INSERT INTO `U` ( `A`, `B`, `C`, `E` ) VALUES ( 20, 21, 22, 23 )";
3252     r = run_query(hdb, 0, query);
3253     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3254
3255     /* drop the ref count once more */
3256     query = "ALTER TABLE `U` FREE";
3257     r = run_query(hdb, 0, query);
3258     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3259
3260     /* table still exists */
3261     query = "SELECT * FROM `U`";
3262     r = run_query(hdb, 0, query);
3263     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3264
3265     MsiCloseHandle( hdb );
3266     DeleteFile(msifile);
3267 }
3268
3269 static void test_integers(void)
3270 {
3271     MSIHANDLE hdb = 0, view = 0, rec = 0;
3272     DWORD count, i;
3273     const char *query;
3274     UINT r;
3275
3276     /* just MsiOpenDatabase should not create a file */
3277     r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
3278     ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
3279
3280     /* create a table */
3281     query = "CREATE TABLE `integers` ( "
3282             "`one` SHORT, `two` INT, `three` INTEGER, `four` LONG, "
3283             "`five` SHORT NOT NULL, `six` INT NOT NULL, "
3284             "`seven` INTEGER NOT NULL, `eight` LONG NOT NULL "
3285             "PRIMARY KEY `one`)";
3286     r = MsiDatabaseOpenView(hdb, query, &view);
3287     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
3288     r = MsiViewExecute(view, 0);
3289     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
3290     r = MsiViewClose(view);
3291     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3292     r = MsiCloseHandle(view);
3293     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3294
3295     query = "SELECT * FROM `integers`";
3296     r = MsiDatabaseOpenView(hdb, query, &view);
3297     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3298
3299     r = MsiViewGetColumnInfo(view, MSICOLINFO_NAMES, &rec);
3300     count = MsiRecordGetFieldCount(rec);
3301     ok(count == 8, "Expected 8, got %d\n", count);
3302     ok(check_record(rec, 1, "one"), "Expected one\n");
3303     ok(check_record(rec, 2, "two"), "Expected two\n");
3304     ok(check_record(rec, 3, "three"), "Expected three\n");
3305     ok(check_record(rec, 4, "four"), "Expected four\n");
3306     ok(check_record(rec, 5, "five"), "Expected five\n");
3307     ok(check_record(rec, 6, "six"), "Expected six\n");
3308     ok(check_record(rec, 7, "seven"), "Expected seven\n");
3309     ok(check_record(rec, 8, "eight"), "Expected eight\n");
3310     MsiCloseHandle(rec);
3311
3312     r = MsiViewGetColumnInfo(view, MSICOLINFO_TYPES, &rec);
3313     count = MsiRecordGetFieldCount(rec);
3314     ok(count == 8, "Expected 8, got %d\n", count);
3315     ok(check_record(rec, 1, "I2"), "Expected I2\n");
3316     ok(check_record(rec, 2, "I2"), "Expected I2\n");
3317     ok(check_record(rec, 3, "I2"), "Expected I2\n");
3318     ok(check_record(rec, 4, "I4"), "Expected I4\n");
3319     ok(check_record(rec, 5, "i2"), "Expected i2\n");
3320     ok(check_record(rec, 6, "i2"), "Expected i2\n");
3321     ok(check_record(rec, 7, "i2"), "Expected i2\n");
3322     ok(check_record(rec, 8, "i4"), "Expected i4\n");
3323     MsiCloseHandle(rec);
3324
3325     MsiViewClose(view);
3326     MsiCloseHandle(view);
3327
3328     /* insert values into it, NULL where NOT NULL is specified */
3329     query = "INSERT INTO `integers` ( `one`, `two`, `three`, `four`, `five`, `six`, `seven`, `eight` )"
3330         "VALUES('', '', '', '', '', '', '', '')";
3331     r = MsiDatabaseOpenView(hdb, query, &view);
3332     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3333     r = MsiViewExecute(view, 0);
3334     ok(r == ERROR_FUNCTION_FAILED, "Expected ERROR_FUNCTION_FAILED, got %d\n", r);
3335
3336     MsiViewClose(view);
3337     MsiCloseHandle(view);
3338
3339     query = "SELECT * FROM `integers`";
3340     r = do_query(hdb, query, &rec);
3341     ok(r == ERROR_NO_MORE_ITEMS, "Expected ERROR_NO_MORE_ITEMS, got %d\n", r);
3342
3343     r = MsiRecordGetFieldCount(rec);
3344     ok(r == -1, "record count wrong: %d\n", r);
3345
3346     MsiCloseHandle(rec);
3347
3348     /* insert legitimate values into it */
3349     query = "INSERT INTO `integers` ( `one`, `two`, `three`, `four`, `five`, `six`, `seven`, `eight` )"
3350         "VALUES('', '2', '', '4', '5', '6', '7', '8')";
3351     r = MsiDatabaseOpenView(hdb, query, &view);
3352     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3353     r = MsiViewExecute(view, 0);
3354     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3355
3356     query = "SELECT * FROM `integers`";
3357     r = do_query(hdb, query, &rec);
3358     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3359
3360     r = MsiRecordGetFieldCount(rec);
3361     ok(r == 8, "record count wrong: %d\n", r);
3362
3363     i = MsiRecordGetInteger(rec, 1);
3364     ok(i == MSI_NULL_INTEGER, "Expected MSI_NULL_INTEGER, got %d\n", i);
3365     i = MsiRecordGetInteger(rec, 3);
3366     ok(i == MSI_NULL_INTEGER, "Expected MSI_NULL_INTEGER, got %d\n", i);
3367     i = MsiRecordGetInteger(rec, 2);
3368     ok(i == 2, "Expected 2, got %d\n", i);
3369     i = MsiRecordGetInteger(rec, 4);
3370     ok(i == 4, "Expected 4, got %d\n", i);
3371     i = MsiRecordGetInteger(rec, 5);
3372     ok(i == 5, "Expected 5, got %d\n", i);
3373     i = MsiRecordGetInteger(rec, 6);
3374     ok(i == 6, "Expected 6, got %d\n", i);
3375     i = MsiRecordGetInteger(rec, 7);
3376     ok(i == 7, "Expected 7, got %d\n", i);
3377     i = MsiRecordGetInteger(rec, 8);
3378     ok(i == 8, "Expected 8, got %d\n", i);
3379
3380     MsiCloseHandle(rec);
3381     MsiViewClose(view);
3382     MsiCloseHandle(view);
3383
3384     r = MsiDatabaseCommit(hdb);
3385     ok(r == ERROR_SUCCESS, "MsiDatabaseCommit failed\n");
3386
3387     r = MsiCloseHandle(hdb);
3388     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3389
3390     r = DeleteFile(msifile);
3391     ok(r == TRUE, "file didn't exist after commit\n");
3392 }
3393
3394 static void test_update(void)
3395 {
3396     MSIHANDLE hdb = 0, view = 0, rec = 0;
3397     CHAR result[MAX_PATH];
3398     const char *query;
3399     DWORD size;
3400     UINT r;
3401
3402     /* just MsiOpenDatabase should not create a file */
3403     r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
3404     ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
3405
3406     /* create the Control table */
3407     query = "CREATE TABLE `Control` ( "
3408         "`Dialog_` CHAR(72) NOT NULL, `Control` CHAR(50) NOT NULL, `Type` SHORT NOT NULL, "
3409         "`X` SHORT NOT NULL, `Y` SHORT NOT NULL, `Width` SHORT NOT NULL, `Height` SHORT NOT NULL,"
3410         "`Attributes` LONG, `Property` CHAR(50), `Text` CHAR(0) LOCALIZABLE, "
3411         "`Control_Next` CHAR(50), `Help` CHAR(50) LOCALIZABLE PRIMARY KEY `Dialog_`, `Control`)";
3412     r = MsiDatabaseOpenView(hdb, query, &view);
3413     ok(r == ERROR_SUCCESS, "MsiDatabaseOpenView failed\n");
3414     r = MsiViewExecute(view, 0);
3415     ok(r == ERROR_SUCCESS, "MsiViewExecute failed\n");
3416     r = MsiViewClose(view);
3417     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3418     r = MsiCloseHandle(view);
3419     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3420
3421     /* add a control */
3422     query = "INSERT INTO `Control` ( "
3423         "`Dialog_`, `Control`, `Type`, `X`, `Y`, `Width`, `Height`, "
3424         "`Property`, `Text`, `Control_Next`, `Help` )"
3425         "VALUES('ErrorDialog', 'ErrorText', '1', '5', '5', '5', '5', '', '', '', '')";
3426     r = MsiDatabaseOpenView(hdb, query, &view);
3427     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3428     r = MsiViewExecute(view, 0);
3429     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3430     r = MsiViewClose(view);
3431     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3432     r = MsiCloseHandle(view);
3433     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3434
3435     /* add a second control */
3436     query = "INSERT INTO `Control` ( "
3437         "`Dialog_`, `Control`, `Type`, `X`, `Y`, `Width`, `Height`, "
3438         "`Property`, `Text`, `Control_Next`, `Help` )"
3439         "VALUES('ErrorDialog', 'Button', '1', '5', '5', '5', '5', '', '', '', '')";
3440     r = MsiDatabaseOpenView(hdb, query, &view);
3441     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3442     r = MsiViewExecute(view, 0);
3443     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3444     r = MsiViewClose(view);
3445     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3446     r = MsiCloseHandle(view);
3447     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3448
3449     /* add a third control */
3450     query = "INSERT INTO `Control` ( "
3451         "`Dialog_`, `Control`, `Type`, `X`, `Y`, `Width`, `Height`, "
3452         "`Property`, `Text`, `Control_Next`, `Help` )"
3453         "VALUES('AnotherDialog', 'ErrorText', '1', '5', '5', '5', '5', '', '', '', '')";
3454     r = MsiDatabaseOpenView(hdb, query, &view);
3455     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3456     r = MsiViewExecute(view, 0);
3457     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3458     r = MsiViewClose(view);
3459     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3460     r = MsiCloseHandle(view);
3461     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3462
3463     /* bad table */
3464     query = "UPDATE `NotATable` SET `Text` = 'this is text' WHERE `Dialog_` = 'ErrorDialog'";
3465     r = MsiDatabaseOpenView(hdb, query, &view);
3466     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3467
3468     /* bad set column */
3469     query = "UPDATE `Control` SET `NotAColumn` = 'this is text' WHERE `Dialog_` = 'ErrorDialog'";
3470     r = MsiDatabaseOpenView(hdb, query, &view);
3471     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3472
3473     /* bad where condition */
3474     query = "UPDATE `Control` SET `Text` = 'this is text' WHERE `NotAColumn` = 'ErrorDialog'";
3475     r = MsiDatabaseOpenView(hdb, query, &view);
3476     ok(r == ERROR_BAD_QUERY_SYNTAX, "Expected ERROR_BAD_QUERY_SYNTAX, got %d\n", r);
3477
3478     /* just the dialog_ specified */
3479     query = "UPDATE `Control` SET `Text` = 'this is text' WHERE `Dialog_` = 'ErrorDialog'";
3480     r = MsiDatabaseOpenView(hdb, query, &view);
3481     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3482     r = MsiViewExecute(view, 0);
3483     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3484     r = MsiViewClose(view);
3485     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3486     r = MsiCloseHandle(view);
3487     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3488
3489     /* check the modified text */
3490     query = "SELECT `Text` FROM `Control` WHERE `Control` = 'ErrorText'";
3491     r = MsiDatabaseOpenView(hdb, query, &view);
3492     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3493     r = MsiViewExecute(view, 0);
3494     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3495
3496     r = MsiViewFetch(view, &rec);
3497     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3498
3499     size = MAX_PATH;
3500     r = MsiRecordGetString(rec, 1, result, &size);
3501     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3502     ok(!lstrcmp(result, "this is text"), "Expected `this is text`, got %s\n", result);
3503
3504     MsiCloseHandle(rec);
3505
3506     r = MsiViewFetch(view, &rec);
3507     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3508
3509     size = MAX_PATH;
3510     r = MsiRecordGetString(rec, 1, result, &size);
3511     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3512     ok(!lstrlen(result), "Expected an empty string, got %s\n", result);
3513
3514     MsiCloseHandle(rec);
3515
3516     r = MsiViewFetch(view, &rec);
3517     ok(r == ERROR_NO_MORE_ITEMS, "Expected ERROR_NO_MORE_ITEMS, got %d\n", r);
3518
3519     r = MsiViewClose(view);
3520     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3521     r = MsiCloseHandle(view);
3522     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3523
3524     /* dialog_ and control specified */
3525     query = "UPDATE `Control` SET `Text` = 'this is text' WHERE `Dialog_` = 'ErrorDialog' AND `Control` = 'ErrorText'";
3526     r = MsiDatabaseOpenView(hdb, query, &view);
3527     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3528     r = MsiViewExecute(view, 0);
3529     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3530     r = MsiViewClose(view);
3531     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3532     r = MsiCloseHandle(view);
3533     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3534
3535     /* check the modified text */
3536     query = "SELECT `Text` FROM `Control` WHERE `Control` = 'ErrorText'";
3537     r = MsiDatabaseOpenView(hdb, query, &view);
3538     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3539     r = MsiViewExecute(view, 0);
3540     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3541
3542     r = MsiViewFetch(view, &rec);
3543     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3544
3545     size = MAX_PATH;
3546     r = MsiRecordGetString(rec, 1, result, &size);
3547     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3548     ok(!lstrcmp(result, "this is text"), "Expected `this is text`, got %s\n", result);
3549
3550     MsiCloseHandle(rec);
3551
3552     r = MsiViewFetch(view, &rec);
3553     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3554
3555     size = MAX_PATH;
3556     r = MsiRecordGetString(rec, 1, result, &size);
3557     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3558     ok(!lstrlen(result), "Expected an empty string, got %s\n", result);
3559
3560     MsiCloseHandle(rec);
3561
3562     r = MsiViewFetch(view, &rec);
3563     ok(r == ERROR_NO_MORE_ITEMS, "Expected ERROR_NO_MORE_ITEMS, got %d\n", r);
3564
3565     r = MsiViewClose(view);
3566     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3567     r = MsiCloseHandle(view);
3568     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3569
3570     /* no where condition */
3571     query = "UPDATE `Control` SET `Text` = 'this is text'";
3572     r = MsiDatabaseOpenView(hdb, query, &view);
3573     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3574     r = MsiViewExecute(view, 0);
3575     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3576     r = MsiViewClose(view);
3577     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3578     r = MsiCloseHandle(view);
3579     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3580
3581     /* check the modified text */
3582     query = "SELECT `Text` FROM `Control`";
3583     r = MsiDatabaseOpenView(hdb, query, &view);
3584     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3585     r = MsiViewExecute(view, 0);
3586     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3587
3588     r = MsiViewFetch(view, &rec);
3589     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3590
3591     size = MAX_PATH;
3592     r = MsiRecordGetString(rec, 1, result, &size);
3593     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3594     ok(!lstrcmp(result, "this is text"), "Expected `this is text`, got %s\n", result);
3595
3596     MsiCloseHandle(rec);
3597
3598     r = MsiViewFetch(view, &rec);
3599     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3600
3601     size = MAX_PATH;
3602     r = MsiRecordGetString(rec, 1, result, &size);
3603     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3604     ok(!lstrcmp(result, "this is text"), "Expected `this is text`, got %s\n", result);
3605
3606     MsiCloseHandle(rec);
3607
3608     r = MsiViewFetch(view, &rec);
3609     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3610
3611     size = MAX_PATH;
3612     r = MsiRecordGetString(rec, 1, result, &size);
3613     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3614     ok(!lstrcmp(result, "this is text"), "Expected `this is text`, got %s\n", result);
3615
3616     MsiCloseHandle(rec);
3617
3618     r = MsiViewFetch(view, &rec);
3619     ok(r == ERROR_NO_MORE_ITEMS, "Expected ERROR_NO_MORE_ITEMS, got %d\n", r);
3620
3621     r = MsiViewClose(view);
3622     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3623     r = MsiCloseHandle(view);
3624     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3625     r = MsiDatabaseCommit(hdb);
3626     ok(r == ERROR_SUCCESS, "MsiDatabaseCommit failed\n");
3627     r = MsiCloseHandle(hdb);
3628     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3629
3630     DeleteFile(msifile);
3631 }
3632
3633 static void test_special_tables(void)
3634 {
3635     const char *query;
3636     MSIHANDLE hdb = 0;
3637     UINT r;
3638
3639     r = MsiOpenDatabase(msifile, MSIDBOPEN_CREATE, &hdb);
3640     ok(r == ERROR_SUCCESS, "MsiOpenDatabase failed\n");
3641
3642     query = "CREATE TABLE `_Properties` ( "
3643         "`foo` INT NOT NULL, `bar` INT LOCALIZABLE PRIMARY KEY `foo`)";
3644     r = run_query(hdb, 0, query);
3645     ok(r == ERROR_SUCCESS, "failed to create table\n");
3646
3647     query = "CREATE TABLE `_Streams` ( "
3648         "`foo` INT NOT NULL, `bar` INT LOCALIZABLE PRIMARY KEY `foo`)";
3649     r = run_query(hdb, 0, query);
3650     todo_wine ok(r == ERROR_BAD_QUERY_SYNTAX, "created _Streams table\n");
3651
3652     query = "CREATE TABLE `_Tables` ( "
3653         "`foo` INT NOT NULL, `bar` INT LOCALIZABLE PRIMARY KEY `foo`)";
3654     r = run_query(hdb, 0, query);
3655     ok(r == ERROR_BAD_QUERY_SYNTAX, "created _Tables table\n");
3656
3657     query = "CREATE TABLE `_Columns` ( "
3658         "`foo` INT NOT NULL, `bar` INT LOCALIZABLE PRIMARY KEY `foo`)";
3659     r = run_query(hdb, 0, query);
3660     ok(r == ERROR_BAD_QUERY_SYNTAX, "created _Columns table\n");
3661
3662     r = MsiCloseHandle(hdb);
3663     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3664 }
3665
3666 static void test_select_markers(void)
3667 {
3668     MSIHANDLE hdb = 0, rec, view, res;
3669     LPCSTR query;
3670     UINT r;
3671     DWORD size;
3672     CHAR buf[MAX_PATH];
3673
3674     hdb = create_db();
3675     ok( hdb, "failed to create db\n");
3676
3677     r = run_query(hdb, 0,
3678             "CREATE TABLE `Table` (`One` CHAR(72), `Two` CHAR(72), `Three` SHORT PRIMARY KEY `One`, `Two`, `Three`)");
3679     ok(r == S_OK, "cannot create table: %d\n", r);
3680
3681     r = run_query(hdb, 0, "INSERT INTO `Table` "
3682             "( `One`, `Two`, `Three` ) VALUES ( 'apple', 'one', 1 )");
3683     ok(r == S_OK, "cannot add file to the Media table: %d\n", r);
3684
3685     r = run_query(hdb, 0, "INSERT INTO `Table` "
3686             "( `One`, `Two`, `Three` ) VALUES ( 'apple', 'two', 1 )");
3687     ok(r == S_OK, "cannot add file to the Media table: %d\n", r);
3688
3689     r = run_query(hdb, 0, "INSERT INTO `Table` "
3690             "( `One`, `Two`, `Three` ) VALUES ( 'apple', 'two', 2 )");
3691     ok(r == S_OK, "cannot add file to the Media table: %d\n", r);
3692
3693     r = run_query(hdb, 0, "INSERT INTO `Table` "
3694             "( `One`, `Two`, `Three` ) VALUES ( 'banana', 'three', 3 )");
3695     ok(r == S_OK, "cannot add file to the Media table: %d\n", r);
3696
3697     rec = MsiCreateRecord(2);
3698     MsiRecordSetString(rec, 1, "apple");
3699     MsiRecordSetString(rec, 2, "two");
3700
3701     query = "SELECT * FROM `Table` WHERE `One`=? AND `Two`=? ORDER BY `Three`";
3702     r = MsiDatabaseOpenView(hdb, query, &view);
3703     ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3704
3705     r = MsiViewExecute(view, rec);
3706     todo_wine
3707     {
3708         ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3709     }
3710
3711     r = MsiViewFetch(view, &res);
3712     todo_wine
3713     {
3714         ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3715     }
3716
3717     size = MAX_PATH;
3718     r = MsiRecordGetString(res, 1, buf, &size);
3719     todo_wine
3720     {
3721         ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3722         ok(!lstrcmp(buf, "apple"), "Expected apple, got %s\n", buf);
3723     }
3724
3725     size = MAX_PATH;
3726     r = MsiRecordGetString(res, 2, buf, &size);
3727     todo_wine
3728     {
3729         ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3730         ok(!lstrcmp(buf, "two"), "Expected two, got %s\n", buf);
3731     }
3732
3733     r = MsiRecordGetInteger(res, 3);
3734     todo_wine
3735     {
3736         ok(r == 1, "Expected 1, got %d\n", r);
3737     }
3738
3739     MsiCloseHandle(res);
3740
3741     r = MsiViewFetch(view, &res);
3742     todo_wine
3743     {
3744         ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3745     }
3746
3747     size = MAX_PATH;
3748     r = MsiRecordGetString(res, 1, buf, &size);
3749     todo_wine
3750     {
3751         ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3752         ok(!lstrcmp(buf, "apple"), "Expected apple, got %s\n", buf);
3753     }
3754
3755     size = MAX_PATH;
3756     r = MsiRecordGetString(res, 2, buf, &size);
3757     todo_wine
3758     {
3759         ok(r == ERROR_SUCCESS, "Expected ERROR_SUCCESS, got %d\n", r);
3760         ok(!lstrcmp(buf, "two"), "Expected two, got %s\n", buf);
3761     }
3762
3763     r = MsiRecordGetInteger(res, 3);
3764     todo_wine
3765     {
3766         ok(r == 2, "Expected 2, got %d\n", r);
3767     }
3768
3769     MsiCloseHandle(res);
3770
3771     r = MsiViewFetch(view, &res);
3772     ok(r == ERROR_NO_MORE_ITEMS, "Expected ERROR_NO_MORE_ITEMS, got %d\n", r);
3773
3774     r = MsiViewClose(view);
3775     ok(r == ERROR_SUCCESS, "MsiViewClose failed\n");
3776     r = MsiCloseHandle(view);
3777     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3778     r = MsiCloseHandle(hdb);
3779     ok(r == ERROR_SUCCESS, "MsiCloseHandle failed\n");
3780
3781     DeleteFile(msifile);
3782 }
3783
3784 START_TEST(db)
3785 {
3786     test_msidatabase();
3787     test_msiinsert();
3788     test_msidecomposedesc();
3789     test_msibadqueries();
3790     test_viewmodify();
3791     test_viewgetcolumninfo();
3792     test_getcolinfo();
3793     test_msiexport();
3794     test_longstrings();
3795     test_streamtable();
3796     test_where();
3797     test_msiimport();
3798     test_markers();
3799     test_handle_limit();
3800     test_try_transform();
3801     test_join();
3802     test_temporary_table();
3803     test_alter();
3804     test_integers();
3805     test_update();
3806     test_special_tables();
3807     test_select_markers();
3808 }