2 * Implementation of the Microsoft Installer (msi.dll)
4 * Copyright 2004 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
21 #define WIN32_NO_STATUS
23 #define COM_NO_WINDOWS_H
28 //#include "winbase.h"
29 //#include "winerror.h"
30 #include <wine/debug.h>
31 #include <wine/unicode.h>
33 //#include "msiquery.h"
34 //#include "objbase.h"
36 //#include "msipriv.h"
41 WINE_DEFAULT_DEBUG_CHANNEL(msidb
);
44 /* below is the query interface to a table */
46 typedef struct tagMSIINSERTVIEW
56 static UINT
INSERT_fetch_int( struct tagMSIVIEW
*view
, UINT row
, UINT col
, UINT
*val
)
58 MSIINSERTVIEW
*iv
= (MSIINSERTVIEW
*)view
;
60 TRACE("%p %d %d %p\n", iv
, row
, col
, val
);
62 return ERROR_FUNCTION_FAILED
;
66 * msi_query_merge_record
68 * Merge a value_list and a record to create a second record.
69 * Replace wildcard entries in the valuelist with values from the record
71 MSIRECORD
*msi_query_merge_record( UINT fields
, const column_info
*vl
, MSIRECORD
*rec
)
74 DWORD wildcard_count
= 1, i
;
76 merged
= MSI_CreateRecord( fields
);
77 for( i
=1; i
<= fields
; i
++ )
81 TRACE("Not enough elements in the list to insert\n");
84 switch( vl
->val
->type
)
87 TRACE("field %d -> %s\n", i
, debugstr_w(vl
->val
->u
.sval
));
88 MSI_RecordSetStringW( merged
, i
, vl
->val
->u
.sval
);
91 MSI_RecordSetInteger( merged
, i
, vl
->val
->u
.ival
);
96 MSI_RecordCopyField( rec
, wildcard_count
, merged
, i
);
100 ERR("Unknown expression type %d\n", vl
->val
->type
);
107 msiobj_release( &merged
->hdr
);
111 /* checks to see if the column order specified in the INSERT query
112 * matches the column order of the table
114 static BOOL
msi_columns_in_order(MSIINSERTVIEW
*iv
, UINT col_count
)
119 for (i
= 1; i
<= col_count
; i
++)
121 iv
->sv
->ops
->get_column_info(iv
->sv
, i
, &a
, NULL
, NULL
, NULL
);
122 iv
->table
->ops
->get_column_info(iv
->table
, i
, &b
, NULL
, NULL
, NULL
);
124 if (strcmpW( a
, b
)) return FALSE
;
129 /* rearranges the data in the record to be inserted based on column order,
130 * and pads the record for any missing columns in the INSERT query
132 static UINT
msi_arrange_record(MSIINSERTVIEW
*iv
, MSIRECORD
**values
)
135 UINT col_count
, val_count
;
139 r
= iv
->table
->ops
->get_dimensions(iv
->table
, NULL
, &col_count
);
140 if (r
!= ERROR_SUCCESS
)
143 val_count
= MSI_RecordGetFieldCount(*values
);
145 /* check to see if the columns are arranged already
146 * to avoid unnecessary copying
148 if (col_count
== val_count
&& msi_columns_in_order(iv
, col_count
))
149 return ERROR_SUCCESS
;
151 padded
= MSI_CreateRecord(col_count
);
153 return ERROR_OUTOFMEMORY
;
155 for (colidx
= 1; colidx
<= val_count
; colidx
++)
157 r
= iv
->sv
->ops
->get_column_info(iv
->sv
, colidx
, &a
, NULL
, NULL
, NULL
);
158 if (r
!= ERROR_SUCCESS
)
161 for (i
= 1; i
<= col_count
; i
++)
163 r
= iv
->table
->ops
->get_column_info(iv
->table
, i
, &b
, NULL
,
165 if (r
!= ERROR_SUCCESS
)
168 if (!strcmpW( a
, b
))
170 MSI_RecordCopyField(*values
, colidx
, padded
, i
);
175 msiobj_release(&(*values
)->hdr
);
177 return ERROR_SUCCESS
;
180 msiobj_release(&padded
->hdr
);
184 static BOOL
row_has_null_primary_keys(MSIINSERTVIEW
*iv
, MSIRECORD
*row
)
186 UINT r
, i
, col_count
, type
;
188 r
= iv
->table
->ops
->get_dimensions( iv
->table
, NULL
, &col_count
);
189 if (r
!= ERROR_SUCCESS
)
192 for (i
= 1; i
<= col_count
; i
++)
194 r
= iv
->table
->ops
->get_column_info(iv
->table
, i
, NULL
, &type
,
196 if (r
!= ERROR_SUCCESS
)
199 if (!(type
& MSITYPE_KEY
))
202 if (MSI_RecordIsNull(row
, i
))
209 static UINT
INSERT_execute( struct tagMSIVIEW
*view
, MSIRECORD
*record
)
211 MSIINSERTVIEW
*iv
= (MSIINSERTVIEW
*)view
;
212 UINT r
, row
= -1, col_count
= 0;
214 MSIRECORD
*values
= NULL
;
216 TRACE("%p %p\n", iv
, record
);
220 return ERROR_FUNCTION_FAILED
;
222 r
= sv
->ops
->execute( sv
, 0 );
223 TRACE("sv execute returned %x\n", r
);
227 r
= sv
->ops
->get_dimensions( sv
, NULL
, &col_count
);
232 * Merge the wildcard values into the list of values provided
233 * in the query, and create a record containing both.
235 values
= msi_query_merge_record( col_count
, iv
->vals
, record
);
239 r
= msi_arrange_record( iv
, &values
);
240 if( r
!= ERROR_SUCCESS
)
243 /* rows with NULL primary keys are inserted at the beginning of the table */
244 if( row_has_null_primary_keys( iv
, values
) )
247 r
= iv
->table
->ops
->insert_row( iv
->table
, values
, row
, iv
->bIsTemp
);
251 msiobj_release( &values
->hdr
);
257 static UINT
INSERT_close( struct tagMSIVIEW
*view
)
259 MSIINSERTVIEW
*iv
= (MSIINSERTVIEW
*)view
;
266 return ERROR_FUNCTION_FAILED
;
268 return sv
->ops
->close( sv
);
271 static UINT
INSERT_get_dimensions( struct tagMSIVIEW
*view
, UINT
*rows
, UINT
*cols
)
273 MSIINSERTVIEW
*iv
= (MSIINSERTVIEW
*)view
;
276 TRACE("%p %p %p\n", iv
, rows
, cols
);
280 return ERROR_FUNCTION_FAILED
;
282 return sv
->ops
->get_dimensions( sv
, rows
, cols
);
285 static UINT
INSERT_get_column_info( struct tagMSIVIEW
*view
, UINT n
, LPCWSTR
*name
,
286 UINT
*type
, BOOL
*temporary
, LPCWSTR
*table_name
)
288 MSIINSERTVIEW
*iv
= (MSIINSERTVIEW
*)view
;
291 TRACE("%p %d %p %p %p %p\n", iv
, n
, name
, type
, temporary
, table_name
);
295 return ERROR_FUNCTION_FAILED
;
297 return sv
->ops
->get_column_info( sv
, n
, name
, type
, temporary
, table_name
);
300 static UINT
INSERT_modify( struct tagMSIVIEW
*view
, MSIMODIFY eModifyMode
, MSIRECORD
*rec
, UINT row
)
302 MSIINSERTVIEW
*iv
= (MSIINSERTVIEW
*)view
;
304 TRACE("%p %d %p\n", iv
, eModifyMode
, rec
);
306 return ERROR_FUNCTION_FAILED
;
309 static UINT
INSERT_delete( struct tagMSIVIEW
*view
)
311 MSIINSERTVIEW
*iv
= (MSIINSERTVIEW
*)view
;
318 sv
->ops
->delete( sv
);
319 msiobj_release( &iv
->db
->hdr
);
322 return ERROR_SUCCESS
;
325 static UINT
INSERT_find_matching_rows( struct tagMSIVIEW
*view
, UINT col
,
326 UINT val
, UINT
*row
, MSIITERHANDLE
*handle
)
328 TRACE("%p, %d, %u, %p\n", view
, col
, val
, *handle
);
330 return ERROR_FUNCTION_FAILED
;
334 static const MSIVIEWOPS insert_ops
=
344 INSERT_get_dimensions
,
345 INSERT_get_column_info
,
348 INSERT_find_matching_rows
,
357 static UINT
count_column_info( const column_info
*ci
)
360 for ( ; ci
; ci
= ci
->next
)
365 UINT
INSERT_CreateView( MSIDATABASE
*db
, MSIVIEW
**view
, LPCWSTR table
,
366 column_info
*columns
, column_info
*values
, BOOL temp
)
368 MSIINSERTVIEW
*iv
= NULL
;
370 MSIVIEW
*tv
= NULL
, *sv
= NULL
;
374 /* there should be one value for each column */
375 if ( count_column_info( columns
) != count_column_info(values
) )
376 return ERROR_BAD_QUERY_SYNTAX
;
378 r
= TABLE_CreateView( db
, table
, &tv
);
379 if( r
!= ERROR_SUCCESS
)
382 r
= SELECT_CreateView( db
, &sv
, tv
, columns
);
383 if( r
!= ERROR_SUCCESS
)
386 tv
->ops
->delete( tv
);
390 iv
= msi_alloc_zero( sizeof *iv
);
392 return ERROR_FUNCTION_FAILED
;
394 /* fill the structure */
395 iv
->view
.ops
= &insert_ops
;
396 msiobj_addref( &db
->hdr
);
402 *view
= (MSIVIEW
*) iv
;
404 return ERROR_SUCCESS
;