table.c File Reference

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

Include dependency graph for table.c:

Go to the source code of this file.

Classes
struct	tagMSICOLUMNHASHENTRY
struct	tagMSICOLUMNINFO
struct	tagMSITABLE
struct	tagMSITABLEVIEW
struct	TRANSFORMDATA

Macros
#define	COBJMACROS
#define	MSITABLE_HASH_TABLE_SIZE   37
#define	MAX_STREAM_NAME   0x1f

Typedefs
typedef struct tagMSICOLUMNHASHENTRY	MSICOLUMNHASHENTRY
typedef struct tagMSICOLUMNINFO	MSICOLUMNINFO
typedef struct tagMSITABLEVIEW	MSITABLEVIEW

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (msidb)
static UINT	bytes_per_column (MSIDATABASE *db, const MSICOLUMNINFO *col, UINT bytes_per_strref)
static int	utf2mime (int x)
LPWSTR	encode_streamname (BOOL bTable, LPCWSTR in)
static int	mime2utf (int x)
BOOL	decode_streamname (LPCWSTR in, LPWSTR out)
void	enum_stream_names (IStorage *stg)
UINT	read_stream_data (IStorage *stg, LPCWSTR stname, BOOL table, BYTE **pdata, UINT *psz)
UINT	write_stream_data (IStorage *stg, LPCWSTR stname, LPCVOID data, UINT sz, BOOL bTable)
static void	msi_free_colinfo (MSICOLUMNINFO *colinfo, UINT count)
static void	free_table (MSITABLE *table)
static UINT	msi_table_get_row_size (MSIDATABASE *db, const MSICOLUMNINFO *cols, UINT count, UINT bytes_per_strref)
static UINT	read_table_from_storage (MSIDATABASE *db, MSITABLE *t, IStorage *stg)
void	free_cached_tables (MSIDATABASE *db)
static MSITABLE *	find_cached_table (MSIDATABASE *db, LPCWSTR name)
static void	table_calc_column_offsets (MSIDATABASE *db, MSICOLUMNINFO *colinfo, DWORD count)
static UINT	get_defaulttablecolumns (MSIDATABASE *db, LPCWSTR name, MSICOLUMNINFO *colinfo, UINT *sz)
static UINT	get_tablecolumns (MSIDATABASE *db, LPCWSTR szTableName, MSICOLUMNINFO *colinfo, UINT *sz)
static UINT	table_get_column_info (MSIDATABASE *db, LPCWSTR name, MSICOLUMNINFO **pcols, UINT *pcount)
static UINT	get_table (MSIDATABASE *db, LPCWSTR name, MSITABLE **table_ret)
static UINT	read_table_int (BYTE *const *data, UINT row, UINT col, UINT bytes)
UINT	msi_create_table (MSIDATABASE *db, LPCWSTR name, column_info *col_info, MSICONDITION persistent, BOOL hold)
static UINT	save_table (MSIDATABASE *db, const MSITABLE *t, UINT bytes_per_strref)
static void	msi_update_table_columns (MSIDATABASE *db, LPCWSTR name)
BOOL	TABLE_Exists (MSIDATABASE *db, LPCWSTR name)
static UINT	TABLE_fetch_int (struct tagMSIVIEW *view, UINT row, UINT col, UINT *val)
static UINT	get_stream_name (const MSITABLEVIEW *tv, UINT row, WCHAR **pstname)
static UINT	TABLE_fetch_stream (struct tagMSIVIEW *view, UINT row, UINT col, IStream **stm)
static UINT	table_set_bytes (MSITABLEVIEW *tv, UINT row, UINT col, UINT val)
static UINT	int_to_table_storage (const MSITABLEVIEW *tv, UINT col, int val, UINT *ret)
static UINT	TABLE_set_int (MSIVIEW *view, UINT row, UINT col, int val)
static UINT	TABLE_set_string (MSIVIEW *view, UINT row, UINT col, const WCHAR *val, int len)
static UINT	TABLE_get_row (struct tagMSIVIEW *view, UINT row, MSIRECORD **rec)
static UINT	add_stream (MSIDATABASE *db, const WCHAR *name, IStream *data)
static UINT	TABLE_set_stream (MSIVIEW *view, UINT row, UINT col, IStream *stream)
static UINT	get_table_value_from_record (MSITABLEVIEW *tv, MSIRECORD *rec, UINT iField, UINT *pvalue)
static UINT	TABLE_set_row (struct tagMSIVIEW *view, UINT row, MSIRECORD *rec, UINT mask)
static UINT	table_create_new_row (struct tagMSIVIEW *view, UINT *num, BOOL temporary)
static UINT	TABLE_execute (struct tagMSIVIEW *view, MSIRECORD *record)
static UINT	TABLE_close (struct tagMSIVIEW *view)
static UINT	TABLE_get_dimensions (struct tagMSIVIEW *view, UINT *rows, UINT *cols)
static UINT	TABLE_get_column_info (struct tagMSIVIEW *view, UINT n, LPCWSTR *name, UINT *type, BOOL *temporary, LPCWSTR *table_name)
static UINT	msi_table_find_row (MSITABLEVIEW *tv, MSIRECORD *rec, UINT *row, UINT *column)
static UINT	table_validate_new (MSITABLEVIEW *tv, MSIRECORD *rec, UINT *column)
static int	compare_record (MSITABLEVIEW *tv, UINT row, MSIRECORD *rec)
static int	find_insert_index (MSITABLEVIEW *tv, MSIRECORD *rec)
static UINT	TABLE_insert_row (struct tagMSIVIEW *view, MSIRECORD *rec, UINT row, BOOL temporary)
static UINT	TABLE_delete_row (struct tagMSIVIEW *view, UINT row)
static UINT	msi_table_update (struct tagMSIVIEW *view, MSIRECORD *rec, UINT row)
static UINT	msi_table_assign (struct tagMSIVIEW *view, MSIRECORD *rec)
static UINT	msi_refresh_record (struct tagMSIVIEW *view, MSIRECORD *rec, UINT row)
static UINT	TABLE_modify (struct tagMSIVIEW *view, MSIMODIFY eModifyMode, MSIRECORD *rec, UINT row)
static UINT	TABLE_delete (struct tagMSIVIEW *view)
static UINT	TABLE_add_ref (struct tagMSIVIEW *view)
static UINT	TABLE_remove_column (struct tagMSIVIEW *view, UINT number)
static UINT	TABLE_release (struct tagMSIVIEW *view)
static UINT	TABLE_add_column (struct tagMSIVIEW *view, LPCWSTR column, INT type, BOOL hold)
static UINT	TABLE_drop (struct tagMSIVIEW *view)
UINT	TABLE_CreateView (MSIDATABASE *db, LPCWSTR name, MSIVIEW **view)
static WCHAR *	create_key_string (MSITABLEVIEW *tv, MSIRECORD *rec)
static UINT	msi_record_stream_name (const MSITABLEVIEW *tv, MSIRECORD *rec, LPWSTR name, DWORD *len)
static UINT	TransformView_fetch_int (MSIVIEW *view, UINT row, UINT col, UINT *val)
static UINT	TransformView_fetch_stream (MSIVIEW *view, UINT row, UINT col, IStream **stm)
static UINT	TransformView_set_row (MSIVIEW *view, UINT row, MSIRECORD *rec, UINT mask)
static UINT	TransformView_create_table (MSITABLEVIEW *tv, MSIRECORD *rec)
static UINT	TransformView_add_column (MSITABLEVIEW *tv, MSIRECORD *rec)
static UINT	TransformView_insert_row (MSIVIEW *view, MSIRECORD *rec, UINT row, BOOL temporary)
static UINT	TransformView_drop_table (MSITABLEVIEW *tv, UINT row)
static UINT	TransformView_delete_row (MSIVIEW *view, UINT row)
static UINT	TransformView_execute (MSIVIEW *view, MSIRECORD *record)
static UINT	TransformView_close (MSIVIEW *view)
static UINT	TransformView_get_dimensions (MSIVIEW *view, UINT *rows, UINT *cols)
static UINT	TransformView_get_column_info (MSIVIEW *view, UINT n, LPCWSTR *name, UINT *type, BOOL *temporary, LPCWSTR *table_name)
static UINT	TransformView_delete (MSIVIEW *view)
UINT	TransformView_Create (MSIDATABASE *db, string_table *st, LPCWSTR name, MSIVIEW **view)
UINT	MSI_CommitTables (MSIDATABASE *db)
MSICONDITION	MSI_DatabaseIsTablePersistent (MSIDATABASE *db, LPCWSTR table)
static UINT	read_raw_int (const BYTE *data, UINT col, UINT bytes)
static UINT	msi_record_encoded_stream_name (const MSITABLEVIEW *tv, MSIRECORD *rec, LPWSTR *pstname)
static MSIRECORD *	msi_get_transform_record (const MSITABLEVIEW *tv, const string_table *st, IStorage *stg, const BYTE *rawdata, UINT bytes_per_strref)
static void	dump_table (const string_table *st, const USHORT *rawdata, UINT rawsize)
static UINT *	msi_record_to_row (const MSITABLEVIEW *tv, MSIRECORD *rec)
static UINT	msi_row_matches (MSITABLEVIEW *tv, UINT row, const UINT *data, UINT *column)
static UINT	msi_table_load_transform (MSIDATABASE *db, IStorage *stg, string_table *st, TRANSFORMDATA *transform, UINT bytes_per_strref, int err_cond)
UINT	msi_table_apply_transform (MSIDATABASE *db, IStorage *stg, int err_cond)

Variables
static const MSICOLUMNINFO	_Columns_cols [4]
static const MSICOLUMNINFO	_Tables_cols [1]
static const MSIVIEWOPS	table_ops
static const MSIVIEWOPS	transform_view_ops

Macro Definition Documentation

COBJMACROS

#define COBJMACROS

Definition at line 24 of file table.c.

MAX_STREAM_NAME

#define MAX_STREAM_NAME   0x1f

Definition at line 85 of file table.c.

MSITABLE_HASH_TABLE_SIZE

#define MSITABLE_HASH_TABLE_SIZE   37

Definition at line 41 of file table.c.

Typedef Documentation

MSICOLUMNHASHENTRY

typedef struct tagMSICOLUMNHASHENTRY MSICOLUMNHASHENTRY

MSICOLUMNINFO

typedef struct tagMSICOLUMNINFO MSICOLUMNINFO

MSITABLEVIEW

typedef struct tagMSITABLEVIEW MSITABLEVIEW

Function Documentation

add_stream()

static UINT add_stream ( MSIDATABASE *  db, const WCHAR *  name, IStream *  data  )

static

Definition at line 1288 of file table.c.

{
    MSIQUERY *query;
    MSIRECORD *rec;
    UINT r;
 
    TRACE("%p %s %p\n", db, debugstr_w(name), data);
 
    if (!(rec = MSI_CreateRecord( 2 )))
        return ERROR_OUTOFMEMORY;
 
    r = MSI_RecordSetStringW( rec, 1, name );
    if (r != ERROR_SUCCESS)
       goto done;
 
    r = MSI_RecordSetIStream( rec, 2, data );
    if (r != ERROR_SUCCESS)
       goto done;
 
    r = MSI_DatabaseOpenViewW( db, L"INSERT INTO `_Streams` (`Name`,`Data`) VALUES (?,?)", &query );
    if (r != ERROR_SUCCESS)
       goto done;
 
    r = MSI_ViewExecute( query, rec );
    msiobj_release( &query->hdr );
    if (r == ERROR_SUCCESS)
        goto done;
 
    msiobj_release( &rec->hdr );
    if (!(rec = MSI_CreateRecord( 2 )))
        return ERROR_OUTOFMEMORY;
 
    r = MSI_RecordSetIStream( rec, 1, data );
    if (r != ERROR_SUCCESS)
       goto done;
 
    r = MSI_RecordSetStringW( rec, 2, name );
    if (r != ERROR_SUCCESS)
       goto done;
 
    r = MSI_DatabaseOpenViewW( db, L"UPDATE `_Streams` SET `Data` = ? WHERE `Name` = ?", &query );
    if (r != ERROR_SUCCESS)
        goto done;
 
    r = MSI_ViewExecute( query, rec );
    msiobj_release( &query->hdr );
 
done:
    msiobj_release( &rec->hdr );
    return r;
}

Referenced by TABLE_set_row(), and TABLE_set_stream().

bytes_per_column()

static UINT bytes_per_column ( MSIDATABASE *  db, const MSICOLUMNINFO *  col, UINT  bytes_per_strref  )

inlinestatic

Definition at line 87 of file table.c.

{
    if( MSITYPE_IS_BINARY(col->type) )
        return 2;
 
    if( col->type & MSITYPE_STRING )
        return bytes_per_strref;
 
    if( (col->type & 0xff) <= 2)
        return 2;
 
    if( (col->type & 0xff) != 4 )
        ERR("Invalid column size %u\n", col->type & 0xff);
 
    return 4;
}

Referenced by get_stream_name(), msi_get_transform_record(), msi_table_get_row_size(), msi_table_load_transform(), read_table_from_storage(), save_table(), table_calc_column_offsets(), TABLE_fetch_int(), and table_set_bytes().

compare_record()

static int compare_record ( MSITABLEVIEW *  tv, UINT  row, MSIRECORD *  rec  )

static

Definition at line 1648 of file table.c.

{
    UINT r, i, ivalue, x;
 
    for (i = 0; i < tv->num_cols; i++ )
    {
        if (!(tv->columns[i].type & MSITYPE_KEY)) continue;
 
        r = get_table_value_from_record( tv, rec, i + 1, &ivalue );
        if (r != ERROR_SUCCESS)
            return 1;
 
        r = TABLE_fetch_int( &tv->view, row, i + 1, &x );
        if (r != ERROR_SUCCESS)
        {
            WARN("TABLE_fetch_int should not fail here %u\n", r);
            return -1;
        }
        if (ivalue > x)
        {
            return 1;
        }
        else if (ivalue == x)
        {
            if (i < tv->num_cols - 1) continue;
            return 0;
        }
        else
            return -1;
    }
    return 1;
}

Referenced by find_insert_index().

create_key_string()

static WCHAR * create_key_string ( MSITABLEVIEW *  tv, MSIRECORD *  rec  )

static

Definition at line 2231 of file table.c.

{
    DWORD i, p, len, key_len = 0;
    WCHAR *key;
 
    for (i = 0; i < tv->num_cols; i++)
    {
        if (!(tv->columns[i].type & MSITYPE_KEY))
            continue;
        if (MSI_RecordGetStringW( rec, i+1, NULL, &len ) == ERROR_SUCCESS)
            key_len += len;
        key_len++;
    }
 
    key = msi_alloc( key_len * sizeof(WCHAR) );
    if(!key)
        return NULL;
 
    p = 0;
    for (i = 0; i < tv->num_cols; i++)
    {
        if (!(tv->columns[i].type & MSITYPE_KEY))
            continue;
        if (p)
            key[p++] = '\t';
        len = key_len - p;
        if (MSI_RecordGetStringW( rec, i+1, key + p, &len ) == ERROR_SUCCESS)
            p += len;
    }
    return key;
}

Referenced by TransformView_delete_row(), TransformView_insert_row(), and TransformView_set_row().

decode_streamname()

BOOL decode_streamname	(	LPCWSTR	in,
		LPWSTR	out
	)

Definition at line 178 of file table.c.

{
    WCHAR ch;
    DWORD count = 0;
 
    while ( (ch = *in++) )
    {
        if( (ch >= 0x3800 ) && (ch < 0x4840 ) )
        {
            if( ch >= 0x4800 )
                ch = mime2utf(ch-0x4800);
            else
            {
                ch -= 0x3800;
                *out++ = mime2utf(ch&0x3f);
                count++;
                ch = mime2utf((ch>>6)&0x3f);
            }
        }
        *out++ = ch;
        count++;
    }
    *out = 0;
    return count;
}

Referenced by enum_stream_names(), load_streams(), and msi_table_apply_transform().

dump_table()

static void dump_table ( const string_table *  st, const USHORT *  rawdata, UINT  rawsize  )

static

Definition at line 3066 of file table.c.

{
    UINT i;
    for (i = 0; i < rawsize / 2; i++)
    {
        int len;
        const WCHAR *sval = msi_string_lookup( st, rawdata[i], &len );
        MESSAGE(" %04x %s\n", rawdata[i], debugstr_wn(sval, len) );
    }
}

Referenced by msi_table_load_transform().

encode_streamname()

LPWSTR encode_streamname	(	BOOL	bTable,
		LPCWSTR	in
	)

Definition at line 119 of file table.c.

{
    DWORD count = MAX_STREAM_NAME;
    DWORD ch, next;
    LPWSTR out, p;
 
    if( !bTable )
        count = lstrlenW( in )+2;
    if (!(out = msi_alloc( count*sizeof(WCHAR) ))) return NULL;
    p = out;
 
    if( bTable )
    {
         *p++ = 0x4840;
         count --;
    }
    while( count -- )
    {
        ch = *in++;
        if( !ch )
        {
            *p = ch;
            return out;
        }
        if( ( ch < 0x80 ) && ( utf2mime(ch) >= 0 ) )
        {
            ch = utf2mime(ch) + 0x4800;
            next = *in;
            if( next && (next<0x80) )
            {
                next = utf2mime(next);
                if( next != -1 )
                {
                     next += 0x3ffffc0;
                     ch += (next<<6);
                     in++;
                }
            }
        }
        *p++ = ch;
    }
    ERR("Failed to encode stream name (%s)\n",debugstr_w(in));
    msi_free( out );
    return NULL;
}

Referenced by cabinet_open_stream(), msi_commit_streams(), msi_get_stream(), msi_record_encoded_stream_name(), read_stream_data(), STREAMS_delete_row(), and write_stream_data().

enum_stream_names()

void enum_stream_names

(

IStorage *

stg

)

Definition at line 204 of file table.c.

{
    IEnumSTATSTG *stgenum = NULL;
    HRESULT r;
    STATSTG stat;
    ULONG n, count;
    WCHAR name[0x40];
 
    r = IStorage_EnumElements( stg, 0, NULL, 0, &stgenum );
    if( FAILED( r ) )
        return;
 
    n = 0;
    while( 1 )
    {
        count = 0;
        r = IEnumSTATSTG_Next( stgenum, 1, &stat, &count );
        if( FAILED( r ) || !count )
            break;
        decode_streamname( stat.pwcsName, name );
        TRACE( "stream %2lu -> %s %s\n", n, debugstr_w(stat.pwcsName), debugstr_w(name) );
        CoTaskMemFree( stat.pwcsName );
        n++;
    }
 
    IEnumSTATSTG_Release( stgenum );
}

Referenced by MSI_DatabaseApplyTransformW(), and MSI_OpenDatabaseW().

find_cached_table()

static MSITABLE * find_cached_table ( MSIDATABASE *  db, LPCWSTR  name  )

static

Definition at line 481 of file table.c.

{
    MSITABLE *t;
 
    LIST_FOR_EACH_ENTRY( t, &db->tables, MSITABLE, entry )
        if( !wcscmp( name, t->name ) )
            return t;
 
    return NULL;
}

Referenced by get_table(), and msi_update_table_columns().

find_insert_index()

static int find_insert_index ( MSITABLEVIEW *  tv, MSIRECORD *  rec  )

static

Definition at line 1681 of file table.c.

{
    int idx, c, low = 0, high = tv->table->row_count - 1;
 
    TRACE("%p %p\n", tv, rec);
 
    while (low <= high)
    {
        idx = (low + high) / 2;
        c = compare_record( tv, idx, rec );
 
        if (c < 0)
            high = idx - 1;
        else if (c > 0)
            low = idx + 1;
        else
        {
            TRACE("found %u\n", idx);
            return idx;
        }
    }
    TRACE("found %u\n", high + 1);
    return high + 1;
}

Referenced by TABLE_insert_row().

free_cached_tables()

void free_cached_tables

(

MSIDATABASE *

db

)

Definition at line 470 of file table.c.

{
    while( !list_empty( &db->tables ) )
    {
        MSITABLE *t = LIST_ENTRY( list_head( &db->tables ), MSITABLE, entry );
 
        list_remove( &t->entry );
        free_table( t );
    }
}

Referenced by MSI_CloseDatabase().

free_table()

static void free_table ( MSITABLE *  table )

static

Definition at line 362 of file table.c.

{
    UINT i;
    for( i=0; i<table->row_count; i++ )
        msi_free( table->data[i] );
    msi_free( table->data );
    msi_free( table->data_persistent );
    msi_free_colinfo( table->colinfo, table->col_count );
    msi_free( table->colinfo );
    msi_free( table );
}

Referenced by create_signature_table(), free_cached_tables(), get_table(), msi_create_table(), release_table(), TABLE_drop(), and TABLE_release().

get_defaulttablecolumns()

static UINT get_defaulttablecolumns ( MSIDATABASE *  db, LPCWSTR  name, MSICOLUMNINFO *  colinfo, UINT *  sz  )

static

Definition at line 509 of file table.c.

{
    const MSICOLUMNINFO *p;
    DWORD i, n;
 
    TRACE("%s\n", debugstr_w(name));
 
    if (!wcscmp( name, L"_Tables" ))
    {
        p = _Tables_cols;
        n = 1;
    }
    else if (!wcscmp( name, L"_Columns" ))
    {
        p = _Columns_cols;
        n = 4;
    }
    else return ERROR_FUNCTION_FAILED;
 
    for (i = 0; i < n; i++)
    {
        if (colinfo && i < *sz) colinfo[i] = p[i];
        if (colinfo && i >= *sz) break;
    }
    table_calc_column_offsets( db, colinfo, n );
    *sz = n;
    return ERROR_SUCCESS;
}

Referenced by get_tablecolumns().

get_stream_name()

static UINT get_stream_name ( const MSITABLEVIEW *  tv, UINT  row, WCHAR **  pstname  )

static

Definition at line 1042 of file table.c.

{
    LPWSTR p, stname = NULL;
    UINT i, r, type, ival;
    DWORD len;
    LPCWSTR sval;
    MSIVIEW *view = (MSIVIEW *) tv;
 
    TRACE("%p %d\n", tv, row);
 
    len = lstrlenW( tv->name ) + 1;
    stname = msi_alloc( len*sizeof(WCHAR) );
    if ( !stname )
    {
       r = ERROR_OUTOFMEMORY;
       goto err;
    }
 
    lstrcpyW( stname, tv->name );
 
    for ( i = 0; i < tv->num_cols; i++ )
    {
        type = tv->columns[i].type;
        if ( type & MSITYPE_KEY )
        {
            WCHAR number[0x20];
 
            r = TABLE_fetch_int( view, row, i+1, &ival );
            if ( r != ERROR_SUCCESS )
                goto err;
 
            if ( tv->columns[i].type & MSITYPE_STRING )
            {
                sval = msi_string_lookup( tv->db->strings, ival, NULL );
                if ( !sval )
                {
                    r = ERROR_INVALID_PARAMETER;
                    goto err;
                }
            }
            else
            {
                UINT n = bytes_per_column( tv->db, &tv->columns[i], LONG_STR_BYTES );
 
                switch( n )
                {
                case 2:
                    swprintf( number, ARRAY_SIZE(number), L"%d", ival-0x8000 );
                    break;
                case 4:
                    swprintf( number, ARRAY_SIZE(number), L"%d", ival^0x80000000 );
                    break;
                default:
                    ERR( "oops - unknown column width %d\n", n );
                    r = ERROR_FUNCTION_FAILED;
                    goto err;
                }
                sval = number;
            }
 
            len += lstrlenW( L"." ) + lstrlenW( sval );
            p = msi_realloc ( stname, len*sizeof(WCHAR) );
            if ( !p )
            {
                r = ERROR_OUTOFMEMORY;
                goto err;
            }
            stname = p;
 
            lstrcatW( stname, L"." );
            lstrcatW( stname, sval );
        }
        else
           continue;
    }
 
    *pstname = stname;
    return ERROR_SUCCESS;
 
err:
    msi_free( stname );
    *pstname = NULL;
    return r;
}

Referenced by TABLE_fetch_stream(), TABLE_set_row(), and TABLE_set_stream().

get_table()

static UINT get_table ( MSIDATABASE *  db, LPCWSTR  name, MSITABLE **  table_ret  )

static

Definition at line 573 of file table.c.

{
    MSITABLE *table;
    UINT r;
 
    /* first, see if the table is cached */
    table = find_cached_table( db, name );
    if (table)
    {
        *table_ret = table;
        return ERROR_SUCCESS;
    }
 
    /* nonexistent tables should be interpreted as empty tables */
    table = msi_alloc( sizeof(MSITABLE) + lstrlenW( name ) * sizeof(WCHAR) );
    if (!table)
        return ERROR_FUNCTION_FAILED;
 
    table->row_count = 0;
    table->data = NULL;
    table->data_persistent = NULL;
    table->colinfo = NULL;
    table->col_count = 0;
    table->persistent = MSICONDITION_TRUE;
    lstrcpyW( table->name, name );
 
    if (!wcscmp( name, L"_Tables" ) || !wcscmp( name, L"_Columns" ))
        table->persistent = MSICONDITION_NONE;
 
    r = table_get_column_info( db, name, &table->colinfo, &table->col_count );
    if (r != ERROR_SUCCESS)
    {
        free_table( table );
        return r;
    }
    r = read_table_from_storage( db, table, db->storage );
    if (r != ERROR_SUCCESS)
    {
        free_table( table );
        return r;
    }
    list_add_head( &db->tables, &table->entry );
    *table_ret = table;
    return ERROR_SUCCESS;
}

Referenced by FT_DEFINE_SERVICE(), get_tablecolumns(), MSI_DatabaseIsTablePersistent(), TABLE_CreateView(), and TABLE_Exists().

get_table_value_from_record()

static UINT get_table_value_from_record ( MSITABLEVIEW *  tv, MSIRECORD *  rec, UINT  iField, UINT *  pvalue  )

static

Definition at line 1356 of file table.c.

{
    MSICOLUMNINFO columninfo;
    UINT r;
 
    if (!iField || iField > tv->num_cols || MSI_RecordIsNull( rec, iField ))
        return ERROR_FUNCTION_FAILED;
 
    columninfo = tv->columns[ iField - 1 ];
 
    if ( MSITYPE_IS_BINARY(columninfo.type) )
    {
        *pvalue = 1; /* refers to the first key column */
    }
    else if ( columninfo.type & MSITYPE_STRING )
    {
        int len;
        const WCHAR *sval = msi_record_get_string( rec, iField, &len );
        if (sval)
        {
            r = msi_string2id( tv->db->strings, sval, len, pvalue );
            if (r != ERROR_SUCCESS)
                return ERROR_NOT_FOUND;
        }
        else *pvalue = 0;
    }
    else
        return int_to_table_storage( tv, iField, MSI_RecordGetInteger( rec, iField ), pvalue );
 
    return ERROR_SUCCESS;
}

Referenced by compare_record(), and TABLE_set_row().

get_tablecolumns()

static UINT get_tablecolumns ( MSIDATABASE *  db, LPCWSTR  szTableName, MSICOLUMNINFO *  colinfo, UINT *  sz  )

static

Definition at line 629 of file table.c.

{
    UINT r, i, n = 0, table_id, count, maxcount = *sz;
    MSITABLE *table = NULL;
 
    TRACE("%s\n", debugstr_w(szTableName));
 
    /* first check if there is a default table with that name */
    r = get_defaulttablecolumns( db, szTableName, colinfo, sz );
    if (r == ERROR_SUCCESS && *sz)
        return r;
 
    r = get_table( db, L"_Columns", &table );
    if (r != ERROR_SUCCESS)
    {
        ERR("couldn't load _Columns table\n");
        return ERROR_FUNCTION_FAILED;
    }
 
    /* convert table and column names to IDs from the string table */
    r = msi_string2id( db->strings, szTableName, -1, &table_id );
    if (r != ERROR_SUCCESS)
    {
        WARN("Couldn't find id for %s\n", debugstr_w(szTableName));
        return r;
    }
    TRACE("Table id is %d, row count is %d\n", table_id, table->row_count);
 
    /* Note: _Columns table doesn't have non-persistent data */
 
    /* if maxcount is non-zero, assume it's exactly right for this table */
    if (colinfo) memset( colinfo, 0, maxcount * sizeof(*colinfo) );
    count = table->row_count;
    for (i = 0; i < count; i++)
    {
        if (read_table_int( table->data, i, 0, LONG_STR_BYTES) != table_id) continue;
        if (colinfo)
        {
            UINT id = read_table_int( table->data, i, table->colinfo[2].offset, LONG_STR_BYTES );
            UINT col = read_table_int( table->data, i, table->colinfo[1].offset, sizeof(USHORT) ) - (1 << 15);
 
            /* check the column number is in range */
            if (col < 1 || col > maxcount)
            {
                ERR("column %d out of range (maxcount: %d)\n", col, maxcount);
                continue;
            }
            /* check if this column was already set */
            if (colinfo[col - 1].number)
            {
                ERR("duplicate column %d\n", col);
                continue;
            }
            colinfo[col - 1].tablename = msi_string_lookup( db->strings, table_id, NULL );
            colinfo[col - 1].number = col;
            colinfo[col - 1].colname = msi_string_lookup( db->strings, id, NULL );
            colinfo[col - 1].type = read_table_int( table->data, i, table->colinfo[3].offset,
                                                    sizeof(USHORT) ) - (1 << 15);
            colinfo[col - 1].offset = 0;
            colinfo[col - 1].hash_table = NULL;
        }
        n++;
    }
    TRACE("%s has %d columns\n", debugstr_w(szTableName), n);
 
    if (colinfo && n != maxcount)
    {
        ERR("missing column in table %s\n", debugstr_w(szTableName));
        msi_free_colinfo( colinfo, maxcount );
        return ERROR_FUNCTION_FAILED;
    }
    table_calc_column_offsets( db, colinfo, n );
    *sz = n;
    return ERROR_SUCCESS;
}

Referenced by table_get_column_info().

int_to_table_storage()

static UINT int_to_table_storage ( const MSITABLEVIEW *  tv, UINT  col, int  val, UINT *  ret  )

static

Definition at line 1194 of file table.c.

{
    if ((tv->columns[col-1].type & MSI_DATASIZEMASK) == 2)
    {
        if (val == MSI_NULL_INTEGER)
            *ret = 0;
        else if ((val + 0x8000) & 0xffff0000)
        {
            ERR("value %d out of range\n", val);
            return ERROR_FUNCTION_FAILED;
        }
        else
            *ret = val + 0x8000;
    }
    else
        *ret = val ^ 0x80000000;
 
    return ERROR_SUCCESS;
}

Referenced by get_table_value_from_record(), msi_record_to_row(), and TABLE_set_int().

mime2utf()

static int mime2utf ( int  x )

static

Definition at line 165 of file table.c.

{
    if( x<10 )
        return x + '0';
    if( x<(10+26))
        return x - 10 + 'A';
    if( x<(10+26+26))
        return x - 10 - 26 + 'a';
    if( x == (10+26+26) )
        return '.';
    return '_';
}

Referenced by decode_streamname().

MSI_CommitTables()

UINT MSI_CommitTables

(

MSIDATABASE *

db

)

Definition at line 2887 of file table.c.

{
    UINT r, bytes_per_strref;
    HRESULT hr;
    MSITABLE *table = NULL;
 
    TRACE("%p\n",db);
 
    r = msi_save_string_table( db->strings, db->storage, &bytes_per_strref );
    if( r != ERROR_SUCCESS )
    {
        WARN("failed to save string table r=%08x\n",r);
        return r;
    }
 
    LIST_FOR_EACH_ENTRY( table, &db->tables, MSITABLE, entry )
    {
        r = save_table( db, table, bytes_per_strref );
        if( r != ERROR_SUCCESS )
        {
            WARN("failed to save table %s (r=%08x)\n",
                  debugstr_w(table->name), r);
            return r;
        }
    }
 
    hr = IStorage_Commit( db->storage, 0 );
    if (FAILED( hr ))
    {
        WARN( "failed to commit changes %#lx\n", hr );
        r = ERROR_FUNCTION_FAILED;
    }
    return r;
}

Referenced by MsiDatabaseCommit().

msi_create_table()

UINT msi_create_table	(	MSIDATABASE *	db,
		LPCWSTR	name,
		column_info *	col_info,
		MSICONDITION	persistent,
		BOOL	hold
	)

Definition at line 705 of file table.c.

{
    UINT r, nField;
    MSIVIEW *tv = NULL;
    MSIRECORD *rec = NULL;
    column_info *col;
    MSITABLE *table;
    UINT i;
 
    /* only add tables that don't exist already */
    if( TABLE_Exists(db, name ) )
    {
        WARN("table %s exists\n", debugstr_w(name));
        return ERROR_BAD_QUERY_SYNTAX;
    }
 
    table = msi_alloc( sizeof (MSITABLE) + lstrlenW(name)*sizeof (WCHAR) );
    if( !table )
        return ERROR_FUNCTION_FAILED;
 
    table->ref_count = 0;
    table->row_count = 0;
    table->data = NULL;
    table->data_persistent = NULL;
    table->colinfo = NULL;
    table->col_count = 0;
    table->persistent = persistent;
    lstrcpyW( table->name, name );
 
    if( hold )
        table->ref_count++;
 
    for( col = col_info; col; col = col->next )
        table->col_count++;
 
    table->colinfo = msi_alloc( table->col_count * sizeof(MSICOLUMNINFO) );
    if (!table->colinfo)
    {
        free_table( table );
        return ERROR_FUNCTION_FAILED;
    }
 
    for( i = 0, col = col_info; col; i++, col = col->next )
    {
        UINT table_id = msi_add_string( db->strings, col->table, -1, persistent );
        UINT col_id = msi_add_string( db->strings, col->column, -1, persistent );
 
        table->colinfo[ i ].tablename = msi_string_lookup( db->strings, table_id, NULL );
        table->colinfo[ i ].number = i + 1;
        table->colinfo[ i ].colname = msi_string_lookup( db->strings, col_id, NULL );
        table->colinfo[ i ].type = col->type;
        table->colinfo[ i ].offset = 0;
        table->colinfo[ i ].hash_table = NULL;
    }
    table_calc_column_offsets( db, table->colinfo, table->col_count);
 
    r = TABLE_CreateView( db, L"_Tables", &tv );
    TRACE("CreateView returned %x\n", r);
    if( r )
    {
        free_table( table );
        return r;
    }
 
    r = tv->ops->execute( tv, 0 );
    TRACE("tv execute returned %x\n", r);
    if( r )
        goto err;
 
    rec = MSI_CreateRecord( 1 );
    if( !rec )
        goto err;
 
    r = MSI_RecordSetStringW( rec, 1, name );
    if( r )
        goto err;
 
    r = tv->ops->insert_row( tv, rec, -1, persistent == MSICONDITION_FALSE );
    TRACE("insert_row returned %x\n", r);
    if( r )
        goto err;
 
    tv->ops->delete( tv );
    tv = NULL;
 
    msiobj_release( &rec->hdr );
    rec = NULL;
 
    if( persistent != MSICONDITION_FALSE )
    {
        /* add each column to the _Columns table */
        r = TABLE_CreateView( db, L"_Columns", &tv );
        if( r )
            goto err;
 
        r = tv->ops->execute( tv, 0 );
        TRACE("tv execute returned %x\n", r);
        if( r )
            goto err;
 
        rec = MSI_CreateRecord( 4 );
        if( !rec )
            goto err;
 
        r = MSI_RecordSetStringW( rec, 1, name );
        if( r )
            goto err;
 
        /*
         * need to set the table, column number, col name and type
         * for each column we enter in the table
         */
        nField = 1;
        for( col = col_info; col; col = col->next )
        {
            r = MSI_RecordSetInteger( rec, 2, nField );
            if( r )
                goto err;
 
            r = MSI_RecordSetStringW( rec, 3, col->column );
            if( r )
                goto err;
 
            r = MSI_RecordSetInteger( rec, 4, col->type );
            if( r )
                goto err;
 
            r = tv->ops->insert_row( tv, rec, -1, FALSE );
            if( r )
                goto err;
 
            nField++;
        }
        if( !col )
            r = ERROR_SUCCESS;
    }
 
err:
    if (rec)
        msiobj_release( &rec->hdr );
    /* FIXME: remove values from the string table on error */
    if( tv )
        tv->ops->delete( tv );
 
    if (r == ERROR_SUCCESS)
        list_add_head( &db->tables, &table->entry );
    else
        free_table( table );
 
    return r;
}

Referenced by CREATE_execute().

MSI_DatabaseIsTablePersistent()

MSICONDITION MSI_DatabaseIsTablePersistent	(	MSIDATABASE *	db,
		LPCWSTR	table
	)

Definition at line 2922 of file table.c.

{
    MSITABLE *t;
    UINT r;
 
    TRACE("%p %s\n", db, debugstr_w(table));
 
    if (!table)
        return MSICONDITION_ERROR;
 
    r = get_table( db, table, &t );
    if (r != ERROR_SUCCESS)
        return MSICONDITION_NONE;
 
    return t->persistent;
}

Referenced by MsiDatabaseIsTablePersistentW().

msi_free_colinfo()

static void msi_free_colinfo ( MSICOLUMNINFO *  colinfo, UINT  count  )

static

Definition at line 356 of file table.c.

{
    UINT i;
    for (i = 0; i < count; i++) msi_free( colinfo[i].hash_table );
}

Referenced by free_table(), get_tablecolumns(), and msi_update_table_columns().

msi_get_transform_record()

static MSIRECORD * msi_get_transform_record ( const MSITABLEVIEW *  tv, const string_table *  st, IStorage *  stg, const BYTE *  rawdata, UINT  bytes_per_strref  )

static

Definition at line 2978 of file table.c.

{
    UINT i, val, ofs = 0;
    USHORT mask;
    MSICOLUMNINFO *columns = tv->columns;
    MSIRECORD *rec;
 
    mask = rawdata[0] | (rawdata[1] << 8);
    rawdata += 2;
 
    rec = MSI_CreateRecord( tv->num_cols );
    if( !rec )
        return rec;
 
    TRACE("row ->\n");
    for( i=0; i<tv->num_cols; i++ )
    {
        if ( (mask&1) && (i>=(mask>>8)) )
            break;
        /* all keys must be present */
        if ( (~mask&1) && (~columns[i].type & MSITYPE_KEY) && ((1<<i) & ~mask) )
            continue;
 
        if( MSITYPE_IS_BINARY(tv->columns[i].type) )
        {
            LPWSTR encname;
            IStream *stm = NULL;
            UINT r;
 
            ofs += bytes_per_column( tv->db, &columns[i], bytes_per_strref );
 
            r = msi_record_encoded_stream_name( tv, rec, &encname );
            if ( r != ERROR_SUCCESS )
            {
                msiobj_release( &rec->hdr );
                return NULL;
            }
            r = IStorage_OpenStream( stg, encname, NULL, STGM_READ | STGM_SHARE_EXCLUSIVE, 0, &stm );
            if ( r != ERROR_SUCCESS )
            {
                msiobj_release( &rec->hdr );
                msi_free( encname );
                return NULL;
            }
 
            MSI_RecordSetStream( rec, i+1, stm );
            TRACE(" field %d [%s]\n", i+1, debugstr_w(encname));
            msi_free( encname );
        }
        else if( columns[i].type & MSITYPE_STRING )
        {
            int len;
            const WCHAR *sval;
 
            val = read_raw_int(rawdata, ofs, bytes_per_strref);
            sval = msi_string_lookup( st, val, &len );
            msi_record_set_string( rec, i+1, sval, len );
            TRACE(" field %d [%s]\n", i+1, debugstr_wn(sval, len));
            ofs += bytes_per_strref;
        }
        else
        {
            UINT n = bytes_per_column( tv->db, &columns[i], bytes_per_strref );
            switch( n )
            {
            case 2:
                val = read_raw_int(rawdata, ofs, n);
                if (val)
                    MSI_RecordSetInteger( rec, i+1, val-0x8000 );
                TRACE(" field %d [0x%04x]\n", i+1, val );
                break;
            case 4:
                val = read_raw_int(rawdata, ofs, n);
                if (val)
                    MSI_RecordSetInteger( rec, i+1, val^0x80000000 );
                TRACE(" field %d [0x%08x]\n", i+1, val );
                break;
            default:
                ERR("oops - unknown column width %d\n", n);
                break;
            }
            ofs += n;
        }
    }
    return rec;
}

Referenced by msi_table_load_transform().

msi_record_encoded_stream_name()

static UINT msi_record_encoded_stream_name ( const MSITABLEVIEW *  tv, MSIRECORD *  rec, LPWSTR *  pstname  )

static

Definition at line 2949 of file table.c.

{
    UINT r;
    DWORD len;
    WCHAR *name;
 
    TRACE("%p %p\n", tv, rec);
 
    r = msi_record_stream_name( tv, rec, NULL, &len );
    if (r != ERROR_SUCCESS)
        return r;
    len++;
 
    name = msi_alloc( len * sizeof(WCHAR) );
    if (!name)
        return ERROR_OUTOFMEMORY;
 
    r = msi_record_stream_name( tv, rec, name, &len );
    if (r != ERROR_SUCCESS)
    {
        msi_free( name );
        return r;
    }
 
    *pstname = encode_streamname( FALSE, name );
    msi_free( name );
    return ERROR_SUCCESS;
}

Referenced by msi_get_transform_record().

msi_record_stream_name()

static UINT msi_record_stream_name ( const MSITABLEVIEW *  tv, MSIRECORD *  rec, LPWSTR  name, DWORD *  len  )

static

Definition at line 2263 of file table.c.

{
    UINT p = 0, i, r;
    DWORD l;
 
    l = wcslen( tv->name );
    if (name && *len > l)
        memcpy(name, tv->name, l * sizeof(WCHAR));
    p += l;
 
    for ( i = 0; i < tv->num_cols; i++ )
    {
        if (!(tv->columns[i].type & MSITYPE_KEY))
            continue;
 
        if (name && *len > p + 1)
            name[p] = '.';
        p++;
 
        l = (*len > p ? *len - p : 0);
        r = MSI_RecordGetStringW( rec, i + 1, name ? name + p : NULL, &l );
        if (r != ERROR_SUCCESS)
            return r;
        p += l;
    }
 
    if (name && *len > p)
        name[p] = 0;
 
    *len = p;
    return ERROR_SUCCESS;
}

Referenced by msi_record_encoded_stream_name(), and TransformView_set_row().

msi_record_to_row()

static UINT * msi_record_to_row ( const MSITABLEVIEW *  tv, MSIRECORD *  rec  )

static

Definition at line 3077 of file table.c.

{
    UINT i, r, *data;
 
    data = msi_alloc( tv->num_cols *sizeof (UINT) );
    for( i=0; i<tv->num_cols; i++ )
    {
        data[i] = 0;
 
        if ( ~tv->columns[i].type & MSITYPE_KEY )
            continue;
 
        /* turn the transform column value into a row value */
        if ( ( tv->columns[i].type & MSITYPE_STRING ) &&
             ! MSITYPE_IS_BINARY(tv->columns[i].type) )
        {
            int len;
            const WCHAR *str = msi_record_get_string( rec, i+1, &len );
            if (str)
            {
                r = msi_string2id( tv->db->strings, str, len, &data[i] );
 
                /* if there's no matching string in the string table,
                   these keys can't match any record, so fail now. */
                if (r != ERROR_SUCCESS)
                {
                    msi_free( data );
                    return NULL;
                }
            }
            else data[i] = 0;
        }
        else
        {
            if (int_to_table_storage( tv, i + 1, MSI_RecordGetInteger( rec, i + 1 ), &data[i] ))
            {
                msi_free( data );
                return NULL;
            }
        }
    }
    return data;
}

Referenced by msi_table_find_row().

msi_refresh_record()

static UINT msi_refresh_record ( struct tagMSIVIEW *  view, MSIRECORD *  rec, UINT  row  )

static

Definition at line 1818 of file table.c.

{
    MSIRECORD *curr;
    UINT r, i, count;
 
    r = TABLE_get_row(view, row, &curr);
    if (r != ERROR_SUCCESS)
        return r;
 
    /* Close the original record */
    MSI_CloseRecord(&rec->hdr);
 
    count = MSI_RecordGetFieldCount(rec);
    for (i = 0; i < count; i++)
        MSI_RecordCopyField(curr, i + 1, rec, i + 1);
 
    msiobj_release(&curr->hdr);
    return ERROR_SUCCESS;
}

Referenced by TABLE_modify().

msi_row_matches()

static UINT msi_row_matches ( MSITABLEVIEW *  tv, UINT  row, const UINT *  data, UINT *  column  )

static

Definition at line 3121 of file table.c.

{
    UINT i, r, x, ret = ERROR_FUNCTION_FAILED;
 
    for( i=0; i<tv->num_cols; i++ )
    {
        if ( ~tv->columns[i].type & MSITYPE_KEY )
            continue;
 
        /* turn the transform column value into a row value */
        r = TABLE_fetch_int( &tv->view, row, i+1, &x );
        if ( r != ERROR_SUCCESS )
        {
            ERR("TABLE_fetch_int shouldn't fail here\n");
            break;
        }
 
        /* if this key matches, move to the next column */
        if ( x != data[i] )
        {
            ret = ERROR_FUNCTION_FAILED;
            break;
        }
        if (column) *column = i;
        ret = ERROR_SUCCESS;
    }
    return ret;
}

Referenced by msi_table_find_row().

msi_table_apply_transform()

UINT msi_table_apply_transform	(	MSIDATABASE *	db,
		IStorage *	stg,
		int	err_cond
	)

Definition at line 3371 of file table.c.

{
    struct list transforms;
    IEnumSTATSTG *stgenum = NULL;
    TRANSFORMDATA *transform;
    TRANSFORMDATA *tables = NULL, *columns = NULL;
    HRESULT hr;
    STATSTG stat;
    string_table *strings;
    UINT ret = ERROR_FUNCTION_FAILED;
    UINT bytes_per_strref;
    BOOL property_update = FALSE;
    MSIVIEW *transform_view = NULL;
 
    TRACE("%p %p\n", db, stg );
 
    strings = msi_load_string_table( stg, &bytes_per_strref );
    if( !strings )
        goto end;
 
    hr = IStorage_EnumElements( stg, 0, NULL, 0, &stgenum );
    if (FAILED( hr ))
        goto end;
 
    list_init(&transforms);
 
    while ( TRUE )
    {
        MSITABLEVIEW *tv = NULL;
        WCHAR name[0x40];
        ULONG count = 0;
 
        hr = IEnumSTATSTG_Next( stgenum, 1, &stat, &count );
        if (FAILED( hr ) || !count)
            break;
 
        decode_streamname( stat.pwcsName, name );
        CoTaskMemFree( stat.pwcsName );
        if ( name[0] != 0x4840 )
            continue;
 
        if ( !wcscmp( name+1, L"_StringPool" ) ||
             !wcscmp( name+1, L"_StringData" ) )
            continue;
 
        transform = msi_alloc_zero( sizeof(TRANSFORMDATA) );
        if ( !transform )
            break;
 
        list_add_tail( &transforms, &transform->entry );
 
        transform->name = strdupW( name + 1 );
 
        if ( !wcscmp( transform->name, L"_Tables" ) )
            tables = transform;
        else if (!wcscmp( transform->name, L"_Columns" ) )
            columns = transform;
        else if (!wcscmp( transform->name, L"Property" ))
            property_update = TRUE;
 
        TRACE("transform contains stream %s\n", debugstr_w(name));
 
        /* load the table */
        if (TABLE_CreateView( db, transform->name, (MSIVIEW**) &tv ) != ERROR_SUCCESS)
            continue;
 
        if (tv->view.ops->execute( &tv->view, NULL ) != ERROR_SUCCESS)
        {
            tv->view.ops->delete( &tv->view );
            continue;
        }
 
        tv->view.ops->delete( &tv->view );
    }
 
    if (err_cond & MSITRANSFORM_ERROR_VIEWTRANSFORM)
    {
        static const WCHAR create_query[] = L"CREATE TABLE `_TransformView` ( "
            L"`Table` CHAR(0) NOT NULL TEMPORARY, `Column` CHAR(0) NOT NULL TEMPORARY, "
            L"`Row` CHAR(0) TEMPORARY, `Data` CHAR(0) TEMPORARY, `Current` CHAR(0) TEMPORARY "
            L"PRIMARY KEY `Table`, `Column`, `Row` ) HOLD";
 
        MSIQUERY *query;
        UINT r;
 
        r = MSI_DatabaseOpenViewW( db, create_query, &query );
        if (r != ERROR_SUCCESS)
            goto end;
 
        r = MSI_ViewExecute( query, NULL );
        if (r == ERROR_SUCCESS)
            MSI_ViewClose( query );
        msiobj_release( &query->hdr );
        if (r != ERROR_BAD_QUERY_SYNTAX && r != ERROR_SUCCESS)
            goto end;
 
        if (TABLE_CreateView(db, L"_TransformView", &transform_view) != ERROR_SUCCESS)
            goto end;
 
        if (r == ERROR_BAD_QUERY_SYNTAX)
            transform_view->ops->add_ref( transform_view );
 
        r = transform_view->ops->add_column( transform_view, L"new",
                MSITYPE_TEMPORARY | MSITYPE_NULLABLE | 0x402 /* INT */, FALSE );
        if (r != ERROR_SUCCESS)
            goto end;
    }
 
    /*
     * Apply _Tables and _Columns transforms first so that
     * the table metadata is correct, and empty tables exist.
     */
    ret = msi_table_load_transform( db, stg, strings, tables, bytes_per_strref, err_cond );
    if (ret != ERROR_SUCCESS && ret != ERROR_INVALID_TABLE)
        goto end;
 
    ret = msi_table_load_transform( db, stg, strings, columns, bytes_per_strref, err_cond );
    if (ret != ERROR_SUCCESS && ret != ERROR_INVALID_TABLE)
        goto end;
 
    ret = ERROR_SUCCESS;
 
    while ( !list_empty( &transforms ) )
    {
        transform = LIST_ENTRY( list_head( &transforms ), TRANSFORMDATA, entry );
 
        if ( wcscmp( transform->name, L"_Columns" ) &&
             wcscmp( transform->name, L"_Tables" ) &&
             ret == ERROR_SUCCESS )
        {
            ret = msi_table_load_transform( db, stg, strings, transform, bytes_per_strref, err_cond );
        }
 
        list_remove( &transform->entry );
        msi_free( transform->name );
        msi_free( transform );
    }
 
    if ( ret == ERROR_SUCCESS )
    {
        append_storage_to_db( db, stg );
        if (property_update) msi_clone_properties( db );
    }
 
end:
    if ( stgenum )
        IEnumSTATSTG_Release( stgenum );
    if ( strings )
        msi_destroy_stringtable( strings );
    if (transform_view)
    {
        struct tagMSITABLE *table = ((MSITABLEVIEW*)transform_view)->table;
 
        if (ret != ERROR_SUCCESS)
            transform_view->ops->release( transform_view );
 
        if (!wcscmp(table->colinfo[table->col_count - 1].colname, L"new"))
            TABLE_remove_column( transform_view, table->colinfo[table->col_count - 1].number );
        transform_view->ops->delete( transform_view );
    }
 
    return ret;
}

Referenced by apply_substorage_transform(), and MSI_DatabaseApplyTransformW().

msi_table_assign()

static UINT msi_table_assign ( struct tagMSIVIEW *  view, MSIRECORD *  rec  )

static

Definition at line 1803 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW *)view;
    UINT r, row;
 
    if (!tv->table)
        return ERROR_INVALID_PARAMETER;
 
    r = msi_table_find_row(tv, rec, &row, NULL);
    if (r == ERROR_SUCCESS)
        return TABLE_set_row(view, row, rec, (1 << tv->num_cols) - 1);
    else
        return TABLE_insert_row( view, rec, -1, FALSE );
}

Referenced by TABLE_modify().

msi_table_find_row()

static UINT msi_table_find_row ( MSITABLEVIEW *  tv, MSIRECORD *  rec, UINT *  row, UINT *  column  )

static

Definition at line 3150 of file table.c.

{
    UINT i, r = ERROR_FUNCTION_FAILED, *data;
 
    data = msi_record_to_row( tv, rec );
    if( !data )
        return r;
    for( i = 0; i < tv->table->row_count; i++ )
    {
        r = msi_row_matches( tv, i, data, column );
        if( r == ERROR_SUCCESS )
        {
            *row = i;
            break;
        }
    }
    msi_free( data );
    return r;
}

Referenced by msi_table_assign(), msi_table_load_transform(), msi_table_update(), TABLE_drop(), TABLE_modify(), TABLE_remove_column(), and table_validate_new().

msi_table_get_row_size()

static UINT msi_table_get_row_size ( MSIDATABASE *  db, const MSICOLUMNINFO *  cols, UINT  count, UINT  bytes_per_strref  )

static

Definition at line 374 of file table.c.

{
    const MSICOLUMNINFO *last_col;
 
    if (!count)
        return 0;
 
    if (bytes_per_strref != LONG_STR_BYTES)
    {
        UINT i, size = 0;
        for (i = 0; i < count; i++) size += bytes_per_column( db, &cols[i], bytes_per_strref );
        return size;
    }
    last_col = &cols[count - 1];
    return last_col->offset + bytes_per_column( db, last_col, bytes_per_strref );
}

Referenced by msi_update_table_columns(), read_table_from_storage(), save_table(), TABLE_add_column(), and TABLE_CreateView().

msi_table_load_transform()

static UINT msi_table_load_transform ( MSIDATABASE *  db, IStorage *  stg, string_table *  st, TRANSFORMDATA *  transform, UINT  bytes_per_strref, int  err_cond  )

static

Definition at line 3176 of file table.c.

{
    BYTE *rawdata = NULL;
    MSITABLEVIEW *tv = NULL;
    UINT r, n, sz, i, mask, num_cols, colcol = 0, rawsize = 0;
    MSIRECORD *rec = NULL;
    WCHAR coltable[32];
    const WCHAR *name;
 
    if (!transform)
        return ERROR_SUCCESS;
 
    name = transform->name;
 
    coltable[0] = 0;
    TRACE("%p %p %p %s\n", db, stg, st, debugstr_w(name) );
 
    /* read the transform data */
    read_stream_data( stg, name, TRUE, &rawdata, &rawsize );
    if ( !rawdata )
    {
        TRACE("table %s empty\n", debugstr_w(name) );
        return ERROR_INVALID_TABLE;
    }
 
    /* create a table view */
    if ( err_cond & MSITRANSFORM_ERROR_VIEWTRANSFORM )
        r = TransformView_Create( db, st, name, (MSIVIEW**) &tv );
    else
        r = TABLE_CreateView( db, name, (MSIVIEW**) &tv );
    if( r != ERROR_SUCCESS )
        goto err;
 
    r = tv->view.ops->execute( &tv->view, NULL );
    if( r != ERROR_SUCCESS )
        goto err;
 
    TRACE("name = %s columns = %u row_size = %u raw size = %u\n",
          debugstr_w(name), tv->num_cols, tv->row_size, rawsize );
 
    /* interpret the data */
    for (n = 0; n < rawsize;)
    {
        mask = rawdata[n] | (rawdata[n + 1] << 8);
        if (mask & 1)
        {
            /*
             * if the low bit is set, columns are continuous and
             * the number of columns is specified in the high byte
             */
            sz = 2;
            num_cols = mask >> 8;
            if (num_cols > tv->num_cols)
            {
                ERR("excess columns in transform: %u > %u\n", num_cols, tv->num_cols);
                break;
            }
 
            for (i = 0; i < num_cols; i++)
            {
                if( (tv->columns[i].type & MSITYPE_STRING) &&
                    ! MSITYPE_IS_BINARY(tv->columns[i].type) )
                    sz += bytes_per_strref;
                else
                    sz += bytes_per_column( tv->db, &tv->columns[i], bytes_per_strref );
            }
        }
        else
        {
            /*
             * If the low bit is not set, mask is a bitmask.
             * Excepting for key fields, which are always present,
             *  each bit indicates that a field is present in the transform record.
             *
             * mask == 0 is a special case ... only the keys will be present
             * and it means that this row should be deleted.
             */
            sz = 2;
            num_cols = tv->num_cols;
            for (i = 0; i < num_cols; i++)
            {
                if ((tv->columns[i].type & MSITYPE_KEY) || ((1 << i) & mask))
                {
                    if ((tv->columns[i].type & MSITYPE_STRING) &&
                        !MSITYPE_IS_BINARY(tv->columns[i].type))
                        sz += bytes_per_strref;
                    else
                        sz += bytes_per_column( tv->db, &tv->columns[i], bytes_per_strref );
                }
            }
        }
 
        /* check we didn't run of the end of the table */
        if (n + sz > rawsize)
        {
            ERR("borked.\n");
            dump_table( st, (USHORT *)rawdata, rawsize );
            break;
        }
 
        rec = msi_get_transform_record( tv, st, stg, &rawdata[n], bytes_per_strref );
        if (rec)
        {
            WCHAR table[32];
            DWORD sz = 32;
            UINT number = MSI_NULL_INTEGER;
            UINT row = 0;
 
            if (!wcscmp( name, L"_Columns" ))
            {
                MSI_RecordGetStringW( rec, 1, table, &sz );
                number = MSI_RecordGetInteger( rec, 2 );
 
                /*
                 * Native msi seems writes nul into the Number (2nd) column of
                 * the _Columns table when there are new columns
                 */
                if ( number == MSI_NULL_INTEGER )
                {
                    /* reset the column number on a new table */
                    if (wcscmp( coltable, table ))
                    {
                        colcol = 0;
                        lstrcpyW( coltable, table );
                    }
 
                    /* fix nul column numbers */
                    MSI_RecordSetInteger( rec, 2, ++colcol );
                }
            }
 
            if (TRACE_ON(msidb)) dump_record( rec );
 
            if (tv->table)
                r = msi_table_find_row( tv, rec, &row, NULL );
            else
                r = ERROR_FUNCTION_FAILED;
            if (r == ERROR_SUCCESS)
            {
                if (!mask)
                {
                    TRACE("deleting row [%d]:\n", row);
                    r = tv->view.ops->delete_row( &tv->view, row );
                    if (r != ERROR_SUCCESS)
                        WARN("failed to delete row %u\n", r);
                }
                else if (mask & 1)
                {
                    TRACE("modifying full row [%d]:\n", row);
                    r = tv->view.ops->set_row( &tv->view, row, rec, (1 << tv->num_cols) - 1 );
                    if (r != ERROR_SUCCESS)
                        WARN("failed to modify row %u\n", r);
                }
                else
                {
                    TRACE("modifying masked row [%d]:\n", row);
                    r = tv->view.ops->set_row( &tv->view, row, rec, mask );
                    if (r != ERROR_SUCCESS)
                        WARN("failed to modify row %u\n", r);
                }
            }
            else
            {
                TRACE("inserting row\n");
                r = tv->view.ops->insert_row( &tv->view, rec, -1, FALSE );
                if (r != ERROR_SUCCESS)
                    WARN("failed to insert row %u\n", r);
            }
 
            if (!(err_cond & MSITRANSFORM_ERROR_VIEWTRANSFORM) &&
                    !wcscmp( name, L"_Columns" ))
                msi_update_table_columns( db, table );
 
            msiobj_release( &rec->hdr );
        }
 
        n += sz;
    }
 
err:
    /* no need to free the table, it's associated with the database */
    msi_free( rawdata );
    if( tv )
        tv->view.ops->delete( &tv->view );
 
    return ERROR_SUCCESS;
}

Referenced by msi_table_apply_transform().

msi_table_update()

static UINT msi_table_update ( struct tagMSIVIEW *  view, MSIRECORD *  rec, UINT  row  )

static

Definition at line 1777 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW *)view;
    UINT r, new_row;
 
    /* FIXME: MsiViewFetch should set rec index 0 to some ID that
     * sets the fetched record apart from other records
     */
 
    if (!tv->table)
        return ERROR_INVALID_PARAMETER;
 
    r = msi_table_find_row(tv, rec, &new_row, NULL);
    if (r != ERROR_SUCCESS)
    {
        ERR("can't find row to modify\n");
        return ERROR_FUNCTION_FAILED;
    }
 
    /* the row cannot be changed */
    if (row != new_row)
        return ERROR_FUNCTION_FAILED;
 
    return TABLE_set_row(view, new_row, rec, (1 << tv->num_cols) - 1);
}

Referenced by TABLE_modify().

msi_update_table_columns()

static void msi_update_table_columns ( MSIDATABASE *  db, LPCWSTR  name  )

static

Definition at line 933 of file table.c.

{
    MSITABLE *table;
    UINT size, offset, old_count;
    UINT n;
 
    if (!(table = find_cached_table( db, name ))) return;
    old_count = table->col_count;
    msi_free_colinfo( table->colinfo, table->col_count );
    msi_free( table->colinfo );
    table->colinfo = NULL;
 
    table_get_column_info( db, name, &table->colinfo, &table->col_count );
    if (!table->col_count) return;
 
    size = msi_table_get_row_size( db, table->colinfo, table->col_count, LONG_STR_BYTES );
    offset = table->colinfo[table->col_count - 1].offset;
 
    for ( n = 0; n < table->row_count; n++ )
    {
        table->data[n] = msi_realloc( table->data[n], size );
        if (old_count < table->col_count)
            memset( &table->data[n][offset], 0, size - offset );
    }
}

Referenced by msi_table_load_transform(), and TABLE_remove_column().

read_raw_int()

static UINT read_raw_int ( const BYTE *  data, UINT  col, UINT  bytes  )

static

Definition at line 2939 of file table.c.

{
    UINT ret = 0, i;
 
    for (i = 0; i < bytes; i++)
        ret += (data[col + i] << i * 8);
 
    return ret;
}

Referenced by msi_get_transform_record().

read_stream_data()

UINT read_stream_data	(	IStorage *	stg,
		LPCWSTR	stname,
		BOOL	table,
		BYTE **	pdata,
		UINT *	psz
	)

Definition at line 232 of file table.c.

{
    HRESULT r;
    UINT ret = ERROR_FUNCTION_FAILED;
    VOID *data;
    ULONG sz, count;
    IStream *stm = NULL;
    STATSTG stat;
    LPWSTR encname;
 
    encname = encode_streamname(table, stname);
 
    TRACE("%s -> %s\n",debugstr_w(stname),debugstr_w(encname));
 
    r = IStorage_OpenStream(stg, encname, NULL,
            STGM_READ | STGM_SHARE_EXCLUSIVE, 0, &stm);
    msi_free( encname );
    if( FAILED( r ) )
    {
        WARN( "open stream failed r = %#lx - empty table?\n", r );
        return ret;
    }
 
    r = IStream_Stat(stm, &stat, STATFLAG_NONAME );
    if( FAILED( r ) )
    {
        WARN( "open stream failed r = %#lx!\n", r );
        goto end;
    }
 
    if( stat.cbSize.QuadPart >> 32 )
    {
        WARN("Too big!\n");
        goto end;
    }
 
    sz = stat.cbSize.QuadPart;
    data = msi_alloc( sz );
    if( !data )
    {
        WARN( "couldn't allocate memory r = %#lx!\n", r );
        ret = ERROR_NOT_ENOUGH_MEMORY;
        goto end;
    }
 
    r = IStream_Read(stm, data, sz, &count );
    if( FAILED( r ) || ( count != sz ) )
    {
        msi_free( data );
        WARN("read stream failed r = %#lx!\n", r);
        goto end;
    }
 
    *pdata = data;
    *psz = sz;
    ret = ERROR_SUCCESS;
 
end:
    IStream_Release( stm );
 
    return ret;
}

Referenced by msi_table_load_transform(), and read_table_from_storage().

read_table_from_storage()

static UINT read_table_from_storage ( MSIDATABASE *  db, MSITABLE *  t, IStorage *  stg  )

static

Definition at line 392 of file table.c.

{
    BYTE *rawdata = NULL;
    UINT rawsize = 0, i, j, row_size, row_size_mem;
 
    TRACE("%s\n",debugstr_w(t->name));
 
    row_size = msi_table_get_row_size( db, t->colinfo, t->col_count, db->bytes_per_strref );
    row_size_mem = msi_table_get_row_size( db, t->colinfo, t->col_count, LONG_STR_BYTES );
 
    /* if we can't read the table, just assume that it's empty */
    read_stream_data( stg, t->name, TRUE, &rawdata, &rawsize );
    if( !rawdata )
        return ERROR_SUCCESS;
 
    TRACE("Read %d bytes\n", rawsize );
 
    if( rawsize % row_size )
    {
        WARN("Table size is invalid %d/%d\n", rawsize, row_size );
        goto err;
    }
 
    if ((t->row_count = rawsize / row_size))
    {
        if (!(t->data = msi_alloc_zero( t->row_count * sizeof(USHORT *) ))) goto err;
        if (!(t->data_persistent = msi_alloc_zero( t->row_count * sizeof(BOOL) ))) goto err;
    }
 
    /* transpose all the data */
    TRACE("Transposing data from %d rows\n", t->row_count );
    for (i = 0; i < t->row_count; i++)
    {
        UINT ofs = 0, ofs_mem = 0;
 
        t->data[i] = msi_alloc( row_size_mem );
        if( !t->data[i] )
            goto err;
        t->data_persistent[i] = TRUE;
 
        for (j = 0; j < t->col_count; j++)
        {
            UINT m = bytes_per_column( db, &t->colinfo[j], LONG_STR_BYTES );
            UINT n = bytes_per_column( db, &t->colinfo[j], db->bytes_per_strref );
            UINT k;
 
            if ( n != 2 && n != 3 && n != 4 )
            {
                ERR("oops - unknown column width %d\n", n);
                goto err;
            }
            if (t->colinfo[j].type & MSITYPE_STRING && n < m)
            {
                for (k = 0; k < m; k++)
                {
                    if (k < n)
                        t->data[i][ofs_mem + k] = rawdata[ofs * t->row_count + i * n + k];
                    else
                        t->data[i][ofs_mem + k] = 0;
                }
            }
            else
            {
                for (k = 0; k < n; k++)
                    t->data[i][ofs_mem + k] = rawdata[ofs * t->row_count + i * n + k];
            }
            ofs_mem += m;
            ofs += n;
        }
    }
 
    msi_free( rawdata );
    return ERROR_SUCCESS;
err:
    msi_free( rawdata );
    return ERROR_FUNCTION_FAILED;
}

Referenced by get_table().

read_table_int()

static UINT read_table_int ( BYTE *const *  data, UINT  row, UINT  col, UINT  bytes  )

static

Definition at line 619 of file table.c.

{
    UINT ret = 0, i;
 
    for (i = 0; i < bytes; i++)
        ret += data[row][col + i] << i * 8;
 
    return ret;
}

Referenced by get_tablecolumns(), save_table(), TABLE_Exists(), and TABLE_fetch_int().

save_table()

static UINT save_table ( MSIDATABASE *  db, const MSITABLE *  t, UINT  bytes_per_strref  )

static

Definition at line 858 of file table.c.

{
    BYTE *rawdata = NULL;
    UINT rawsize, i, j, row_size, row_count;
    UINT r = ERROR_FUNCTION_FAILED;
 
    /* Nothing to do for non-persistent tables */
    if( t->persistent == MSICONDITION_FALSE )
        return ERROR_SUCCESS;
 
    TRACE("Saving %s\n", debugstr_w( t->name ) );
 
    row_size = msi_table_get_row_size( db, t->colinfo, t->col_count, bytes_per_strref );
    row_count = t->row_count;
    for (i = 0; i < t->row_count; i++)
    {
        if (!t->data_persistent[i])
        {
            row_count = 1; /* yes, this is bizarre */
            break;
        }
    }
    rawsize = row_count * row_size;
    rawdata = msi_alloc_zero( rawsize );
    if( !rawdata )
    {
        r = ERROR_NOT_ENOUGH_MEMORY;
        goto err;
    }
 
    rawsize = 0;
    for (i = 0; i < row_count; i++)
    {
        UINT ofs = 0, ofs_mem = 0;
 
        if (!t->data_persistent[i]) break;
 
        for (j = 0; j < t->col_count; j++)
        {
            UINT m = bytes_per_column( db, &t->colinfo[j], LONG_STR_BYTES );
            UINT n = bytes_per_column( db, &t->colinfo[j], bytes_per_strref );
            UINT k;
 
            if (n != 2 && n != 3 && n != 4)
            {
                ERR("oops - unknown column width %d\n", n);
                goto err;
            }
            if (t->colinfo[j].type & MSITYPE_STRING && n < m)
            {
                UINT id = read_table_int( t->data, i, ofs_mem, LONG_STR_BYTES );
                if (id > 1 << bytes_per_strref * 8)
                {
                    ERR("string id %u out of range\n", id);
                    goto err;
                }
            }
            for (k = 0; k < n; k++)
            {
                rawdata[ofs * row_count + i * n + k] = t->data[i][ofs_mem + k];
            }
            ofs_mem += m;
            ofs += n;
        }
        rawsize += row_size;
    }
 
    TRACE("writing %d bytes\n", rawsize);
    r = write_stream_data( db->storage, t->name, rawdata, rawsize, TRUE );
 
err:
    msi_free( rawdata );
    return r;
}

Referenced by MSI_CommitTables().

TABLE_add_column()

static UINT TABLE_add_column ( struct tagMSIVIEW *  view, LPCWSTR  column, INT  type, BOOL  hold  )

static

Definition at line 2023 of file table.c.

{
    UINT i, r, table_id, col_id, size, offset;
    BOOL temporary = type & MSITYPE_TEMPORARY;
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    MSICOLUMNINFO *colinfo;
 
    if (temporary && !hold && !tv->table->ref_count)
        return ERROR_SUCCESS;
 
    if (!temporary && tv->table->col_count &&
            tv->table->colinfo[tv->table->col_count-1].type & MSITYPE_TEMPORARY)
        return ERROR_BAD_QUERY_SYNTAX;
 
    for (i = 0; i < tv->table->col_count; i++)
    {
        if (!wcscmp(tv->table->colinfo[i].colname, column))
            return ERROR_BAD_QUERY_SYNTAX;
    }
 
    colinfo = msi_realloc(tv->table->colinfo, sizeof(*tv->table->colinfo) * (tv->table->col_count + 1));
    if (!colinfo)
        return ERROR_OUTOFMEMORY;
    tv->table->colinfo = colinfo;
 
    r = msi_string2id( tv->db->strings, tv->name, -1, &table_id );
    if (r != ERROR_SUCCESS)
        return r;
    col_id = msi_add_string( tv->db->strings, column, -1, !temporary );
 
    colinfo[tv->table->col_count].tablename = msi_string_lookup( tv->db->strings, table_id, NULL );
    colinfo[tv->table->col_count].number = tv->table->col_count + 1;
    colinfo[tv->table->col_count].colname = msi_string_lookup( tv->db->strings, col_id, NULL );
    colinfo[tv->table->col_count].type = type;
    colinfo[tv->table->col_count].offset = 0;
    colinfo[tv->table->col_count].hash_table = NULL;
    tv->table->col_count++;
 
    table_calc_column_offsets( tv->db, tv->table->colinfo, tv->table->col_count);
 
    size = msi_table_get_row_size( tv->db, tv->table->colinfo, tv->table->col_count, LONG_STR_BYTES );
    offset = tv->table->colinfo[tv->table->col_count - 1].offset;
    for (i = 0; i < tv->table->row_count; i++)
    {
        BYTE *data = msi_realloc( tv->table->data[i], size );
        if (!data)
        {
            tv->table->col_count--;
            return ERROR_OUTOFMEMORY;
        }
 
        tv->table->data[i] = data;
        memset(data + offset, 0, size - offset);
    }
 
    if (!temporary)
    {
        MSIVIEW *columns;
        MSIRECORD *rec;
 
        rec = MSI_CreateRecord(4);
        if (!rec)
        {
            tv->table->col_count--;
            return ERROR_OUTOFMEMORY;
        }
 
        MSI_RecordSetStringW(rec, 1, tv->name);
        MSI_RecordSetInteger(rec, 2, tv->table->col_count);
        MSI_RecordSetStringW(rec, 3, column);
        MSI_RecordSetInteger(rec, 4, type);
 
        r = TABLE_CreateView(tv->db, L"_Columns", &columns);
        if (r != ERROR_SUCCESS)
        {
            tv->table->col_count--;
            msiobj_release(&rec->hdr);
            return r;
        }
 
        r = TABLE_insert_row(columns, rec, -1, FALSE);
        columns->ops->delete(columns);
        msiobj_release(&rec->hdr);
        if (r != ERROR_SUCCESS)
        {
            tv->table->col_count--;
            return r;
        }
    }
    if (hold)
        TABLE_add_ref(view);
    return ERROR_SUCCESS;
}

TABLE_add_ref()

static UINT TABLE_add_ref ( struct tagMSIVIEW *  view )

static

Definition at line 1927 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
 
    TRACE( "%p, %ld\n", view, tv->table->ref_count );
    return InterlockedIncrement(&tv->table->ref_count);
}

Referenced by TABLE_add_column().

table_calc_column_offsets()

static void table_calc_column_offsets ( MSIDATABASE *  db, MSICOLUMNINFO *  colinfo, DWORD  count  )

static

Definition at line 492 of file table.c.

{
    DWORD i;
 
    for (i = 0; colinfo && i < count; i++)
    {
         assert( i + 1 == colinfo[i].number );
         if (i) colinfo[i].offset = colinfo[i - 1].offset +
                                    bytes_per_column( db, &colinfo[i - 1], LONG_STR_BYTES );
         else colinfo[i].offset = 0;
 
         TRACE("column %d is [%s] with type %08x ofs %d\n",
               colinfo[i].number, debugstr_w(colinfo[i].colname),
               colinfo[i].type, colinfo[i].offset);
    }
}

Referenced by get_defaulttablecolumns(), get_tablecolumns(), msi_create_table(), and TABLE_add_column().

TABLE_close()

static UINT TABLE_close ( struct tagMSIVIEW *  view )

static

Definition at line 1543 of file table.c.

{
    TRACE("%p\n", view );
 
    return ERROR_SUCCESS;
}

table_create_new_row()

static UINT table_create_new_row ( struct tagMSIVIEW *  view, UINT *  num, BOOL  temporary  )

static

Definition at line 1473 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    BYTE **p, *row;
    BOOL *b;
    UINT sz;
    BYTE ***data_ptr;
    BOOL **data_persist_ptr;
    UINT *row_count;
 
    TRACE("%p %s\n", view, temporary ? "TRUE" : "FALSE");
 
    if( !tv->table )
        return ERROR_INVALID_PARAMETER;
 
    row = msi_alloc_zero( tv->row_size );
    if( !row )
        return ERROR_NOT_ENOUGH_MEMORY;
 
    row_count = &tv->table->row_count;
    data_ptr = &tv->table->data;
    data_persist_ptr = &tv->table->data_persistent;
    if (*num == -1)
        *num = tv->table->row_count;
 
    sz = (*row_count + 1) * sizeof (BYTE*);
    if( *data_ptr )
        p = msi_realloc( *data_ptr, sz );
    else
        p = msi_alloc( sz );
    if( !p )
    {
        msi_free( row );
        return ERROR_NOT_ENOUGH_MEMORY;
    }
 
    sz = (*row_count + 1) * sizeof (BOOL);
    if( *data_persist_ptr )
        b = msi_realloc( *data_persist_ptr, sz );
    else
        b = msi_alloc( sz );
    if( !b )
    {
        msi_free( row );
        msi_free( p );
        return ERROR_NOT_ENOUGH_MEMORY;
    }
 
    *data_ptr = p;
    (*data_ptr)[*row_count] = row;
 
    *data_persist_ptr = b;
    (*data_persist_ptr)[*row_count] = !temporary;
 
    (*row_count)++;
 
    return ERROR_SUCCESS;
}

Referenced by TABLE_insert_row().

TABLE_CreateView()

UINT TABLE_CreateView	(	MSIDATABASE *	db,
		LPCWSTR	name,
		MSIVIEW **	view
	)

Definition at line 2189 of file table.c.

{
    MSITABLEVIEW *tv ;
    UINT r, sz;
 
    TRACE("%p %s %p\n", db, debugstr_w(name), view );
 
    if ( !wcscmp( name, L"_Streams" ) )
        return STREAMS_CreateView( db, view );
    else if ( !wcscmp( name, L"_Storages" ) )
        return STORAGES_CreateView( db, view );
 
    sz = FIELD_OFFSET( MSITABLEVIEW, name[lstrlenW( name ) + 1] );
    tv = msi_alloc_zero( sz );
    if( !tv )
        return ERROR_FUNCTION_FAILED;
 
    r = get_table( db, name, &tv->table );
    if( r != ERROR_SUCCESS )
    {
        msi_free( tv );
        WARN("table not found\n");
        return r;
    }
 
    TRACE("table %p found with %d columns\n", tv->table, tv->table->col_count);
 
    /* fill the structure */
    tv->view.ops = &table_ops;
    tv->db = db;
    tv->columns = tv->table->colinfo;
    tv->num_cols = tv->table->col_count;
    tv->row_size = msi_table_get_row_size( db, tv->table->colinfo, tv->table->col_count, LONG_STR_BYTES );
 
    TRACE("%s one row is %d bytes\n", debugstr_w(name), tv->row_size );
 
    *view = (MSIVIEW*) tv;
    lstrcpyW( tv->name, name );
 
    return ERROR_SUCCESS;
}

Referenced by ALTER_CreateView(), DROP_CreateView(), INSERT_CreateView(), merge_table(), msi_create_table(), msi_table_apply_transform(), msi_table_load_transform(), TABLE_add_column(), TABLE_drop(), TABLE_remove_column(), TransformView_Create(), UPDATE_CreateView(), and WHERE_CreateView().

TABLE_delete()

static UINT TABLE_delete ( struct tagMSIVIEW *  view )

static

Definition at line 1913 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
 
    TRACE("%p\n", view );
 
    tv->table = NULL;
    tv->columns = NULL;
 
    msi_free( tv );
 
    return ERROR_SUCCESS;
}

Referenced by TABLE_release(), and TransformView_delete().

TABLE_delete_row()

static UINT TABLE_delete_row ( struct tagMSIVIEW *  view, UINT  row  )

static

Definition at line 1739 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    UINT r, num_rows, num_cols, i;
 
    TRACE("%p %d\n", tv, row);
 
    if ( !tv->table )
        return ERROR_INVALID_PARAMETER;
 
    r = TABLE_get_dimensions( view, &num_rows, &num_cols );
    if ( r != ERROR_SUCCESS )
        return r;
 
    if ( row >= num_rows )
        return ERROR_FUNCTION_FAILED;
 
    num_rows = tv->table->row_count;
    tv->table->row_count--;
 
    /* reset the hash tables */
    for (i = 0; i < tv->num_cols; i++)
    {
        msi_free( tv->columns[i].hash_table );
        tv->columns[i].hash_table = NULL;
    }
 
    for (i = row + 1; i < num_rows; i++)
    {
        memcpy(tv->table->data[i - 1], tv->table->data[i], tv->row_size);
        tv->table->data_persistent[i - 1] = tv->table->data_persistent[i];
    }
 
    msi_free(tv->table->data[num_rows - 1]);
 
    return ERROR_SUCCESS;
}

Referenced by TABLE_drop(), TABLE_modify(), and TABLE_remove_column().

TABLE_drop()

static UINT TABLE_drop ( struct tagMSIVIEW *  view )

static

Definition at line 2118 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    MSIVIEW *tables = NULL;
    MSIRECORD *rec = NULL;
    UINT r, row;
    INT i;
 
    TRACE("dropping table %s\n", debugstr_w(tv->name));
 
    for (i = tv->table->col_count - 1; i >= 0; i--)
    {
        r = TABLE_remove_column(view, tv->table->colinfo[i].number);
        if (r != ERROR_SUCCESS)
            return r;
    }
 
    rec = MSI_CreateRecord(1);
    if (!rec)
        return ERROR_OUTOFMEMORY;
 
    MSI_RecordSetStringW(rec, 1, tv->name);
 
    r = TABLE_CreateView(tv->db, L"_Tables", &tables);
    if (r != ERROR_SUCCESS)
    {
        msiobj_release(&rec->hdr);
        return r;
    }
 
    r = msi_table_find_row((MSITABLEVIEW *)tables, rec, &row, NULL);
    if (r != ERROR_SUCCESS)
        goto done;
 
    r = TABLE_delete_row(tables, row);
    if (r != ERROR_SUCCESS)
        goto done;
 
    list_remove(&tv->table->entry);
    free_table(tv->table);
 
done:
    msiobj_release(&rec->hdr);
    tables->ops->delete(tables);
 
    return r;
}

TABLE_execute()

static UINT TABLE_execute ( struct tagMSIVIEW *  view, MSIRECORD *  record  )

static

Definition at line 1532 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
 
    TRACE("%p %p\n", tv, record);
 
    TRACE("There are %d columns\n", tv->num_cols );
 
    return ERROR_SUCCESS;
}

TABLE_Exists()

BOOL TABLE_Exists	(	MSIDATABASE *	db,
		LPCWSTR	name
	)

Definition at line 960 of file table.c.

{
    UINT r, table_id, i;
    MSITABLE *table;
 
    if( !wcscmp( name, L"_Tables" ) || !wcscmp( name, L"_Columns" ) ||
        !wcscmp( name, L"_Streams" ) || !wcscmp( name, L"_Storages" ) )
        return TRUE;
 
    r = msi_string2id( db->strings, name, -1, &table_id );
    if( r != ERROR_SUCCESS )
    {
        TRACE("Couldn't find id for %s\n", debugstr_w(name));
        return FALSE;
    }
 
    r = get_table( db, L"_Tables", &table );
    if( r != ERROR_SUCCESS )
    {
        ERR("table _Tables not available\n");
        return FALSE;
    }
 
    for( i = 0; i < table->row_count; i++ )
    {
        if( read_table_int( table->data, i, 0, LONG_STR_BYTES ) == table_id )
            return TRUE;
    }
 
    return FALSE;
}

Referenced by ACTION_ShowDialog(), merge_diff_row(), merge_diff_tables(), merge_table(), msi_create_table(), MSI_DatabaseGetPrimaryKeys(), MSI_DatabaseImport(), and update_merge_errors().

TABLE_fetch_int()

static UINT TABLE_fetch_int ( struct tagMSIVIEW *  view, UINT  row, UINT  col, UINT *  val  )

static

Definition at line 1005 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    UINT offset, n;
 
    if( !tv->table )
        return ERROR_INVALID_PARAMETER;
 
    if( (col==0) || (col>tv->num_cols) )
        return ERROR_INVALID_PARAMETER;
 
    /* how many rows are there ? */
    if( row >= tv->table->row_count )
        return ERROR_NO_MORE_ITEMS;
 
    if( tv->columns[col-1].offset >= tv->row_size )
    {
        ERR("Stuffed up %d >= %d\n", tv->columns[col-1].offset, tv->row_size );
        ERR("%p %p\n", tv, tv->columns );
        return ERROR_FUNCTION_FAILED;
    }
 
    n = bytes_per_column( tv->db, &tv->columns[col - 1], LONG_STR_BYTES );
    if (n != 2 && n != 3 && n != 4)
    {
        ERR("oops! what is %d bytes per column?\n", n );
        return ERROR_FUNCTION_FAILED;
    }
 
    offset = tv->columns[col-1].offset;
    *val = read_table_int(tv->table->data, row, offset, n);
 
    /* TRACE("Data [%d][%d] = %d\n", row, col, *val ); */
 
    return ERROR_SUCCESS;
}

Referenced by compare_record(), get_stream_name(), msi_row_matches(), TABLE_set_int(), TABLE_set_row(), TABLE_set_string(), TransformView_drop_table(), and TransformView_fetch_int().

TABLE_fetch_stream()

static UINT TABLE_fetch_stream ( struct tagMSIVIEW *  view, UINT  row, UINT  col, IStream **  stm  )

static

Definition at line 1132 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    UINT r;
    WCHAR *name;
 
    if( !view->ops->fetch_int )
        return ERROR_INVALID_PARAMETER;
 
    r = get_stream_name( tv, row, &name );
    if (r != ERROR_SUCCESS)
    {
        ERR("fetching stream, error = %u\n", r);
        return r;
    }
 
    r = msi_get_stream( tv->db, name, stm );
    if (r != ERROR_SUCCESS)
        ERR("fetching stream %s, error = %u\n", debugstr_w(name), r);
 
    msi_free( name );
    return r;
}

Referenced by TransformView_fetch_stream().

table_get_column_info()

static UINT table_get_column_info ( MSIDATABASE *  db, LPCWSTR  name, MSICOLUMNINFO **  pcols, UINT *  pcount  )

static

Definition at line 540 of file table.c.

{
    UINT r, column_count = 0;
    MSICOLUMNINFO *columns;
 
    /* get the number of columns in this table */
    column_count = 0;
    r = get_tablecolumns( db, name, NULL, &column_count );
    if (r != ERROR_SUCCESS)
        return r;
 
    *pcount = column_count;
 
    /* if there are no columns, there's no table */
    if (!column_count)
        return ERROR_INVALID_PARAMETER;
 
    TRACE("table %s found\n", debugstr_w(name));
 
    columns = msi_alloc( column_count * sizeof(MSICOLUMNINFO) );
    if (!columns)
        return ERROR_FUNCTION_FAILED;
 
    r = get_tablecolumns( db, name, columns, &column_count );
    if (r != ERROR_SUCCESS)
    {
        msi_free( columns );
        return ERROR_FUNCTION_FAILED;
    }
    *pcols = columns;
    return r;
}

Referenced by get_table(), and msi_update_table_columns().

TABLE_get_column_info()

static UINT TABLE_get_column_info ( struct tagMSIVIEW *  view, UINT  n, LPCWSTR *  name, UINT *  type, BOOL *  temporary, LPCWSTR *  table_name  )

static

Definition at line 1568 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
 
    TRACE("%p %d %p %p\n", tv, n, name, type );
 
    if( ( n == 0 ) || ( n > tv->num_cols ) )
        return ERROR_INVALID_PARAMETER;
 
    if( name )
    {
        *name = tv->columns[n-1].colname;
        if( !*name )
            return ERROR_FUNCTION_FAILED;
    }
 
    if( table_name )
    {
        *table_name = tv->columns[n-1].tablename;
        if( !*table_name )
            return ERROR_FUNCTION_FAILED;
    }
 
    if( type )
        *type = tv->columns[n-1].type;
 
    if( temporary )
        *temporary = (tv->columns[n-1].type & MSITYPE_TEMPORARY) != 0;
 
    return ERROR_SUCCESS;
}

Referenced by TransformView_get_column_info().

TABLE_get_dimensions()

static UINT TABLE_get_dimensions ( struct tagMSIVIEW *  view, UINT *  rows, UINT *  cols  )

static

Definition at line 1550 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
 
    TRACE("%p %p %p\n", view, rows, cols );
 
    if( cols )
        *cols = tv->num_cols;
    if( rows )
    {
        if( !tv->table )
            return ERROR_INVALID_PARAMETER;
        *rows = tv->table->row_count;
    }
 
    return ERROR_SUCCESS;
}

Referenced by TABLE_delete_row(), and TransformView_get_dimensions().

TABLE_get_row()

static UINT TABLE_get_row ( struct tagMSIVIEW *  view, UINT  row, MSIRECORD **  rec  )

static

Definition at line 1278 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW *)view;
 
    if (!tv->table)
        return ERROR_INVALID_PARAMETER;
 
    return msi_view_get_row(tv->db, view, row, rec);
}

Referenced by msi_refresh_record().

TABLE_insert_row()

static UINT TABLE_insert_row ( struct tagMSIVIEW *  view, MSIRECORD *  rec, UINT  row, BOOL  temporary  )

static

Definition at line 1706 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    UINT i, r;
 
    TRACE("%p %p %s\n", tv, rec, temporary ? "TRUE" : "FALSE" );
 
    /* check that the key is unique - can we find a matching row? */
    r = table_validate_new( tv, rec, NULL );
    if( r != ERROR_SUCCESS )
        return ERROR_FUNCTION_FAILED;
 
    if (row == -1)
        row = find_insert_index( tv, rec );
 
    r = table_create_new_row( view, &row, temporary );
    TRACE("insert_row returned %08x\n", r);
    if( r != ERROR_SUCCESS )
        return r;
 
    /* shift the rows to make room for the new row */
    for (i = tv->table->row_count - 1; i > row; i--)
    {
        memmove(&(tv->table->data[i][0]),
                &(tv->table->data[i - 1][0]), tv->row_size);
        tv->table->data_persistent[i] = tv->table->data_persistent[i - 1];
    }
 
    /* Re-set the persistence flag */
    tv->table->data_persistent[row] = !temporary;
    return TABLE_set_row( view, row, rec, (1<<tv->num_cols) - 1 );
}

Referenced by msi_table_assign(), TABLE_add_column(), and TABLE_modify().

TABLE_modify()

static UINT TABLE_modify ( struct tagMSIVIEW *  view, MSIMODIFY  eModifyMode, MSIRECORD *  rec, UINT  row  )

static

Definition at line 1838 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    UINT r, frow, column;
 
    TRACE("%p %d %p\n", view, eModifyMode, rec );
 
    switch (eModifyMode)
    {
    case MSIMODIFY_DELETE:
        r = TABLE_delete_row( view, row );
        break;
    case MSIMODIFY_VALIDATE_NEW:
        r = table_validate_new( tv, rec, &column );
        if (r != ERROR_SUCCESS)
        {
            tv->view.error = MSIDBERROR_DUPLICATEKEY;
            tv->view.error_column = tv->columns[column].colname;
            r = ERROR_INVALID_DATA;
        }
        break;
 
    case MSIMODIFY_INSERT:
        r = table_validate_new( tv, rec, NULL );
        if (r != ERROR_SUCCESS)
            break;
        r = TABLE_insert_row( view, rec, -1, FALSE );
        break;
 
    case MSIMODIFY_INSERT_TEMPORARY:
        r = table_validate_new( tv, rec, NULL );
        if (r != ERROR_SUCCESS)
            break;
        r = TABLE_insert_row( view, rec, -1, TRUE );
        break;
 
    case MSIMODIFY_REFRESH:
        r = msi_refresh_record( view, rec, row );
        break;
 
    case MSIMODIFY_UPDATE:
        r = msi_table_update( view, rec, row );
        break;
 
    case MSIMODIFY_ASSIGN:
        r = msi_table_assign( view, rec );
        break;
 
    case MSIMODIFY_MERGE:
        /* check row that matches this record */
        r = msi_table_find_row( tv, rec, &frow, &column );
        if (r != ERROR_SUCCESS)
        {
            r = table_validate_new( tv, rec, NULL );
            if (r == ERROR_SUCCESS)
                r = TABLE_insert_row( view, rec, -1, FALSE );
        }
        break;
 
    case MSIMODIFY_REPLACE:
    case MSIMODIFY_VALIDATE:
    case MSIMODIFY_VALIDATE_FIELD:
    case MSIMODIFY_VALIDATE_DELETE:
        FIXME("%p %d %p - mode not implemented\n", view, eModifyMode, rec );
        r = ERROR_CALL_NOT_IMPLEMENTED;
        break;
 
    default:
        r = ERROR_INVALID_DATA;
    }
 
    return r;
}

TABLE_release()

static UINT TABLE_release ( struct tagMSIVIEW *  view )

static

Definition at line 1986 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    INT ref = tv->table->ref_count;
    UINT r;
    INT i;
 
    TRACE("%p %d\n", view, ref);
 
    ref = InterlockedDecrement(&tv->table->ref_count);
    if (ref == 0)
    {
        for (i = tv->table->col_count - 1; i >= 0; i--)
        {
            if (tv->table->colinfo[i].type & MSITYPE_TEMPORARY)
            {
                r = TABLE_remove_column(view, tv->table->colinfo[i].number);
                if (r != ERROR_SUCCESS)
                    break;
            }
            else
            {
                break;
            }
        }
 
        if (!tv->table->col_count)
        {
            list_remove(&tv->table->entry);
            free_table(tv->table);
            TABLE_delete(view);
        }
    }
 
    return ref;
}

TABLE_remove_column()

static UINT TABLE_remove_column ( struct tagMSIVIEW *  view, UINT  number  )

static

Definition at line 1935 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    MSIRECORD *rec = NULL;
    MSIVIEW *columns = NULL;
    UINT row, r;
 
    if (tv->table->col_count != number)
        return ERROR_BAD_QUERY_SYNTAX;
 
    if (tv->table->colinfo[number-1].type & MSITYPE_TEMPORARY)
    {
        UINT size = tv->table->colinfo[number-1].offset;
        tv->table->col_count--;
        tv->table->colinfo = msi_realloc( tv->table->colinfo, sizeof(*tv->table->colinfo) * tv->table->col_count );
 
        for (row = 0; row < tv->table->row_count; row++)
            tv->table->data[row] = msi_realloc( tv->table->data[row], size );
        return ERROR_SUCCESS;
    }
 
    rec = MSI_CreateRecord(2);
    if (!rec)
        return ERROR_OUTOFMEMORY;
 
    MSI_RecordSetStringW(rec, 1, tv->name);
    MSI_RecordSetInteger(rec, 2, number);
 
    r = TABLE_CreateView(tv->db, L"_Columns", &columns);
    if (r != ERROR_SUCCESS)
    {
        msiobj_release(&rec->hdr);
        return r;
    }
 
    r = msi_table_find_row((MSITABLEVIEW *)columns, rec, &row, NULL);
    if (r != ERROR_SUCCESS)
        goto done;
 
    r = TABLE_delete_row(columns, row);
    if (r != ERROR_SUCCESS)
        goto done;
 
    msi_update_table_columns(tv->db, tv->name);
 
done:
    msiobj_release(&rec->hdr);
    columns->ops->delete(columns);
    return r;
}

Referenced by msi_table_apply_transform(), TABLE_drop(), and TABLE_release().

table_set_bytes()

static UINT table_set_bytes ( MSITABLEVIEW *  tv, UINT  row, UINT  col, UINT  val  )

static

Definition at line 1157 of file table.c.

{
    UINT offset, n, i;
 
    if( !tv->table )
        return ERROR_INVALID_PARAMETER;
 
    if( (col==0) || (col>tv->num_cols) )
        return ERROR_INVALID_PARAMETER;
 
    if( row >= tv->table->row_count )
        return ERROR_INVALID_PARAMETER;
 
    if( tv->columns[col-1].offset >= tv->row_size )
    {
        ERR("Stuffed up %d >= %d\n", tv->columns[col-1].offset, tv->row_size );
        ERR("%p %p\n", tv, tv->columns );
        return ERROR_FUNCTION_FAILED;
    }
 
    msi_free( tv->columns[col-1].hash_table );
    tv->columns[col-1].hash_table = NULL;
 
    n = bytes_per_column( tv->db, &tv->columns[col - 1], LONG_STR_BYTES );
    if ( n != 2 && n != 3 && n != 4 )
    {
        ERR("oops! what is %d bytes per column?\n", n );
        return ERROR_FUNCTION_FAILED;
    }
 
    offset = tv->columns[col-1].offset;
    for ( i = 0; i < n; i++ )
        tv->table->data[row][offset + i] = (val >> i * 8) & 0xff;
 
    return ERROR_SUCCESS;
}

Referenced by TABLE_set_int(), TABLE_set_row(), and TABLE_set_string().

TABLE_set_int()

static UINT TABLE_set_int ( MSIVIEW *  view, UINT  row, UINT  col, int  val  )

static

Definition at line 1214 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW *)view;
    UINT r, table_int;
 
    TRACE("row %u, col %u, val %d.\n", row, col, val);
 
    if ((r = int_to_table_storage( tv, col, val, &table_int )))
        return r;
 
    if (tv->columns[col-1].type & MSITYPE_KEY)
    {
        UINT key;
 
        if ((r = TABLE_fetch_int( view, row, col, &key )))
            return r;
        if (key != table_int)
        {
            ERR("Cannot modify primary key %s.%s.\n",
                debugstr_w(tv->table->name), debugstr_w(tv->columns[col-1].colname));
            return ERROR_FUNCTION_FAILED;
        }
    }
 
    return table_set_bytes( tv, row, col, table_int );
}

TABLE_set_row()

static UINT TABLE_set_row ( struct tagMSIVIEW *  view, UINT  row, MSIRECORD *  rec, UINT  mask  )

static

Definition at line 1388 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    UINT i, val, r = ERROR_SUCCESS;
 
    if ( !tv->table )
        return ERROR_INVALID_PARAMETER;
 
    /* test if any of the mask bits are invalid */
    if ( mask >= (1<<tv->num_cols) )
        return ERROR_INVALID_PARAMETER;
 
    for ( i = 0; i < tv->num_cols; i++ )
    {
        BOOL persistent;
 
        /* only update the fields specified in the mask */
        if ( !(mask&(1<<i)) )
            continue;
 
        persistent = (tv->table->persistent != MSICONDITION_FALSE) &&
                     (tv->table->data_persistent[row]);
        /* FIXME: should we allow updating keys? */
 
        val = 0;
        if ( !MSI_RecordIsNull( rec, i + 1 ) )
        {
            r = get_table_value_from_record (tv, rec, i + 1, &val);
            if ( MSITYPE_IS_BINARY(tv->columns[ i ].type) )
            {
                IStream *stm;
                LPWSTR stname;
 
                if ( r != ERROR_SUCCESS )
                    return ERROR_FUNCTION_FAILED;
 
                r = MSI_RecordGetIStream( rec, i + 1, &stm );
                if ( r != ERROR_SUCCESS )
                    return r;
 
                r = get_stream_name( tv, row, &stname );
                if ( r != ERROR_SUCCESS )
                {
                    IStream_Release( stm );
                    return r;
                }
 
                r = add_stream( tv->db, stname, stm );
                IStream_Release( stm );
                msi_free ( stname );
 
                if ( r != ERROR_SUCCESS )
                    return r;
            }
            else if ( tv->columns[i].type & MSITYPE_STRING )
            {
                UINT x;
 
                if ( r != ERROR_SUCCESS )
                {
                    int len;
                    const WCHAR *sval = msi_record_get_string( rec, i + 1, &len );
                    val = msi_add_string( tv->db->strings, sval, len, persistent );
                }
                else
                {
                    TABLE_fetch_int(&tv->view, row, i + 1, &x);
                    if (val == x)
                        continue;
                }
            }
            else
            {
                if ( r != ERROR_SUCCESS )
                    return ERROR_FUNCTION_FAILED;
            }
        }
 
        r = table_set_bytes( tv, row, i+1, val );
        if ( r != ERROR_SUCCESS )
            break;
    }
    return r;
}

Referenced by msi_table_assign(), msi_table_update(), and TABLE_insert_row().

TABLE_set_stream()

static UINT TABLE_set_stream ( MSIVIEW *  view, UINT  row, UINT  col, IStream *  stream  )

static

Definition at line 1340 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW *)view;
    WCHAR *name;
    UINT r;
 
    TRACE("row %u, col %u, stream %p.\n", row, col, stream);
 
    if ((r = get_stream_name( tv, row - 1, &name )))
        return r;
 
    r = add_stream( tv->db, name, stream );
    msi_free( name );
    return r;
}

TABLE_set_string()

static UINT TABLE_set_string ( MSIVIEW *  view, UINT  row, UINT  col, const WCHAR *  val, int  len  )

static

Definition at line 1241 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW *)view;
    BOOL persistent;
    UINT id, r;
 
    TRACE("row %u, col %u, val %s.\n", row, col, debugstr_wn(val, len));
 
    persistent = (tv->table->persistent != MSICONDITION_FALSE)
                  && tv->table->data_persistent[row];
 
    if (val)
    {
        r = msi_string2id( tv->db->strings, val, len, &id );
        if (r != ERROR_SUCCESS)
            id = msi_add_string( tv->db->strings, val, len, persistent );
    }
    else
        id = 0;
 
    if (tv->columns[col-1].type & MSITYPE_KEY)
    {
        UINT key;
 
        if ((r = TABLE_fetch_int( view, row, col, &key )))
            return r;
        if (key != id)
        {
            ERR("Cannot modify primary key %s.%s.\n",
                debugstr_w(tv->table->name), debugstr_w(tv->columns[col-1].colname));
            return ERROR_FUNCTION_FAILED;
        }
    }
 
    return table_set_bytes( tv, row, col, id );
}

table_validate_new()

static UINT table_validate_new ( MSITABLEVIEW *  tv, MSIRECORD *  rec, UINT *  column  )

static

Definition at line 1604 of file table.c.

{
    UINT r, row, i;
 
    /* check there are no null values where they're not allowed */
    for( i = 0; i < tv->num_cols; i++ )
    {
        if ( tv->columns[i].type & MSITYPE_NULLABLE )
            continue;
 
        if ( MSITYPE_IS_BINARY(tv->columns[i].type) )
            TRACE("skipping binary column\n");
        else if ( tv->columns[i].type & MSITYPE_STRING )
        {
            int len;
            const WCHAR *str = msi_record_get_string( rec, i+1, &len );
 
            if (!str || (!str[0] && !len))
            {
                if (column) *column = i;
                return ERROR_INVALID_DATA;
            }
        }
        else
        {
            UINT n;
 
            n = MSI_RecordGetInteger( rec, i+1 );
            if (n == MSI_NULL_INTEGER)
            {
                if (column) *column = i;
                return ERROR_INVALID_DATA;
            }
        }
    }
 
    /* check there are no duplicate keys */
    r = msi_table_find_row( tv, rec, &row, column );
    if (r == ERROR_SUCCESS)
        return ERROR_FUNCTION_FAILED;
 
    return ERROR_SUCCESS;
}

Referenced by TABLE_insert_row(), and TABLE_modify().

TransformView_add_column()

static UINT TransformView_add_column ( MSITABLEVIEW *  tv, MSIRECORD *  rec  )

static

Definition at line 2501 of file table.c.

{
    static const WCHAR query_pfx[] =
        L"INSERT INTO `_TransformView` (`new`, `Table`, `Current`, `Column`, `Data`) VALUES (1, '";
 
    WCHAR buf[256], *query = buf;
    UINT i, p, r, qlen;
    DWORD len;
    MSIQUERY *q;
 
    qlen = p = wcslen( query_pfx );
    for (i = 1; i <= 4; i++)
    {
        r = MSI_RecordGetStringW( rec, i, NULL, &len );
        if (r != ERROR_SUCCESS)
            return r;
        qlen += len + 3; /* strlen( "','" ) */
    }
 
    if (qlen > ARRAY_SIZE(buf))
    {
        query = msi_alloc( len * sizeof(WCHAR) );
        qlen = len;
        if (!query)
            return ERROR_OUTOFMEMORY;
    }
 
    memcpy( query, query_pfx, p * sizeof(WCHAR) );
    for (i = 1; i <= 4; i++)
    {
        len = qlen - p;
        MSI_RecordGetStringW( rec, i, query + p, &len );
        p += len;
        query[p++] = '\'';
        if (i != 4)
        {
            query[p++] = ',';
            query[p++] = '\'';
        }
    }
    query[p++] = ')';
    query[p++] = 0;
 
    r = MSI_DatabaseOpenViewW( tv->db, query, &q );
    if (query != buf)
        msi_free( query );
    if (r != ERROR_SUCCESS)
        return r;
 
    r = MSI_ViewExecute( q, NULL );
    msiobj_release( &q->hdr );
    return r;
}

Referenced by TransformView_insert_row().

TransformView_close()

static UINT TransformView_close ( MSIVIEW *  view )

static

Definition at line 2719 of file table.c.

{
    return ERROR_SUCCESS;
}

TransformView_Create()

UINT TransformView_Create	(	MSIDATABASE *	db,
		string_table *	st,
		LPCWSTR	name,
		MSIVIEW **	view
	)

Definition at line 2766 of file table.c.

{
    static const WCHAR query_pfx[] = L"SELECT `Column`, `Data`, `Current` FROM `_TransformView` WHERE `Table`='";
    static const WCHAR query_sfx[] = L"' AND `Row` IS NULL AND `Current` IS NOT NULL AND `new` = 1";
 
    WCHAR buf[256], *query = buf;
    UINT r, len, name_len, size, add_col;
    MSICOLUMNINFO *colinfo;
    MSITABLEVIEW *tv;
    MSIRECORD *rec;
    MSIQUERY *q;
 
    name_len = wcslen( name );
 
    r = TABLE_CreateView( db, name, view );
    if (r == ERROR_INVALID_PARAMETER)
    {
        /* table does not exist */
        size = FIELD_OFFSET( MSITABLEVIEW, name[name_len + 1] );
        tv = msi_alloc_zero( size );
        if (!tv)
            return ERROR_OUTOFMEMORY;
 
        tv->db = db;
        memcpy( tv->name, name, name_len * sizeof(WCHAR) );
        *view = (MSIVIEW*)tv;
    }
    else if (r != ERROR_SUCCESS)
    {
        return r;
    }
    else
    {
        tv = (MSITABLEVIEW*)*view;
    }
 
    tv->view.ops = &transform_view_ops;
 
    len = ARRAY_SIZE(query_pfx) + name_len + ARRAY_SIZE(query_sfx) - 1;
    if (len > ARRAY_SIZE(buf))
    {
        query = msi_alloc( len * sizeof(WCHAR) );
        if (!query)
        {
            msi_free( tv );
            return ERROR_OUTOFMEMORY;
        }
    }
    memcpy( query, query_pfx, ARRAY_SIZE(query_pfx) * sizeof(WCHAR) );
    len = ARRAY_SIZE(query_pfx) - 1;
    memcpy( query + len, name, name_len * sizeof(WCHAR) );
    len += name_len;
    memcpy( query + len, query_sfx, ARRAY_SIZE(query_sfx) * sizeof(WCHAR) );
 
    r = MSI_DatabaseOpenViewW( tv->db, query, &q );
    if (query != buf)
        msi_free( query );
    if (r != ERROR_SUCCESS)
    {
        msi_free( tv );
        return r;
    }
 
    r = MSI_ViewExecute( q, NULL );
    if (r != ERROR_SUCCESS)
    {
        msi_free( tv );
        return r;
    }
 
    r = q->view->ops->get_dimensions( q->view, &add_col, NULL );
    if (r != ERROR_SUCCESS)
    {
        MSI_ViewClose( q );
        msiobj_release( &q->hdr );
        msi_free( tv );
        return r;
    }
    if (!add_col)
    {
        MSI_ViewClose( q );
        msiobj_release( &q->hdr );
        return ERROR_SUCCESS;
    }
 
    colinfo = msi_alloc_zero( (add_col + tv->num_cols) * sizeof(*colinfo) );
    if (!colinfo)
    {
        MSI_ViewClose( q );
        msiobj_release( &q->hdr );
        msi_free( tv );
        return r;
    }
 
    while (MSI_ViewFetch( q, &rec ) == ERROR_SUCCESS)
    {
        int name_len;
        const WCHAR *name = msi_record_get_string( rec, 1, &name_len );
        const WCHAR *type = msi_record_get_string( rec, 2, NULL );
        UINT name_id, idx;
 
        idx = _wtoi( msi_record_get_string(rec, 3, NULL) );
        colinfo[idx - 1].number = idx;
        colinfo[idx - 1].type = _wtoi( type );
 
        r = msi_string2id( st, name, name_len, &name_id );
        if (r == ERROR_SUCCESS)
            colinfo[idx - 1].colname = msi_string_lookup( st, name_id, NULL );
        else
            ERR( "column name %s is not defined in strings table\n", wine_dbgstr_w(name) );
        msiobj_release( &rec->hdr );
    }
    MSI_ViewClose( q );
    msiobj_release( &q->hdr );
 
    memcpy( colinfo, tv->columns, tv->num_cols * sizeof(*colinfo) );
    tv->columns = colinfo;
    tv->num_cols += add_col;
    return ERROR_SUCCESS;
}

Referenced by msi_table_load_transform().

TransformView_create_table()

static UINT TransformView_create_table ( MSITABLEVIEW *  tv, MSIRECORD *  rec  )

static

Definition at line 2466 of file table.c.

{
    static const WCHAR query_fmt[] =
        L"INSERT INTO `_TransformView` (`Table`, `Column`, `new`) VALUES ('%s', 'CREATE', 1)";
 
    WCHAR buf[256], *query = buf;
    const WCHAR *name;
    MSIQUERY *q;
    int len;
    UINT r;
 
    name = msi_record_get_string( rec, 1, &len );
    if (!name)
        return ERROR_INSTALL_TRANSFORM_FAILURE;
 
    len = _snwprintf( NULL, 0, query_fmt, name ) + 1;
    if (len > ARRAY_SIZE(buf))
    {
        query = msi_alloc( len * sizeof(WCHAR) );
        if (!query)
            return ERROR_OUTOFMEMORY;
    }
    swprintf( query, len, query_fmt, name );
 
    r = MSI_DatabaseOpenViewW( tv->db, query, &q );
    if (query != buf)
        msi_free( query );
    if (r != ERROR_SUCCESS)
        return r;
 
    r = MSI_ViewExecute( q, NULL );
    msiobj_release( &q->hdr );
    return r;
}

Referenced by TransformView_insert_row().

TransformView_delete()

static UINT TransformView_delete ( MSIVIEW *  view )

static

Definition at line 2735 of file table.c.

{
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    if (!tv->table || tv->columns != tv->table->colinfo)
        msi_free( tv->columns );
    return TABLE_delete( view );
}

TransformView_delete_row()

static UINT TransformView_delete_row ( MSIVIEW *  view, UINT  row  )

static

Definition at line 2648 of file table.c.

{
    static const WCHAR query_pfx[] = L"INSERT INTO `_TransformView` ( `new`, `Table`, `Column`, `Row`) VALUES ( 1, '";
    static const WCHAR query_column[] = L"', 'DELETE', '";
    static const WCHAR query_sfx[] = L"')";
 
    MSITABLEVIEW *tv = (MSITABLEVIEW*)view;
    WCHAR *key, buf[256], *query = buf;
    UINT r, len, name_len, key_len;
    MSIRECORD *rec;
    MSIQUERY *q;
 
    if (!wcscmp( tv->name, L"_Columns" ))
    {
        ERR("trying to remove column\n");
        return ERROR_INSTALL_TRANSFORM_FAILURE;
    }
 
    if (!wcscmp( tv->name, L"_Tables" ))
        return TransformView_drop_table( tv, row );
 
    r = msi_view_get_row( tv->db, view, row, &rec );
    if (r != ERROR_SUCCESS)
        return r;
 
    key = create_key_string( tv, rec );
    msiobj_release( &rec->hdr );
    if (!key)
        return ERROR_OUTOFMEMORY;
 
    name_len = wcslen( tv->name );
    key_len = wcslen( key );
    len = ARRAY_SIZE(query_pfx) + name_len + ARRAY_SIZE(query_column) + key_len + ARRAY_SIZE(query_sfx) - 2;
    if (len > ARRAY_SIZE(buf))
    {
        query = msi_alloc( len * sizeof(WCHAR) );
        if (!query)
        {
            msi_free( tv );
            msi_free( key );
            return ERROR_OUTOFMEMORY;
        }
    }
 
    memcpy( query, query_pfx, ARRAY_SIZE(query_pfx) * sizeof(WCHAR) );
    len = ARRAY_SIZE(query_pfx) - 1;
    memcpy( query + len, tv->name, name_len * sizeof(WCHAR) );
    len += name_len;
    memcpy( query + len, query_column, ARRAY_SIZE(query_column) * sizeof(WCHAR) );
    len += ARRAY_SIZE(query_column) - 1;
    memcpy( query + len, key, key_len * sizeof(WCHAR) );
    len += key_len;
    memcpy( query + len, query_sfx, ARRAY_SIZE(query_sfx) * sizeof(WCHAR) );
    msi_free( key );
 
    r = MSI_DatabaseOpenViewW( tv->db, query, &q );
    if (query != buf)
        msi_free( query );
    if (r != ERROR_SUCCESS)
        return r;
 
    r = MSI_ViewExecute( q, NULL );
    msiobj_release( &q->hdr );
    return r;
}

TransformView_drop_table()

static UINT TransformView_drop_table ( MSITABLEVIEW *  tv, UINT  row  )

static

Definition at line 2604 of file table.c.

{
    static const WCHAR query_pfx[] = L"INSERT INTO `