msiquery.c File Reference

#include <stdarg.h>
#include "windef.h"
#include "winbase.h"
#include "winerror.h"
#include "wine/debug.h"
#include "wine/exception.h"
#include "msi.h"
#include "msiquery.h"
#include "objbase.h"
#include "objidl.h"
#include "winnls.h"
#include "msipriv.h"
#include "query.h"
#include "winemsi.h"
#include "initguid.h"

Include dependency graph for msiquery.c:

Go to the source code of this file.

Classes
struct	primary_key_record_info

Macros
#define	COBJMACROS

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (msi)
static void	MSI_CloseView (MSIOBJECTHDR *arg)
UINT	VIEW_find_column (MSIVIEW *table, LPCWSTR name, LPCWSTR table_name, UINT *n)
UINT WINAPI	MsiDatabaseOpenViewA (MSIHANDLE hdb, const char *szQuery, MSIHANDLE *phView)
UINT	MSI_DatabaseOpenViewW (MSIDATABASE *db, const WCHAR *szQuery, MSIQUERY **pView)
UINT WINAPIV	MSI_OpenQuery (MSIDATABASE *db, MSIQUERY **view, LPCWSTR fmt,...)
UINT	MSI_IterateRecords (MSIQUERY *view, LPDWORD count, record_func func, LPVOID param)
MSIRECORD *WINAPIV	MSI_QueryGetRecord (MSIDATABASE *db, LPCWSTR fmt,...)
UINT WINAPI	MsiDatabaseOpenViewW (MSIHANDLE hdb, LPCWSTR szQuery, MSIHANDLE *phView)
UINT	msi_view_refresh_row (MSIDATABASE *db, MSIVIEW *view, UINT row, MSIRECORD *rec)
UINT	msi_view_get_row (MSIDATABASE *db, MSIVIEW *view, UINT row, MSIRECORD **rec)
UINT	MSI_ViewFetch (MSIQUERY *query, MSIRECORD **prec)
UINT WINAPI	MsiViewFetch (MSIHANDLE hView, MSIHANDLE *record)
UINT	MSI_ViewClose (MSIQUERY *query)
UINT WINAPI	MsiViewClose (MSIHANDLE hView)
UINT	MSI_ViewExecute (MSIQUERY *query, MSIRECORD *rec)
UINT WINAPI	MsiViewExecute (MSIHANDLE hView, MSIHANDLE hRec)
static UINT	set_record_type_string (MSIRECORD *rec, UINT field, UINT type, BOOL temporary)
UINT	MSI_ViewGetColumnInfo (MSIQUERY *query, MSICOLINFO info, MSIRECORD **prec)
UINT WINAPI	MsiViewGetColumnInfo (MSIHANDLE hView, MSICOLINFO info, MSIHANDLE *hRec)
UINT	MSI_ViewModify (MSIQUERY *query, MSIMODIFY mode, MSIRECORD *rec)
UINT WINAPI	MsiViewModify (MSIHANDLE hView, MSIMODIFY eModifyMode, MSIHANDLE hRecord)
MSIDBERROR WINAPI	MsiViewGetErrorW (MSIHANDLE handle, WCHAR *buffer, DWORD *buflen)
MSIDBERROR WINAPI	MsiViewGetErrorA (MSIHANDLE handle, char *buffer, DWORD *buflen)
MSIHANDLE WINAPI	MsiGetLastErrorRecord (void)
UINT	MSI_DatabaseApplyTransformW (MSIDATABASE *db, const WCHAR *transform, int error_cond)
UINT WINAPI	MsiDatabaseApplyTransformW (MSIHANDLE hdb, const WCHAR *transform, int error_cond)
UINT WINAPI	MsiDatabaseApplyTransformA (MSIHANDLE hdb, const char *transform, int error_cond)
UINT WINAPI	MsiDatabaseGenerateTransformA (MSIHANDLE hdb, MSIHANDLE hdbref, const char *szTransformFile, int iReserved1, int iReserved2)
UINT WINAPI	MsiDatabaseGenerateTransformW (MSIHANDLE hdb, MSIHANDLE hdbref, const WCHAR *szTransformFile, int iReserved1, int iReserved2)
UINT WINAPI	MsiDatabaseCommit (MSIHANDLE hdb)
static UINT	primary_key_iterator (MSIRECORD *rec, void *param)
UINT	MSI_DatabaseGetPrimaryKeys (MSIDATABASE *db, const WCHAR *table, MSIRECORD **prec)
UINT WINAPI	MsiDatabaseGetPrimaryKeysW (MSIHANDLE hdb, const WCHAR *table, MSIHANDLE *phRec)
UINT WINAPI	MsiDatabaseGetPrimaryKeysA (MSIHANDLE hdb, const char *table, MSIHANDLE *phRec)
MSICONDITION WINAPI	MsiDatabaseIsTablePersistentA (MSIHANDLE hDatabase, const char *szTableName)
MSICONDITION WINAPI	MsiDatabaseIsTablePersistentW (MSIHANDLE hDatabase, const WCHAR *szTableName)
UINT __cdecl	s_remote_ViewClose (MSIHANDLE view)
UINT __cdecl	s_remote_ViewExecute (MSIHANDLE view, struct wire_record *remote_rec)
UINT __cdecl	s_remote_ViewFetch (MSIHANDLE view, struct wire_record **rec)
UINT __cdecl	s_remote_ViewGetColumnInfo (MSIHANDLE view, MSICOLINFO info, struct wire_record **rec)
MSIDBERROR __cdecl	s_remote_ViewGetError (MSIHANDLE view, LPWSTR *column)
UINT __cdecl	s_remote_ViewModify (MSIHANDLE view, MSIMODIFY mode, struct wire_record *remote_rec, struct wire_record **remote_refreshed)

Macro Definition Documentation

COBJMACROS

#define COBJMACROS

Definition at line 23 of file msiquery.c.

Function Documentation

MSI_CloseView()

static void MSI_CloseView ( MSIOBJECTHDR *  arg )

static

Definition at line 44 of file msiquery.c.

{
    MSIQUERY *query = (MSIQUERY*) arg;
    struct list *ptr, *t;
 
    if( query->view && query->view->ops->delete )
        query->view->ops->delete( query->view );
    msiobj_release( &query->db->hdr );
 
    LIST_FOR_EACH_SAFE( ptr, t, &query->mem )
    {
        free( ptr );
    }
}

Referenced by MSI_DatabaseOpenViewW().

MSI_DatabaseApplyTransformW()

UINT MSI_DatabaseApplyTransformW	(	MSIDATABASE *	db,
		const WCHAR *	transform,
		int	error_cond
	)

Definition at line 873 of file msiquery.c.

{
    HRESULT hr;
    UINT ret = ERROR_FUNCTION_FAILED;
    IStorage *stg;
    STATSTG stat;
 
    TRACE( "%p %s %08x\n", db, debugstr_w(transform), error_cond );
 
    if (*transform == ':')
    {
        hr = IStorage_OpenStorage( db->storage, transform + 1, NULL, STGM_SHARE_EXCLUSIVE, NULL, 0, &stg );
        if (FAILED( hr ))
        {
            WARN( "failed to open substorage transform %#lx\n", hr );
            return ERROR_FUNCTION_FAILED;
        }
    }
    else
    {
        hr = StgOpenStorage( transform, NULL, STGM_DIRECT|STGM_READ|STGM_SHARE_DENY_WRITE, NULL, 0, &stg );
        if (FAILED( hr ))
        {
            WARN( "failed to open file transform %#lx\n", hr );
            return ERROR_FUNCTION_FAILED;
        }
    }
 
    hr = IStorage_Stat( stg, &stat, STATFLAG_NONAME );
    if (FAILED( hr )) goto end;
    if (!IsEqualGUID( &stat.clsid, &CLSID_MsiTransform )) goto end;
    if (TRACE_ON( msi )) enum_stream_names( stg );
 
    ret = msi_table_apply_transform( db, stg, error_cond );
 
end:
    IStorage_Release( stg );
    return ret;
}

Referenced by MsiDatabaseApplyTransformW().

MSI_DatabaseGetPrimaryKeys()

UINT MSI_DatabaseGetPrimaryKeys	(	MSIDATABASE *	db,
		const WCHAR *	table,
		MSIRECORD **	prec
	)

Definition at line 1039 of file msiquery.c.

{
    struct primary_key_record_info info;
    MSIQUERY *query = NULL;
    UINT r;
 
    if (!TABLE_Exists( db, table ))
        return ERROR_INVALID_TABLE;
 
    r = MSI_OpenQuery( db, &query, L"SELECT * FROM `_Columns` WHERE `Table` = '%s'", table );
    if( r != ERROR_SUCCESS )
        return r;
 
    /* count the number of primary key records */
    info.n = 0;
    info.rec = 0;
    r = MSI_IterateRecords( query, 0, primary_key_iterator, &info );
    if( r == ERROR_SUCCESS )
    {
        TRACE( "found %lu primary keys\n", info.n );
 
        /* allocate a record and fill in the names of the tables */
        info.rec = MSI_CreateRecord( info.n );
        info.n = 0;
        r = MSI_IterateRecords( query, 0, primary_key_iterator, &info );
        if( r == ERROR_SUCCESS )
            *prec = info.rec;
        else
            msiobj_release( &info.rec->hdr );
    }
    msiobj_release( &query->hdr );
 
    return r;
}

Referenced by MsiDatabaseGetPrimaryKeysW().

MSI_DatabaseOpenViewW()

UINT MSI_DatabaseOpenViewW	(	MSIDATABASE *	db,
		const WCHAR *	szQuery,
		MSIQUERY **	pView
	)

Definition at line 110 of file msiquery.c.

{
    MSIQUERY *query;
    UINT r;
 
    TRACE( "%s, %p\n", debugstr_w(szQuery), pView );
 
    /* pre allocate a handle to hold a pointer to the view */
    query = alloc_msiobject( MSIHANDLETYPE_VIEW, sizeof (MSIQUERY),
                              MSI_CloseView );
    if( !query )
        return ERROR_FUNCTION_FAILED;
 
    msiobj_addref( &db->hdr );
    query->db = db;
    list_init( &query->mem );
 
    r = MSI_ParseSQL( db, szQuery, &query->view, &query->mem );
    if( r == ERROR_SUCCESS )
    {
        msiobj_addref( &query->hdr );
        *pView = query;
    }
 
    msiobj_release( &query->hdr );
    return r;
}

Referenced by MSI_OpenQuery(), MSI_QueryGetRecord(), and MsiDatabaseOpenViewW().

MSI_IterateRecords()

UINT MSI_IterateRecords	(	MSIQUERY *	view,
		LPDWORD	count,
		record_func	func,
		LPVOID	param
	)

Definition at line 163 of file msiquery.c.

{
    MSIRECORD *rec = NULL;
    UINT r, n = 0, max = 0;
 
    r = MSI_ViewExecute( view, NULL );
    if( r != ERROR_SUCCESS )
        return r;
 
    if( count )
        max = *count;
 
    /* iterate a query */
    for( n = 0; (max == 0) || (n < max); n++ )
    {
        r = MSI_ViewFetch( view, &rec );
        if( r != ERROR_SUCCESS )
            break;
        if (func)
            r = func( rec, param );
        msiobj_release( &rec->hdr );
        if( r != ERROR_SUCCESS )
            break;
    }
 
    MSI_ViewClose( view );
 
    if( count )
        *count = n;
 
    if( r == ERROR_NO_MORE_ITEMS )
        r = ERROR_SUCCESS;
 
    return r;
}

Referenced by ACTION_AppSearch(), ACTION_BindImage(), ACTION_CCPSearch(), ACTION_CostFinalize(), ACTION_CreateFolders(), ACTION_CreateShortcuts(), ACTION_DeleteServices(), ACTION_DuplicateFiles(), ACTION_ExecuteAction(), ACTION_FindRelatedProducts(), ACTION_InstallODBC(), ACTION_InstallServices(), ACTION_InstallValidate(), ACTION_LaunchConditions(), ACTION_MigrateFeatureStates(), ACTION_MoveFiles(), ACTION_ProcessExecSequence(), ACTION_ProcessUISequence(), ACTION_PublishComponents(), ACTION_RegisterFonts(), ACTION_RegisterTypeLibraries(), ACTION_RemoveDuplicateFiles(), ACTION_RemoveEnvironmentStrings(), ACTION_RemoveExistingProducts(), ACTION_RemoveFiles(), ACTION_RemoveFolders(), ACTION_RemoveIniValues(), ACTION_RemoveODBC(), ACTION_RemoveRegistryValues(), ACTION_RemoveShortcuts(), ACTION_SelfRegModules(), ACTION_SelfUnregModules(), ACTION_SetODBCFolders(), ACTION_StartServices(), ACTION_StopServices(), ACTION_UnpublishComponents(), ACTION_UnregisterFonts(), ACTION_UnregisterTypeLibraries(), ACTION_WriteEnvironmentStrings(), ACTION_WriteIniValues(), ACTION_WriteRegistryValues(), combobox_add_items(), dialog_build_font_list(), dialog_button_handler(), dialog_evaluate_control_conditions(), dialog_fill_controls(), dialog_map_events(), dialog_radiogroup_control(), gather_merge_data(), get_assembly_display_name(), listbox_add_items(), listview_add_items(), load_all_classes(), load_all_drlocators(), load_all_extensions(), load_all_files(), load_all_folders(), load_all_media(), load_all_mimes(), load_all_patches(), load_all_progids(), load_all_verbs(), load_feature(), mark_patched_components(), merge_diff_tables(), MSI_DatabaseExport(), MSI_DatabaseGetPrimaryKeys(), msi_load_all_components(), msi_load_all_features(), MSI_Sequence(), publish_icons(), ui_sequence_exists(), unimplemented_action_stub(), and unpublish_icons().

MSI_OpenQuery()

UINT WINAPIV MSI_OpenQuery	(	MSIDATABASE *	db,
		MSIQUERY **	view,
		LPCWSTR	fmt,
			...
	)

Definition at line 138 of file msiquery.c.

{
    UINT r;
    int size = 100, res;
    LPWSTR query;
 
    /* construct the string */
    for (;;)
    {
        va_list va;
        query = malloc(size * sizeof(WCHAR));
        va_start(va, fmt);
        res = vswprintf(query, size, fmt, va);
        va_end(va);
        if (res == -1) size *= 2;
        else if (res >= size) size = res + 1;
        else break;
        free(query);
    }
    /* perform the query */
    r = MSI_DatabaseOpenViewW(db, query, view);
    free(query);
    return r;
}

Referenced by ACTION_AppSearch(), ACTION_CCPSearch(), ACTION_ExecuteAction(), ACTION_ProcessExecSequence(), add_records_to_table(), combobox_add_items(), dialog_build_font_list(), dialog_button_handler(), dialog_evaluate_control_conditions(), dialog_fill_controls(), dialog_map_events(), dialog_radiogroup_control(), get_assembly_display_name(), get_assembly_record(), get_merge_table(), listbox_add_items(), listview_add_items(), load_feature(), load_file_hash(), load_folder_persistence(), mark_patched_components(), merge_diff_tables(), MSI_DatabaseExport(), MSI_DatabaseGetPrimaryKeys(), MSI_Sequence(), MsiGetProductPropertyW(), unimplemented_action_stub(), and update_merge_errors().

MSI_QueryGetRecord()

MSIRECORD *WINAPIV MSI_QueryGetRecord	(	MSIDATABASE *	db,
		LPCWSTR	fmt,
			...
	)

Definition at line 201 of file msiquery.c.

{
    MSIRECORD *rec = NULL;
    MSIQUERY *view = NULL;
    UINT r;
    int size = 100, res;
    LPWSTR query;
 
    /* construct the string */
    for (;;)
    {
        va_list va;
        query = malloc(size * sizeof(WCHAR));
        va_start(va, fmt);
        res = vswprintf(query, size, fmt, va);
        va_end(va);
        if (res == -1) size *= 2;
        else if (res >= size) size = res + 1;
        else break;
        free(query);
    }
    /* perform the query */
    r = MSI_DatabaseOpenViewW(db, query, &view);
    free(query);
 
    if( r == ERROR_SUCCESS )
    {
        MSI_ViewExecute( view, NULL );
        MSI_ViewFetch( view, &rec );
        MSI_ViewClose( view );
        msiobj_release( &view->hdr );
    }
    return rec;
}

Referenced by ACTION_CustomAction(), ACTION_PerformEndAction(), ACTION_ProcessComponents(), create_temp_binary(), dialog_get_uitext(), dialog_seltree_handler(), get_checkbox_value(), get_dialog_record(), get_signature(), HANDLE_CustomType19(), HANDLE_CustomType5_6(), ITERATE_InstallService(), load_file_disk_id(), load_given_appid(), load_given_class(), load_given_extension(), load_given_mime(), load_given_progid(), load_image(), load_patch_disk_id(), load_picture(), media_get_disk_info(), msi_get_error_message(), msi_load_media_info(), resolve_keypath(), search_components(), search_ini(), search_reg(), and ui_actionstart().

msi_view_get_row()

UINT msi_view_get_row	(	MSIDATABASE *	db,
		MSIVIEW *	view,
		UINT	row,
		MSIRECORD **	rec
	)

Definition at line 351 of file msiquery.c.

{
    UINT row_count = 0, col_count = 0, r;
    MSIRECORD *object;
 
    if ((r = view->ops->get_dimensions(view, &row_count, &col_count)))
        return r;
 
    if (row >= row_count)
        return ERROR_NO_MORE_ITEMS;
 
    if (!(object = MSI_CreateRecord( col_count )))
        return ERROR_OUTOFMEMORY;
 
    if ((r = msi_view_refresh_row(db, view, row, object)))
        msiobj_release( &object->hdr );
    else
        *rec = object;
 
    return r;
}

Referenced by join_modify_update(), MSI_ViewFetch(), TABLE_get_row(), TransformView_delete_row(), and TransformView_set_row().

msi_view_refresh_row()

UINT msi_view_refresh_row	(	MSIDATABASE *	db,
		MSIVIEW *	view,
		UINT	row,
		MSIRECORD *	rec
	)

Definition at line 287 of file msiquery.c.

{
    UINT row_count = 0, col_count = 0, i, ival, ret, type;
 
    ret = view->ops->get_dimensions(view, &row_count, &col_count);
    if (ret)
        return ret;
 
    if (!col_count)
        return ERROR_INVALID_PARAMETER;
 
    for (i = 1; i <= col_count; i++)
    {
        ret = view->ops->get_column_info(view, i, NULL, &type, NULL, NULL);
        if (ret)
        {
            ERR("Error getting column type for %d\n", i);
            continue;
        }
 
        if (MSITYPE_IS_BINARY(type))
        {
            IStream *stm = NULL;
 
            ret = view->ops->fetch_stream(view, row, i, &stm);
            if ((ret == ERROR_SUCCESS) && stm)
            {
                MSI_RecordSetIStream(rec, i, stm);
                IStream_Release(stm);
            }
            else
                WARN("failed to get stream\n");
 
            continue;
        }
 
        ret = view->ops->fetch_int(view, row, i, &ival);
        if (ret)
        {
            ERR("Error fetching data for %d\n", i);
            continue;
        }
 
        if (! (type & MSITYPE_VALID))
            ERR("Invalid type!\n");
 
        if (type & MSITYPE_STRING)
        {
            int len;
            const WCHAR *sval = msi_string_lookup(db->strings, ival, &len);
            msi_record_set_string(rec, i, sval, len);
        }
        else
        {
            if ((type & MSI_DATASIZEMASK) == 2)
                MSI_RecordSetInteger(rec, i, ival ? ival - (1<<15) : MSI_NULL_INTEGER);
            else
                MSI_RecordSetInteger(rec, i, ival - (1u<<31));
        }
    }
 
    return ERROR_SUCCESS;
}

Referenced by msi_view_get_row(), and SELECT_modify().

MSI_ViewClose()

UINT MSI_ViewClose

(

MSIQUERY *

query

)

Definition at line 450 of file msiquery.c.

{
    MSIVIEW *view;
 
    TRACE("%p\n", query );
 
    view = query->view;
    if( !view )
        return ERROR_FUNCTION_FAILED;
    if( !view->ops->close )
        return ERROR_FUNCTION_FAILED;
 
    return view->ops->close( view );
}

Referenced by add_table_to_db(), create_temp_property_table(), get_property(), get_property_row(), msi_clone_properties(), MSI_IterateRecords(), MSI_QueryGetRecord(), msi_set_property(), msi_table_apply_transform(), MsiGetProductPropertyW(), MsiViewClose(), and TransformView_Create().

MSI_ViewExecute()

UINT MSI_ViewExecute	(	MSIQUERY *	query,
		MSIRECORD *	rec
	)

Definition at line 498 of file msiquery.c.

{
    MSIVIEW *view;
 
    TRACE("%p %p\n", query, rec);
 
    view = query->view;
    if( !view )
        return ERROR_FUNCTION_FAILED;
    if( !view->ops->execute )
        return ERROR_FUNCTION_FAILED;
    query->row = 0;
 
    return view->ops->execute( view, rec );
}

Referenced by add_stream(), add_table_to_db(), create_temp_property_table(), get_assembly_record(), get_property(), get_property_row(), is_uninstallable(), load_file_hash(), load_folder_persistence(), mark_patched_components(), merge_diff_row(), msi_clone_properties(), MSI_IterateRecords(), MSI_QueryGetRecord(), msi_set_property(), msi_table_apply_transform(), MsiGetProductPropertyW(), MsiViewExecute(), patch_add_media(), patch_offset_get_filepatches(), patch_offset_get_files(), patch_offset_modify_db(), patch_set_media_source_prop(), patch_set_offsets(), patch_update_filepatch_sequence(), TransformView_add_column(), TransformView_Create(), TransformView_create_table(), TransformView_delete_row(), TransformView_drop_table(), TransformView_insert_row(), TransformView_set_row(), and update_merge_errors().

MSI_ViewFetch()

UINT MSI_ViewFetch	(	MSIQUERY *	query,
		MSIRECORD **	prec
	)

Definition at line 373 of file msiquery.c.

{
    MSIVIEW *view;
    UINT r;
 
    TRACE("%p %p\n", query, prec );
 
    view = query->view;
    if( !view )
        return ERROR_FUNCTION_FAILED;
 
    r = msi_view_get_row(query->db, view, query->row, prec);
    if (r == ERROR_SUCCESS)
    {
        query->row ++;
        (*prec)->cookie = (UINT64)(ULONG_PTR)query;
        MSI_RecordSetInteger(*prec, 0, 1);
    }
    else if (r == ERROR_NO_MORE_ITEMS)
    {
        /* end of view; reset cursor to first row */
        query->row = 0;
    }
 
    return r;
}

Referenced by add_records_to_table(), get_assembly_record(), get_property(), get_property_row(), is_uninstallable(), load_file_hash(), load_folder_persistence(), merge_diff_row(), msi_clone_properties(), MSI_IterateRecords(), MSI_QueryGetRecord(), MsiGetProductPropertyW(), MsiViewFetch(), patch_add_media(), patch_offset_get_filepatches(), patch_offset_get_files(), patch_offset_modify_db(), patch_set_media_source_prop(), patch_set_offsets(), and TransformView_Create().

MSI_ViewGetColumnInfo()

UINT MSI_ViewGetColumnInfo	(	MSIQUERY *	query,
		MSICOLINFO	info,
		MSIRECORD **	prec
	)

Definition at line 598 of file msiquery.c.

{
    UINT r = ERROR_FUNCTION_FAILED, i, count = 0, type;
    MSIRECORD *rec;
    MSIVIEW *view = query->view;
    LPCWSTR name;
    BOOL temporary;
 
    if( !view )
        return ERROR_FUNCTION_FAILED;
 
    if( !view->ops->get_dimensions )
        return ERROR_FUNCTION_FAILED;
 
    r = view->ops->get_dimensions( view, NULL, &count );
    if( r != ERROR_SUCCESS )
        return r;
    if( !count )
        return ERROR_INVALID_PARAMETER;
 
    rec = MSI_CreateRecord( count );
    if( !rec )
        return ERROR_FUNCTION_FAILED;
 
    for( i=0; i<count; i++ )
    {
        name = NULL;
        r = view->ops->get_column_info( view, i+1, &name, &type, &temporary, NULL );
        if( r != ERROR_SUCCESS )
            continue;
        if (info == MSICOLINFO_NAMES)
            MSI_RecordSetStringW( rec, i+1, name );
        else
            set_record_type_string( rec, i+1, type, temporary );
    }
    *prec = rec;
    return ERROR_SUCCESS;
}

Referenced by get_key_value(), get_query_columns(), get_query_types(), merge_verify_colnames(), MSI_DatabaseExport(), and MsiViewGetColumnInfo().

MSI_ViewModify()

UINT MSI_ViewModify	(	MSIQUERY *	query,
		MSIMODIFY	mode,
		MSIRECORD *	rec
	)

Definition at line 693 of file msiquery.c.

{
    MSIVIEW *view = NULL;
    UINT r;
 
    if ( !query || !rec )
        return ERROR_INVALID_HANDLE;
 
    view = query->view;
    if ( !view  || !view->ops->modify)
        return ERROR_FUNCTION_FAILED;
 
    if ( mode == MSIMODIFY_UPDATE && rec->cookie != (UINT64)(ULONG_PTR)query )
        return ERROR_FUNCTION_FAILED;
 
    r = view->ops->modify( view, mode, rec, query->row - 1 );
    if (mode == MSIMODIFY_DELETE && r == ERROR_SUCCESS)
        query->row--;
 
    return r;
}

Referenced by add_records_to_table(), MsiViewModify(), patch_set_offsets(), and patch_update_file_sequence().

MsiDatabaseApplyTransformA()

UINT WINAPI MsiDatabaseApplyTransformA	(	MSIHANDLE	hdb,
		const char *	transform,
		int	error_cond
	)

Definition at line 928 of file msiquery.c.

{
    WCHAR *wstr;
    UINT ret;
 
    TRACE( "%lu, %s, %#x\n", hdb, debugstr_a(transform), error_cond );
 
    wstr = strdupAtoW( transform );
    if (transform && !wstr)
        return ERROR_NOT_ENOUGH_MEMORY;
 
    ret = MsiDatabaseApplyTransformW( hdb, wstr, error_cond );
    free( wstr );
    return ret;
}

Referenced by test_invalid_functions(), and test_try_transform().

MsiDatabaseApplyTransformW()

UINT WINAPI MsiDatabaseApplyTransformW	(	MSIHANDLE	hdb,
		const WCHAR *	transform,
		int	error_cond
	)

Definition at line 913 of file msiquery.c.

{
    MSIDATABASE *db;
    UINT r;
 
    if (error_cond & ~MSITRANSFORM_ERROR_VIEWTRANSFORM) FIXME( "ignoring error conditions\n" );
 
    if (!(db = msihandle2msiinfo(hdb, MSIHANDLETYPE_DATABASE)))
        return ERROR_INVALID_HANDLE;
 
    r = MSI_DatabaseApplyTransformW( db, transform, error_cond );
    msiobj_release( &db->hdr );
    return r;
}

Referenced by MsiDatabaseApplyTransformA().

MsiDatabaseCommit()

UINT WINAPI MsiDatabaseCommit

(

MSIHANDLE

hdb

)

Definition at line 958 of file msiquery.c.

{
    MSIDATABASE *db;
    UINT r;
 
    TRACE( "%lu\n", hdb );
 
    db = msihandle2msiinfo( hdb, MSIHANDLETYPE_DATABASE );
    if( !db )
    {
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(hdb)))
            return ERROR_INVALID_HANDLE;
 
        WARN("not allowed during a custom action!\n");
 
        return ERROR_SUCCESS;
    }
 
    if (db->mode == MSI_OPEN_READONLY)
    {
        msiobj_release( &db->hdr );
        return ERROR_SUCCESS;
    }
 
    /* FIXME: lock the database */
 
    r = msi_commit_streams( db );
    if (r != ERROR_SUCCESS) ERR("Failed to commit streams!\n");
    else
    {
        r = MSI_CommitTables( db );
        if (r != ERROR_SUCCESS) ERR("Failed to commit tables!\n");
    }
 
    /* FIXME: unlock the database */
 
    msiobj_release( &db->hdr );
 
    if (r == ERROR_SUCCESS)
    {
        free( db->deletefile );
        db->deletefile = NULL;
    }
 
    return r;
}

Referenced by create_database_suminfo(), create_database_wordcount(), create_db(), create_package_db(), generate_transform(), helper_createpackage(), set_admin_summary_info(), test_access(), test_binary(), test_costs(), test_createtable(), test_customaction1(), test_defaultdatabase(), test_deleterow(), test_emptypackage(), test_forcecodepage(), test_icon_table(), test_int_widths(), test_integers(), test_invalid_functions(), test_longstrings(), test_msibadqueries(), test_msidatabase(), test_MsiDatabaseCommit(), test_MsiGetProductProperty(), test_MsiGetSourcePath(), test_msiinsert(), test_MsiOpenDatabase(), test_shortlongsource(), test_states(), test_storages_table(), test_streamtable(), test_stringtable(), test_suminfo(), test_top_level_action(), test_try_transform(), and test_update().

MsiDatabaseGenerateTransformA()

UINT WINAPI MsiDatabaseGenerateTransformA	(	MSIHANDLE	hdb,
		MSIHANDLE	hdbref,
		const char *	szTransformFile,
		int	iReserved1,
		int	iReserved2
	)

Definition at line 944 of file msiquery.c.

{
    FIXME( "%lu, %lu, %s, %d, %d\n", hdb, hdbref, debugstr_a(szTransformFile), iReserved1, iReserved2 );
    return ERROR_CALL_NOT_IMPLEMENTED;
}

Referenced by generate_transform(), and test_invalid_functions().

MsiDatabaseGenerateTransformW()

UINT WINAPI MsiDatabaseGenerateTransformW	(	MSIHANDLE	hdb,
		MSIHANDLE	hdbref,
		const WCHAR *	szTransformFile,
		int	iReserved1,
		int	iReserved2
	)

Definition at line 951 of file msiquery.c.

{
    FIXME( "%lu, %lu, %s, %d, %d\n", hdb, hdbref, debugstr_w(szTransformFile), iReserved1, iReserved2 );
    return ERROR_CALL_NOT_IMPLEMENTED;
}

MsiDatabaseGetPrimaryKeysA()

UINT WINAPI MsiDatabaseGetPrimaryKeysA	(	MSIHANDLE	hdb,
		const char *	table,
		MSIHANDLE *	phRec
	)

Definition at line 1123 of file msiquery.c.

{
    WCHAR *szwTable = NULL;
    UINT r;
 
    TRACE( "%lu, %s, %p\n", hdb, debugstr_a(table), phRec );
 
    if( table )
    {
        szwTable = strdupAtoW( table );
        if( !szwTable )
            return ERROR_OUTOFMEMORY;
    }
    r = MsiDatabaseGetPrimaryKeysW( hdb, szwTable, phRec );
    free( szwTable );
 
    return r;
}

Referenced by test_db(), test_fieldzero(), and test_primary_keys().

MsiDatabaseGetPrimaryKeysW()

UINT WINAPI MsiDatabaseGetPrimaryKeysW	(	MSIHANDLE	hdb,
		const WCHAR *	table,
		MSIHANDLE *	phRec
	)

Definition at line 1074 of file msiquery.c.

{
    MSIRECORD *rec = NULL;
    MSIDATABASE *db;
    UINT r;
 
    TRACE( "%lu, %s, %p\n", hdb, debugstr_w(table), phRec );
 
    db = msihandle2msiinfo( hdb, MSIHANDLETYPE_DATABASE );
    if( !db )
    {
        struct wire_record *wire_rec = NULL;
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(hdb)))
            return ERROR_INVALID_HANDLE;
 
        __TRY
        {
            r = remote_DatabaseGetPrimaryKeys(remote, table, &wire_rec);
        }
        __EXCEPT(rpc_filter)
        {
            r = GetExceptionCode();
        }
        __ENDTRY
 
        if (!r)
        {
            r = unmarshal_record(wire_rec, phRec);
            free_remote_record(wire_rec);
        }
 
        return r;
    }
 
    r = MSI_DatabaseGetPrimaryKeys( db, table, &rec );
    if( r == ERROR_SUCCESS )
    {
        *phRec = alloc_msihandle( &rec->hdr );
        if (! *phRec)
           r = ERROR_NOT_ENOUGH_MEMORY;
        msiobj_release( &rec->hdr );
    }
    msiobj_release( &db->hdr );
 
    return r;
}

Referenced by MsiDatabaseGetPrimaryKeysA(), and s_remote_DatabaseGetPrimaryKeys().

MsiDatabaseIsTablePersistentA()

MSICONDITION WINAPI MsiDatabaseIsTablePersistentA	(	MSIHANDLE	hDatabase,
		const char *	szTableName
	)

Definition at line 1142 of file msiquery.c.

{
    WCHAR *szwTableName = NULL;
    MSICONDITION r;
 
    TRACE( "%lu, %s\n", hDatabase, debugstr_a(szTableName) );
 
    if( szTableName )
    {
        szwTableName = strdupAtoW( szTableName );
        if( !szwTableName )
            return MSICONDITION_ERROR;
    }
    r = MsiDatabaseIsTablePersistentW( hDatabase, szwTableName );
    free( szwTableName );
 
    return r;
}

Referenced by test_alter(), test_db(), test_emptypackage(), and test_temporary_table().

MsiDatabaseIsTablePersistentW()

MSICONDITION WINAPI MsiDatabaseIsTablePersistentW	(	MSIHANDLE	hDatabase,
		const WCHAR *	szTableName
	)

Definition at line 1161 of file msiquery.c.

{
    MSIDATABASE *db;
    MSICONDITION r;
 
    TRACE( "%lu, %s\n", hDatabase, debugstr_w(szTableName) );
 
    db = msihandle2msiinfo( hDatabase, MSIHANDLETYPE_DATABASE );
    if( !db )
    {
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(hDatabase)))
            return MSICONDITION_ERROR;
 
        __TRY
        {
            r = remote_DatabaseIsTablePersistent(remote, szTableName);
        }
        __EXCEPT(rpc_filter)
        {
            r = MSICONDITION_ERROR;
        }
        __ENDTRY
 
        return r;
    }
 
    r = MSI_DatabaseIsTablePersistent( db, szTableName );
 
    msiobj_release( &db->hdr );
 
    return r;
}

Referenced by MsiDatabaseIsTablePersistentA(), and s_remote_DatabaseIsTablePersistent().

MsiDatabaseOpenViewA()

UINT WINAPI MsiDatabaseOpenViewA	(	MSIHANDLE	hdb,
		const char *	szQuery,
		MSIHANDLE *	phView
	)

Definition at line 88 of file msiquery.c.

{
    UINT r;
    WCHAR *szwQuery;
 
    TRACE( "%lu, %s, %p\n", hdb, debugstr_a(szQuery), phView );
 
    if( szQuery )
    {
        szwQuery = strdupAtoW( szQuery );
        if( !szwQuery )
            return ERROR_FUNCTION_FAILED;
    }
    else
        szwQuery = NULL;
 
    r = MsiDatabaseOpenViewW( hdb, szwQuery, phView);
 
    free( szwQuery );
    return r;
}

Referenced by do_query(), find_entry(), find_prop_in_property(), get_column_info(), get_columns_table_type(), get_integer(), get_string(), run_query(), test_carriagereturn(), test_collation(), test_columnorder(), test_createtable(), test_db(), test_dbmerge(), test_deleterow(), test_droptable(), test_emptypackage(), test_fieldzero(), test_getcolinfo(), test_handle_limit(), test_insertorder(), test_integers(), test_join(), test_longstrings(), test_msiexport(), test_msiimport(), test_msiinsert(), test_noquotes(), test_order(), test_packagecoltypes(), test_quotes(), test_rows_order(), test_select_column_names(), test_select_markers(), test_select_with_tablenames(), test_simple_patch(), test_storages_table(), test_streamtable(), test_stringtable(), test_suminfo_import(), test_system_tables(), test_tables_order(), test_temporary_table(), test_try_transform(), test_update(), test_view_get_error(), test_viewfetch_wraparound(), test_viewmodify(), test_viewmodify_assign(), test_viewmodify_delete(), test_viewmodify_delete_temporary(), test_viewmodify_insert(), test_viewmodify_merge(), test_viewmodify_refresh(), test_viewmodify_update(), test_where(), test_where_not_in_selected(), test_where_viewmodify(), and try_query_param().

MsiDatabaseOpenViewW()

UINT WINAPI MsiDatabaseOpenViewW	(	MSIHANDLE	hdb,
		LPCWSTR	szQuery,
		MSIHANDLE *	phView
	)

Definition at line 236 of file msiquery.c.

{
    MSIDATABASE *db;
    MSIQUERY *query = NULL;
    UINT ret;
 
    TRACE("%s %p\n", debugstr_w(szQuery), phView);
 
    if (!phView)
        return ERROR_INVALID_PARAMETER;
 
    if (!szQuery)
        return ERROR_BAD_QUERY_SYNTAX;
 
    db = msihandle2msiinfo( hdb, MSIHANDLETYPE_DATABASE );
    if( !db )
    {
        MSIHANDLE remote, remote_view;
 
        if (!(remote = msi_get_remote(hdb)))
            return ERROR_INVALID_HANDLE;
 
        __TRY
        {
            ret = remote_DatabaseOpenView(remote, szQuery, &remote_view);
        }
        __EXCEPT(rpc_filter)
        {
            ret = GetExceptionCode();
        }
        __ENDTRY
 
        if (!ret)
            *phView = alloc_msi_remote_handle(remote_view);
        return ret;
    }
 
    ret = MSI_DatabaseOpenViewW( db, szQuery, &query );
    if( ret == ERROR_SUCCESS )
    {
        *phView = alloc_msihandle( &query->hdr );
        if (! *phView)
           ret = ERROR_NOT_ENOUGH_MEMORY;
        msiobj_release( &query->hdr );
    }
    msiobj_release( &db->hdr );
 
    return ret;
}

Referenced by database_invoke(), find_entryW(), MsiDatabaseOpenViewA(), run_queryW(), s_remote_DatabaseOpenView(), and test_collation().

MsiGetLastErrorRecord()

MSIHANDLE WINAPI MsiGetLastErrorRecord

(

void

)

Definition at line 867 of file msiquery.c.

{
    FIXME("\n");
    return 0;
}

MsiViewClose()

UINT WINAPI MsiViewClose

(

MSIHANDLE

hView

)

Definition at line 465 of file msiquery.c.

{
    MSIQUERY *query;
    UINT ret;
 
    TRACE( "%lu\n", hView );
 
    query = msihandle2msiinfo( hView, MSIHANDLETYPE_VIEW );
    if (!query)
    {
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(hView)))
            return ERROR_INVALID_HANDLE;
 
        __TRY
        {
            ret = remote_ViewClose(remote);
        }
        __EXCEPT(rpc_filter)
        {
            ret = GetExceptionCode();
        }
        __ENDTRY
 
        return ret;
    }
 
    ret = MSI_ViewClose( query );
    msiobj_release( &query->hdr );
    return ret;
}

Referenced by do_query(), find_entry(), find_entryW(), find_prop_in_property(), get_column_info(), get_columns_table_type(), get_integer(), get_string(), run_query(), run_queryW(), s_remote_ViewClose(), test_carriagereturn(), test_collation(), test_columnorder(), test_createtable(), test_db(), test_dbmerge(), test_deleterow(), test_droptable(), test_emptypackage(), test_fieldzero(), test_getcolinfo(), test_handle_limit(), test_insertorder(), test_integers(), test_join(), test_longstrings(), test_msiexport(), test_msiimport(), test_msiinsert(), test_noquotes(), test_order(), test_quotes(), test_rows_order(), test_select_column_names(), test_select_markers(), test_select_with_tablenames(), test_simple_patch(), test_storages_table(), test_streamtable(), test_stringtable(), test_system_tables(), test_tables_order(), test_temporary_table(), test_try_transform(), test_update(), test_viewfetch_wraparound(), test_viewmodify(), test_viewmodify_assign(), test_viewmodify_delete(), test_viewmodify_delete_temporary(), test_viewmodify_refresh(), test_viewmodify_update(), test_where(), test_where_not_in_selected(), test_where_viewmodify(), try_query_param(), and view_invoke().

MsiViewExecute()

UINT WINAPI MsiViewExecute	(	MSIHANDLE	hView,
		MSIHANDLE	hRec
	)

Definition at line 514 of file msiquery.c.

{
    MSIQUERY *query;
    MSIRECORD *rec = NULL;
    UINT ret;
 
    TRACE( "%lu, %lu\n", hView, hRec );
 
    if( hRec )
    {
        rec = msihandle2msiinfo( hRec, MSIHANDLETYPE_RECORD );
        if( !rec )
            return ERROR_INVALID_HANDLE;
    }
 
    query = msihandle2msiinfo( hView, MSIHANDLETYPE_VIEW );
    if( !query )
    {
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(hView)))
            return ERROR_INVALID_HANDLE;
 
        __TRY
        {
            ret = remote_ViewExecute(remote, rec ? (struct wire_record *)&rec->count : NULL);
        }
        __EXCEPT(rpc_filter)
        {
            ret = GetExceptionCode();
        }
        __ENDTRY
 
        if (rec)
            msiobj_release(&rec->hdr);
        return ret;
    }
 
    msiobj_lock( &rec->hdr );
    ret = MSI_ViewExecute( query, rec );
    msiobj_unlock( &rec->hdr );
 
    msiobj_release( &query->hdr );
    if( rec )
        msiobj_release( &rec->hdr );
 
    return ret;
}

Referenced by do_query(), find_entry(), find_entryW(), find_prop_in_property(), get_column_info(), get_columns_table_type(), get_integer(), get_string(), run_query(), run_queryW(), s_remote_ViewExecute(), test_carriagereturn(), test_collation(), test_columnorder(), test_createtable(), test_db(), test_dbmerge(), test_deleterow(), test_droptable(), test_emptypackage(), test_fieldzero(), test_getcolinfo(), test_insertorder(), test_integers(), test_join(), test_longstrings(), test_msiexport(), test_msiimport(), test_msiinsert(), test_noquotes(), test_order(), test_quotes(), test_rows_order(), test_select_column_names(), test_select_markers(), test_select_with_tablenames(), test_simple_patch(), test_storages_table(), test_streamtable(), test_stringtable(), test_system_tables(), test_tables_order(), test_try_transform(), test_update(), test_view_get_error(), test_viewfetch_wraparound(), test_viewmodify(), test_viewmodify_assign(), test_viewmodify_delete(), test_viewmodify_delete_temporary(), test_viewmodify_insert(), test_viewmodify_merge(), test_viewmodify_refresh(), test_viewmodify_update(), test_where(), test_where_not_in_selected(), test_where_viewmodify(), try_query_param(), and view_invoke().

MsiViewFetch()

UINT WINAPI MsiViewFetch	(	MSIHANDLE	hView,
		MSIHANDLE *	record
	)

Definition at line 400 of file msiquery.c.

{
    MSIQUERY *query;
    MSIRECORD *rec = NULL;
    UINT ret;
 
    TRACE( "%lu, %p\n", hView, record );
 
    if( !record )
        return ERROR_INVALID_PARAMETER;
    *record = 0;
 
    query = msihandle2msiinfo( hView, MSIHANDLETYPE_VIEW );
    if (!query)
    {
        struct wire_record *wire_rec = NULL;
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(hView)))
            return ERROR_INVALID_HANDLE;
 
        __TRY
        {
            ret = remote_ViewFetch(remote, &wire_rec);
        }
        __EXCEPT(rpc_filter)
        {
            ret = GetExceptionCode();
        }
        __ENDTRY
 
        if (!ret)
        {
            ret = unmarshal_record(wire_rec, record);
            free_remote_record(wire_rec);
        }
        return ret;
    }
    ret = MSI_ViewFetch( query, &rec );
    if( ret == ERROR_SUCCESS )
    {
        *record = alloc_msihandle( &rec->hdr );
        if (! *record)
           ret = ERROR_NOT_ENOUGH_MEMORY;
        msiobj_release( &rec->hdr );
    }
    msiobj_release( &query->hdr );
    return ret;
}

Referenced by do_query(), find_entry(), find_entryW(), find_prop_in_property(), get_columns_table_type(), get_integer(), get_string(), s_remote_ViewFetch(), test_carriagereturn(), test_collation(), test_columnorder(), test_db(), test_dbmerge(), test_deleterow(), test_droptable(), test_emptypackage(), test_fieldzero(), test_insertorder(), test_join(), test_longstrings(), test_msiimport(), test_msiinsert(), test_noquotes(), test_order(), test_quotes(), test_rows_order(), test_select_column_names(), test_select_markers(), test_select_with_tablenames(), test_simple_patch(), test_storages_table(), test_streamtable(), test_stringtable(), test_system_tables(), test_tables_order(), test_try_transform(), test_update(), test_viewfetch_wraparound(), test_viewmodify(), test_viewmodify_assign(), test_viewmodify_delete(), test_viewmodify_delete_temporary(), test_viewmodify_insert(), test_viewmodify_merge(), test_viewmodify_refresh(), test_viewmodify_update(), test_where(), test_where_not_in_selected(), test_where_viewmodify(), and view_invoke().

MsiViewGetColumnInfo()

UINT WINAPI MsiViewGetColumnInfo	(	MSIHANDLE	hView,
		MSICOLINFO	info,
		MSIHANDLE *	hRec
	)

Definition at line 637 of file msiquery.c.

{
    MSIQUERY *query = NULL;
    MSIRECORD *rec = NULL;
    UINT r;
 
    TRACE( "%lu, %d, %p\n", hView, info, hRec );
 
    if( !hRec )
        return ERROR_INVALID_PARAMETER;
 
    if( info != MSICOLINFO_NAMES && info != MSICOLINFO_TYPES )
        return ERROR_INVALID_PARAMETER;
 
    query = msihandle2msiinfo( hView, MSIHANDLETYPE_VIEW );
    if (!query)
    {
        struct wire_record *wire_rec = NULL;
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(hView)))
            return ERROR_INVALID_HANDLE;
 
        __TRY
        {
            r = remote_ViewGetColumnInfo(remote, info, &wire_rec);
        }
        __EXCEPT(rpc_filter)
        {
            r = GetExceptionCode();
        }
        __ENDTRY
 
        if (!r)
        {
            r = unmarshal_record(wire_rec, hRec);
            free_remote_record(wire_rec);
        }
 
        return r;
    }
 
    r = MSI_ViewGetColumnInfo( query, info, &rec );
    if ( r == ERROR_SUCCESS )
    {
        *hRec = alloc_msihandle( &rec->hdr );
        if ( !*hRec )
            r = ERROR_NOT_ENOUGH_MEMORY;
        msiobj_release( &rec->hdr );
    }
 
    msiobj_release( &query->hdr );
 
    return r;
}

Referenced by get_column_info(), s_remote_ViewGetColumnInfo(), test_columnorder(), test_createtable(), test_db(), test_dbmerge(), test_getcolinfo(), test_integers(), test_msiimport(), test_packagecoltypes(), test_select_column_names(), test_temporary_table(), and test_try_transform().

MsiViewGetErrorA()

MSIDBERROR WINAPI MsiViewGetErrorA	(	MSIHANDLE	handle,
		char *	buffer,
		DWORD *	buflen
	)

Definition at line 816 of file msiquery.c.

{
    MSIQUERY *query;
    const WCHAR *column;
    MSIDBERROR r;
 
    TRACE( "%lu, %p, %p\n", handle, buffer, buflen );
 
    if (!buflen)
        return MSIDBERROR_INVALIDARG;
 
    if (!(query = msihandle2msiinfo(handle, MSIHANDLETYPE_VIEW)))
    {
        WCHAR *remote_column = NULL;
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(handle)))
            return MSIDBERROR_INVALIDARG;
 
        if (!*buflen)
            return MSIDBERROR_FUNCTIONERROR;
 
        __TRY
        {
            r = remote_ViewGetError(remote, &remote_column);
        }
        __EXCEPT(rpc_filter)
        {
            r = GetExceptionCode();
        }
        __ENDTRY;
 
        if (msi_strncpyWtoA(remote_column ? remote_column : L"", -1, buffer, buflen, FALSE) == ERROR_MORE_DATA)
            r = MSIDBERROR_MOREDATA;
 
        if (remote_column)
            midl_user_free(remote_column);
 
        return r;
    }
 
    if ((r = query->view->error)) column = query->view->error_column;
    else column = L"";
 
    if (msi_strncpyWtoA(column, -1, buffer, buflen, FALSE) == ERROR_MORE_DATA)
        r = MSIDBERROR_MOREDATA;
 
    msiobj_release( &query->hdr );
    return r;
}

Referenced by test_view_get_error(), and test_viewmodify().

MsiViewGetErrorW()

MSIDBERROR WINAPI MsiViewGetErrorW	(	MSIHANDLE	handle,
		WCHAR *	buffer,
		DWORD *	buflen
	)

Definition at line 765 of file msiquery.c.

{
    MSIQUERY *query;
    const WCHAR *column;
    MSIDBERROR r;
 
    TRACE( "%lu, %p, %p\n", handle, buffer, buflen );
 
    if (!buflen)
        return MSIDBERROR_INVALIDARG;
 
    if (!(query = msihandle2msiinfo(handle, MSIHANDLETYPE_VIEW)))
    {
        WCHAR *remote_column = NULL;
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(handle)))
            return MSIDBERROR_INVALIDARG;
 
        if (!*buflen)
            return MSIDBERROR_FUNCTIONERROR;
 
        __TRY
        {
            r = remote_ViewGetError(remote, &remote_column);
        }
        __EXCEPT(rpc_filter)
        {
            r = GetExceptionCode();
        }
        __ENDTRY;
 
        if (msi_strncpyW(remote_column ? remote_column : L"", -1, buffer, buflen) == ERROR_MORE_DATA)
            r = MSIDBERROR_MOREDATA;
 
        if (remote_column)
            midl_user_free(remote_column);
 
        return r;
    }
 
    if ((r = query->view->error)) column = query->view->error_column;
    else column = L"";
 
    if (msi_strncpyW(column, -1, buffer, buflen) == ERROR_MORE_DATA)
        r = MSIDBERROR_MOREDATA;
 
    msiobj_release( &query->hdr );
    return r;
}

Referenced by s_remote_ViewGetError().

MsiViewModify()

UINT WINAPI MsiViewModify	(	MSIHANDLE	hView,
		MSIMODIFY	eModifyMode,
		MSIHANDLE	hRecord
	)

Definition at line 715 of file msiquery.c.

{
    MSIQUERY *query = NULL;
    MSIRECORD *rec = NULL;
    UINT r = ERROR_FUNCTION_FAILED;
 
    TRACE( "%lu, %#x, %lu\n", hView, eModifyMode, hRecord );
 
    rec = msihandle2msiinfo( hRecord, MSIHANDLETYPE_RECORD );
 
    if (!rec)
        return ERROR_INVALID_HANDLE;
 
    query = msihandle2msiinfo( hView, MSIHANDLETYPE_VIEW );
    if (!query)
    {
        struct wire_record *wire_refreshed = NULL;
        MSIHANDLE remote;
 
        if (!(remote = msi_get_remote(hView)))
            return ERROR_INVALID_HANDLE;
 
        __TRY
        {
            r = remote_ViewModify(remote, eModifyMode,
                (struct wire_record *)&rec->count, &wire_refreshed);
        }
        __EXCEPT(rpc_filter)
        {
            r = GetExceptionCode();
        }
        __ENDTRY
 
        if (!r && (eModifyMode == MSIMODIFY_REFRESH || eModifyMode == MSIMODIFY_SEEK))
        {
            r = copy_remote_record(wire_refreshed, hRecord);
            free_remote_record(wire_refreshed);
        }
 
        msiobj_release(&rec->hdr);
        return r;
    }
 
    r = MSI_ViewModify( query, eModifyMode, rec );
 
    msiobj_release( &query->hdr );
    msiobj_release(&rec->hdr);
    return r;
}

Referenced by s_remote_ViewModify(), test_db(), test_join(), test_stringtable(), test_view_get_error(), test_viewmodify(), test_viewmodify_assign(), test_viewmodify_delete(), test_viewmodify_delete_temporary(), test_viewmodify_insert(), test_viewmodify_merge(), test_viewmodify_refresh(), test_viewmodify_update(), test_where_viewmodify(), and view_invoke().

primary_key_iterator()

static UINT primary_key_iterator ( MSIRECORD *  rec, void *  param  )

static

Definition at line 1013 of file msiquery.c.

{
    struct primary_key_record_info *info = param;
    LPCWSTR name, table;
    DWORD type;
 
    type = MSI_RecordGetInteger( rec, 4 );
    if( type & MSITYPE_KEY )
    {
        info->n++;
        if( info->rec )
        {
            if ( info->n == 1 )
            {
                table = MSI_RecordGetString( rec, 1 );
                MSI_RecordSetStringW( info->rec, 0, table);
            }
 
            name = MSI_RecordGetString( rec, 3 );
            MSI_RecordSetStringW( info->rec, info->n, name );
        }
    }
 
    return ERROR_SUCCESS;
}

Referenced by MSI_DatabaseGetPrimaryKeys().

s_remote_ViewClose()

UINT __cdecl s_remote_ViewClose

(

MSIHANDLE

view

)

Definition at line 1196 of file msiquery.c.

{
    return MsiViewClose(view);
}

s_remote_ViewExecute()

UINT __cdecl s_remote_ViewExecute	(	MSIHANDLE	view,
		struct wire_record *	remote_rec
	)

Definition at line 1201 of file msiquery.c.

{
    MSIHANDLE rec = 0;
    UINT r;
 
    if ((r = unmarshal_record(remote_rec, &rec)))
        return r;
 
    r = MsiViewExecute(view, rec);
 
    MsiCloseHandle(rec);
    return r;
}

s_remote_ViewFetch()

UINT __cdecl s_remote_ViewFetch	(	MSIHANDLE	view,
		struct wire_record **	rec
	)

Definition at line 1215 of file msiquery.c.

{
    MSIHANDLE handle;
    UINT r = MsiViewFetch(view, &handle);
    *rec = NULL;
    if (!r)
        *rec = marshal_record(handle);
    MsiCloseHandle(handle);
    return r;
}

s_remote_ViewGetColumnInfo()

UINT __cdecl s_remote_ViewGetColumnInfo	(	MSIHANDLE	view,
		MSICOLINFO	info,
		struct wire_record **	rec
	)

Definition at line 1226 of file msiquery.c.

{
    MSIHANDLE handle;
    UINT r = MsiViewGetColumnInfo(view, info, &handle);
    *rec = NULL;
    if (!r)
        *rec = marshal_record(handle);
    MsiCloseHandle(handle);
    return r;
}

s_remote_ViewGetError()

MSIDBERROR __cdecl s_remote_ViewGetError	(	MSIHANDLE	view,
		LPWSTR *	column
	)

Definition at line 1237 of file msiquery.c.

{
    WCHAR empty[1];
    DWORD size = 1;
    UINT r;
 
    r = MsiViewGetErrorW(view, empty, &size);
    if (r == MSIDBERROR_MOREDATA)
    {
        if (!(*column = midl_user_allocate(++size * sizeof(WCHAR))))
            return MSIDBERROR_FUNCTIONERROR;
        r = MsiViewGetErrorW(view, *column, &size);
    }
    return r;
}

s_remote_ViewModify()

UINT __cdecl s_remote_ViewModify	(	MSIHANDLE	view,
		MSIMODIFY	mode,
		struct wire_record *	remote_rec,
		struct wire_record **	remote_refreshed
	)

Definition at line 1253 of file msiquery.c.

{
    MSIHANDLE handle = 0;
    UINT r;
 
    if ((r = unmarshal_record(remote_rec, &handle)))
        return r;
 
    r = MsiViewModify(view, mode, handle);
    *remote_refreshed = NULL;
    if (!r && (mode == MSIMODIFY_REFRESH || mode == MSIMODIFY_SEEK))
        *remote_refreshed = marshal_record(handle);
 
    MsiCloseHandle(handle);
    return r;
}

set_record_type_string()

static UINT set_record_type_string ( MSIRECORD *  rec, UINT  field, UINT  type, BOOL  temporary  )

static

Definition at line 563 of file msiquery.c.

{
    WCHAR szType[0x10];
 
    if (MSITYPE_IS_BINARY(type))
        szType[0] = 'v';
    else if (type & MSITYPE_LOCALIZABLE)
        szType[0] = 'l';
    else if (type & MSITYPE_UNKNOWN)
        szType[0] = 'f';
    else if (type & MSITYPE_STRING)
    {
        if (temporary)
            szType[0] = 'g';
        else
          szType[0] = 's';
    }
    else
    {
        if (temporary)
            szType[0] = 'j';
        else
            szType[0] = 'i';
    }
 
    if (type & MSITYPE_NULLABLE)
        szType[0] &= ~0x20;
 
    swprintf( &szType[1], ARRAY_SIZE(szType) - 1, L"%d", (type&0xff) );
 
    TRACE("type %04x -> %s\n", type, debugstr_w(szType) );
 
    return MSI_RecordSetStringW( rec, field, szType );
}

Referenced by MSI_ViewGetColumnInfo().

VIEW_find_column()

UINT VIEW_find_column	(	MSIVIEW *	table,
		LPCWSTR	name,
		LPCWSTR	table_name,
		UINT *	n
	)

Definition at line 59 of file msiquery.c.

{
    LPCWSTR col_name, haystack_table_name;
    UINT i, count, r;
 
    r = table->ops->get_dimensions( table, NULL, &count );
    if( r != ERROR_SUCCESS )
        return r;
 
    for( i=1; i<=count; i++ )
    {
        INT x;
 
        r = table->ops->get_column_info( table, i, &col_name, NULL,
                                         NULL, &haystack_table_name );
        if( r != ERROR_SUCCESS )
            return r;
        x = wcscmp( name, col_name );
        if( table_name )
            x |= wcscmp( table_name, haystack_table_name );
        if( !x )
        {
            *n = i;
            return ERROR_SUCCESS;
        }
    }
    return ERROR_INVALID_PARAMETER;
}

Referenced by SELECT_AddColumn().

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

msi

)