2 * Implementation of the Microsoft Installer (msi.dll)
4 * Copyright 2002-2005 Mike McCormack for CodeWeavers
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Lesser General Public
8 * License as published by the Free Software Foundation; either
9 * version 2.1 of the License, or (at your option) any later version.
11 * This library is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 * Lesser General Public License for more details.
16 * You should have received a copy of the GNU Lesser General Public
17 * License along with this library; if not, write to the Free Software
18 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
28 #include "wine/debug.h"
29 #include "wine/unicode.h"
39 WINE_DEFAULT_DEBUG_CHANNEL(msi
);
41 static void MSI_CloseView( MSIOBJECTHDR
*arg
)
43 MSIQUERY
*query
= (MSIQUERY
*) arg
;
46 if( query
->view
&& query
->view
->ops
->delete )
47 query
->view
->ops
->delete( query
->view
);
48 msiobj_release( &query
->db
->hdr
);
50 LIST_FOR_EACH_SAFE( ptr
, t
, &query
->mem
)
56 UINT
VIEW_find_column( MSIVIEW
*table
, LPCWSTR name
, UINT
*n
)
61 r
= table
->ops
->get_dimensions( table
, NULL
, &count
);
62 if( r
!= ERROR_SUCCESS
)
65 for( i
=1; i
<=count
; i
++ )
70 r
= table
->ops
->get_column_info( table
, i
, &col_name
, NULL
);
71 if( r
!= ERROR_SUCCESS
)
73 x
= lstrcmpW( name
, col_name
);
82 return ERROR_INVALID_PARAMETER
;
85 UINT WINAPI
MsiDatabaseOpenViewA(MSIHANDLE hdb
,
86 LPCSTR szQuery
, MSIHANDLE
*phView
)
91 TRACE("%ld %s %p\n", hdb
, debugstr_a(szQuery
), phView
);
95 szwQuery
= strdupAtoW( szQuery
);
97 return ERROR_FUNCTION_FAILED
;
102 r
= MsiDatabaseOpenViewW( hdb
, szwQuery
, phView
);
104 msi_free( szwQuery
);
108 UINT
MSI_DatabaseOpenViewW(MSIDATABASE
*db
,
109 LPCWSTR szQuery
, MSIQUERY
**pView
)
114 TRACE("%s %p\n", debugstr_w(szQuery
), pView
);
117 return ERROR_INVALID_PARAMETER
;
119 /* pre allocate a handle to hold a pointer to the view */
120 query
= alloc_msiobject( MSIHANDLETYPE_VIEW
, sizeof (MSIQUERY
),
123 return ERROR_FUNCTION_FAILED
;
125 msiobj_addref( &db
->hdr
);
129 list_init( &query
->mem
);
131 r
= MSI_ParseSQL( db
, szQuery
, &query
->view
, &query
->mem
);
132 if( r
== ERROR_SUCCESS
)
134 msiobj_addref( &query
->hdr
);
138 msiobj_release( &query
->hdr
);
142 UINT
MSI_OpenQuery( MSIDATABASE
*db
, MSIQUERY
**view
, LPCWSTR fmt
, ... )
148 /* construct the string */
152 query
= msi_alloc( size
*sizeof(WCHAR
) );
154 res
= vsnprintfW(query
, size
, fmt
, va
);
156 if (res
== -1) size
*= 2;
157 else if (res
>= size
) size
= res
+ 1;
161 /* perform the query */
162 r
= MSI_DatabaseOpenViewW(db
, query
, view
);
167 UINT
MSI_IterateRecords( MSIQUERY
*view
, DWORD
*count
,
168 record_func func
, LPVOID param
)
170 MSIRECORD
*rec
= NULL
;
171 UINT r
, n
= 0, max
= 0;
173 r
= MSI_ViewExecute( view
, NULL
);
174 if( r
!= ERROR_SUCCESS
)
180 /* iterate a query */
181 for( n
= 0; (max
== 0) || (n
< max
); n
++ )
183 r
= MSI_ViewFetch( view
, &rec
);
184 if( r
!= ERROR_SUCCESS
)
186 r
= func( rec
, param
);
187 msiobj_release( &rec
->hdr
);
188 if( r
!= ERROR_SUCCESS
)
192 MSI_ViewClose( view
);
197 if( r
== ERROR_NO_MORE_ITEMS
)
203 /* return a single record from a query */
204 MSIRECORD
*MSI_QueryGetRecord( MSIDATABASE
*db
, LPCWSTR fmt
, ... )
206 MSIRECORD
*rec
= NULL
;
207 MSIQUERY
*view
= NULL
;
212 /* construct the string */
216 query
= msi_alloc( size
*sizeof(WCHAR
) );
218 res
= vsnprintfW(query
, size
, fmt
, va
);
220 if (res
== -1) size
*= 2;
221 else if (res
>= size
) size
= res
+ 1;
225 /* perform the query */
226 r
= MSI_DatabaseOpenViewW(db
, query
, &view
);
229 if( r
== ERROR_SUCCESS
)
231 MSI_ViewExecute( view
, NULL
);
232 MSI_ViewFetch( view
, &rec
);
233 MSI_ViewClose( view
);
234 msiobj_release( &view
->hdr
);
239 UINT WINAPI
MsiDatabaseOpenViewW(MSIHANDLE hdb
,
240 LPCWSTR szQuery
, MSIHANDLE
*phView
)
243 MSIQUERY
*query
= NULL
;
246 TRACE("%s %p\n", debugstr_w(szQuery
), phView
);
248 db
= msihandle2msiinfo( hdb
, MSIHANDLETYPE_DATABASE
);
250 return ERROR_INVALID_HANDLE
;
252 ret
= MSI_DatabaseOpenViewW( db
, szQuery
, &query
);
253 if( ret
== ERROR_SUCCESS
)
255 *phView
= alloc_msihandle( &query
->hdr
);
256 msiobj_release( &query
->hdr
);
258 msiobj_release( &db
->hdr
);
263 UINT
MSI_ViewFetch(MSIQUERY
*query
, MSIRECORD
**prec
)
267 UINT row_count
= 0, col_count
= 0, i
, ival
, ret
, type
;
269 TRACE("%p %p\n", query
, prec
);
273 return ERROR_FUNCTION_FAILED
;
275 ret
= view
->ops
->get_dimensions( view
, &row_count
, &col_count
);
279 return ERROR_INVALID_PARAMETER
;
281 if( query
->row
>= row_count
)
282 return ERROR_NO_MORE_ITEMS
;
284 rec
= MSI_CreateRecord( col_count
);
286 return ERROR_FUNCTION_FAILED
;
288 for( i
=1; i
<=col_count
; i
++ )
290 ret
= view
->ops
->get_column_info( view
, i
, NULL
, &type
);
293 ERR("Error getting column type for %d\n", i
);
296 if (( type
!= MSITYPE_BINARY
) && (type
!= (MSITYPE_BINARY
|
299 ret
= view
->ops
->fetch_int( view
, query
->row
, i
, &ival
);
302 ERR("Error fetching data for %d\n", i
);
305 if( ! (type
& MSITYPE_VALID
) )
306 ERR("Invalid type!\n");
308 /* check if it's nul (0) - if so, don't set anything */
312 if( type
& MSITYPE_STRING
)
316 sval
= MSI_makestring( query
->db
, ival
);
317 MSI_RecordSetStringW( rec
, i
, sval
);
322 if( (type
& MSI_DATASIZEMASK
) == 2 )
323 MSI_RecordSetInteger( rec
, i
, ival
- (1<<15) );
325 MSI_RecordSetInteger( rec
, i
, ival
- (1<<31) );
332 ret
= view
->ops
->fetch_stream( view
, query
->row
, i
, &stm
);
333 if( ( ret
== ERROR_SUCCESS
) && stm
)
335 MSI_RecordSetIStream( rec
, i
, stm
);
336 IStream_Release( stm
);
339 ERR("failed to get stream\n");
346 return ERROR_SUCCESS
;
349 UINT WINAPI
MsiViewFetch(MSIHANDLE hView
, MSIHANDLE
*record
)
352 MSIRECORD
*rec
= NULL
;
355 TRACE("%ld %p\n", hView
, record
);
357 query
= msihandle2msiinfo( hView
, MSIHANDLETYPE_VIEW
);
359 return ERROR_INVALID_HANDLE
;
360 ret
= MSI_ViewFetch( query
, &rec
);
361 if( ret
== ERROR_SUCCESS
)
363 *record
= alloc_msihandle( &rec
->hdr
);
364 msiobj_release( &rec
->hdr
);
366 msiobj_release( &query
->hdr
);
370 UINT
MSI_ViewClose(MSIQUERY
*query
)
374 TRACE("%p\n", query
);
378 return ERROR_FUNCTION_FAILED
;
379 if( !view
->ops
->close
)
380 return ERROR_FUNCTION_FAILED
;
382 return view
->ops
->close( view
);
385 UINT WINAPI
MsiViewClose(MSIHANDLE hView
)
390 TRACE("%ld\n", hView
);
392 query
= msihandle2msiinfo( hView
, MSIHANDLETYPE_VIEW
);
394 return ERROR_INVALID_HANDLE
;
396 ret
= MSI_ViewClose( query
);
397 msiobj_release( &query
->hdr
);
401 UINT
MSI_ViewExecute(MSIQUERY
*query
, MSIRECORD
*rec
)
405 TRACE("%p %p\n", query
, rec
);
409 return ERROR_FUNCTION_FAILED
;
410 if( !view
->ops
->execute
)
411 return ERROR_FUNCTION_FAILED
;
414 return view
->ops
->execute( view
, rec
);
417 UINT WINAPI
MsiViewExecute(MSIHANDLE hView
, MSIHANDLE hRec
)
420 MSIRECORD
*rec
= NULL
;
423 TRACE("%ld %ld\n", hView
, hRec
);
425 query
= msihandle2msiinfo( hView
, MSIHANDLETYPE_VIEW
);
427 return ERROR_INVALID_HANDLE
;
431 rec
= msihandle2msiinfo( hRec
, MSIHANDLETYPE_RECORD
);
434 ret
= ERROR_INVALID_HANDLE
;
439 msiobj_lock( &rec
->hdr
);
440 ret
= MSI_ViewExecute( query
, rec
);
441 msiobj_unlock( &rec
->hdr
);
444 msiobj_release( &query
->hdr
);
446 msiobj_release( &rec
->hdr
);
451 UINT WINAPI
MsiViewGetColumnInfo(MSIHANDLE hView
, MSICOLINFO info
, MSIHANDLE
*hRec
)
453 MSIVIEW
*view
= NULL
;
454 MSIQUERY
*query
= NULL
;
455 MSIRECORD
*rec
= NULL
;
456 UINT r
= ERROR_FUNCTION_FAILED
, i
, count
= 0, type
;
459 TRACE("%ld %d %p\n", hView
, info
, hRec
);
461 query
= msihandle2msiinfo( hView
, MSIHANDLETYPE_VIEW
);
463 return ERROR_INVALID_HANDLE
;
469 if( !view
->ops
->get_dimensions
)
472 r
= view
->ops
->get_dimensions( view
, NULL
, &count
);
477 r
= ERROR_INVALID_PARAMETER
;
481 rec
= MSI_CreateRecord( count
);
484 r
= ERROR_FUNCTION_FAILED
;
488 for( i
=0; i
<count
; i
++ )
491 r
= view
->ops
->get_column_info( view
, i
+1, &name
, &type
);
492 if( r
!= ERROR_SUCCESS
)
494 MSI_RecordSetStringW( rec
, i
+1, name
);
498 *hRec
= alloc_msihandle( &rec
->hdr
);
501 msiobj_release( &query
->hdr
);
503 msiobj_release( &rec
->hdr
);
508 UINT WINAPI
MsiViewModify( MSIHANDLE hView
, MSIMODIFY eModifyMode
,
511 MSIVIEW
*view
= NULL
;
512 MSIQUERY
*query
= NULL
;
513 MSIRECORD
*rec
= NULL
;
514 UINT r
= ERROR_FUNCTION_FAILED
;
516 TRACE("%ld %x %ld\n", hView
, eModifyMode
, hRecord
);
518 query
= msihandle2msiinfo( hView
, MSIHANDLETYPE_VIEW
);
520 return ERROR_INVALID_HANDLE
;
526 if( !view
->ops
->modify
)
529 rec
= msihandle2msiinfo( hRecord
, MSIHANDLETYPE_RECORD
);
532 r
= ERROR_INVALID_HANDLE
;
536 r
= view
->ops
->modify( view
, eModifyMode
, rec
);
539 msiobj_release( &query
->hdr
);
541 msiobj_release( &rec
->hdr
);
546 MSIDBERROR WINAPI
MsiViewGetErrorW( MSIHANDLE handle
, LPWSTR szColumnNameBuffer
,
549 MSIQUERY
*query
= NULL
;
550 static const WCHAR szError
[] = { 0 };
551 MSIDBERROR r
= MSIDBERROR_NOERROR
;
554 FIXME("%ld %p %p - returns empty error string\n",
555 handle
, szColumnNameBuffer
, pcchBuf
);
558 return MSIDBERROR_INVALIDARG
;
560 query
= msihandle2msiinfo( handle
, MSIHANDLETYPE_VIEW
);
562 return MSIDBERROR_INVALIDARG
;
564 len
= lstrlenW( szError
);
565 if( szColumnNameBuffer
)
568 lstrcpyW( szColumnNameBuffer
, szError
);
570 r
= MSIDBERROR_MOREDATA
;
574 msiobj_release( &query
->hdr
);
578 MSIDBERROR WINAPI
MsiViewGetErrorA( MSIHANDLE handle
, LPSTR szColumnNameBuffer
,
581 static const CHAR szError
[] = { 0 };
582 MSIQUERY
*query
= NULL
;
583 MSIDBERROR r
= MSIDBERROR_NOERROR
;
586 FIXME("%ld %p %p - returns empty error string\n",
587 handle
, szColumnNameBuffer
, pcchBuf
);
590 return MSIDBERROR_INVALIDARG
;
592 query
= msihandle2msiinfo( handle
, MSIHANDLETYPE_VIEW
);
594 return MSIDBERROR_INVALIDARG
;
596 len
= lstrlenA( szError
);
597 if( szColumnNameBuffer
)
600 lstrcpyA( szColumnNameBuffer
, szError
);
602 r
= MSIDBERROR_MOREDATA
;
606 msiobj_release( &query
->hdr
);
610 UINT WINAPI
MsiDatabaseApplyTransformA( MSIHANDLE hdb
,
611 LPCSTR szTransformFile
, int iErrorCond
)
613 FIXME("%ld %s %d\n", hdb
, debugstr_a(szTransformFile
), iErrorCond
);
614 return ERROR_CALL_NOT_IMPLEMENTED
;
617 UINT WINAPI
MsiDatabaseApplyTransformW( MSIHANDLE hdb
,
618 LPCWSTR szTransformFile
, int iErrorCond
)
620 FIXME("%ld %s %d\n", hdb
, debugstr_w(szTransformFile
), iErrorCond
);
621 return ERROR_CALL_NOT_IMPLEMENTED
;
624 UINT WINAPI
MsiDatabaseGenerateTransformA( MSIHANDLE hdb
, MSIHANDLE hdbref
,
625 LPCSTR szTransformFile
, int iReserved1
, int iReserved2
)
627 FIXME("%ld %ld %s %d %d\n", hdb
, hdbref
,
628 debugstr_a(szTransformFile
), iReserved1
, iReserved2
);
629 return ERROR_CALL_NOT_IMPLEMENTED
;
632 UINT WINAPI
MsiDatabaseGenerateTransformW( MSIHANDLE hdb
, MSIHANDLE hdbref
,
633 LPCWSTR szTransformFile
, int iReserved1
, int iReserved2
)
635 FIXME("%ld %ld %s %d %d\n", hdb
, hdbref
,
636 debugstr_w(szTransformFile
), iReserved1
, iReserved2
);
637 return ERROR_CALL_NOT_IMPLEMENTED
;
640 UINT WINAPI
MsiDatabaseCommit( MSIHANDLE hdb
)
647 db
= msihandle2msiinfo( hdb
, MSIHANDLETYPE_DATABASE
);
649 return ERROR_INVALID_HANDLE
;
651 /* FIXME: lock the database */
653 r
= MSI_CommitTables( db
);
655 /* FIXME: unlock the database */
657 msiobj_release( &db
->hdr
);
662 struct msi_primary_key_record_info
668 static UINT
msi_primary_key_iterator( MSIRECORD
*rec
, LPVOID param
)
670 struct msi_primary_key_record_info
*info
= param
;
674 type
= MSI_RecordGetInteger( rec
, 4 );
675 if( type
& MSITYPE_KEY
)
680 name
= MSI_RecordGetString( rec
, 3 );
681 MSI_RecordSetStringW( info
->rec
, info
->n
, name
);
685 return ERROR_SUCCESS
;
688 UINT
MSI_DatabaseGetPrimaryKeys( MSIDATABASE
*db
,
689 LPCWSTR table
, MSIRECORD
**prec
)
691 static const WCHAR sql
[] = {
692 's','e','l','e','c','t',' ','*',' ',
693 'f','r','o','m',' ','`','_','C','o','l','u','m','n','s','`',' ',
694 'w','h','e','r','e',' ',
695 '`','T','a','b','l','e','`',' ','=',' ','\'','%','s','\'',0 };
696 struct msi_primary_key_record_info info
;
697 MSIQUERY
*query
= NULL
;
701 r
= MSI_OpenQuery( db
, &query
, sql
, table
);
702 if( r
!= ERROR_SUCCESS
)
707 /* count the number of primary key records */
710 r
= MSI_IterateRecords( query
, 0, msi_primary_key_iterator
, &info
);
711 if( r
== ERROR_SUCCESS
)
713 TRACE("Found %ld primary keys\n", info
.n
);
715 /* allocate a record and fill in the names of the tables */
716 info
.rec
= MSI_CreateRecord( info
.n
);
718 r
= MSI_IterateRecords( query
, 0, msi_primary_key_iterator
, &info
);
719 if( r
== ERROR_SUCCESS
)
722 msiobj_release( &info
.rec
->hdr
);
724 msiobj_release( &query
->hdr
);
729 UINT WINAPI
MsiDatabaseGetPrimaryKeysW( MSIHANDLE hdb
,
730 LPCWSTR table
, MSIHANDLE
* phRec
)
732 MSIRECORD
*rec
= NULL
;
736 TRACE("%ld %s %p\n", hdb
, debugstr_w(table
), phRec
);
738 db
= msihandle2msiinfo( hdb
, MSIHANDLETYPE_DATABASE
);
740 return ERROR_INVALID_HANDLE
;
742 r
= MSI_DatabaseGetPrimaryKeys( db
, table
, &rec
);
743 if( r
== ERROR_SUCCESS
)
745 *phRec
= alloc_msihandle( &rec
->hdr
);
746 msiobj_release( &rec
->hdr
);
748 msiobj_release( &db
->hdr
);
753 UINT WINAPI
MsiDatabaseGetPrimaryKeysA(MSIHANDLE hdb
,
754 LPCSTR table
, MSIHANDLE
* phRec
)
756 LPWSTR szwTable
= NULL
;
759 TRACE("%ld %s %p\n", hdb
, debugstr_a(table
), phRec
);
763 szwTable
= strdupAtoW( table
);
765 return ERROR_OUTOFMEMORY
;
767 r
= MsiDatabaseGetPrimaryKeysW( hdb
, szwTable
, phRec
);
768 msi_free( szwTable
);
773 UINT WINAPI
MsiDatabaseIsTablePersistentA(
774 MSIHANDLE hDatabase
, LPSTR szTableName
)
776 FIXME("%lx %s\n", hDatabase
, debugstr_a(szTableName
));
777 return ERROR_CALL_NOT_IMPLEMENTED
;
780 UINT WINAPI
MsiDatabaseIsTablePersistentW(
781 MSIHANDLE hDatabase
, LPWSTR szTableName
)
783 FIXME("%lx %s\n", hDatabase
, debugstr_w(szTableName
));
784 return ERROR_CALL_NOT_IMPLEMENTED
;