query.h File Reference

#include <stdarg.h>
#include "windef.h"
#include "winbase.h"
#include "objbase.h"
#include "objidl.h"
#include "msi.h"
#include "msiquery.h"
#include "msipriv.h"
#include "wine/list.h"

Include dependency graph for query.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	sql_str
struct	complex_expr
union	ext_column
struct	expr
struct	SQL_input

Macros
#define	OP_EQ   1
#define	OP_AND   2
#define	OP_OR   3
#define	OP_GT   4
#define	OP_LT   5
#define	OP_LE   6
#define	OP_GE   7
#define	OP_NE   8
#define	OP_ISNULL   9
#define	OP_NOTNULL   10
#define	EXPR_COMPLEX   1
#define	EXPR_COLUMN   2
#define	EXPR_COL_NUMBER   3
#define	EXPR_IVAL   4
#define	EXPR_SVAL   5
#define	EXPR_UVAL   6
#define	EXPR_STRCMP   7
#define	EXPR_WILDCARD   9
#define	EXPR_COL_NUMBER_STRING   10
#define	EXPR_COL_NUMBER32   11
#define	EXPR_UNARY   12

Functions
UINT	MSI_ParseSQL (MSIDATABASE *db, LPCWSTR command, MSIVIEW **phview, struct list *mem)
UINT	TABLE_CreateView (MSIDATABASE *db, LPCWSTR name, MSIVIEW **view)
UINT	SELECT_CreateView (MSIDATABASE *db, MSIVIEW **view, MSIVIEW *table, const column_info *columns)
UINT	DISTINCT_CreateView (MSIDATABASE *db, MSIVIEW **view, MSIVIEW *table)
UINT	ORDER_CreateView (MSIDATABASE *db, MSIVIEW **view, MSIVIEW *table, column_info *columns)
UINT	WHERE_CreateView (MSIDATABASE *db, MSIVIEW **view, LPWSTR tables, struct expr *cond)
UINT	CREATE_CreateView (MSIDATABASE *db, MSIVIEW **view, LPCWSTR table, column_info *col_info, BOOL hold)
UINT	INSERT_CreateView (MSIDATABASE *db, MSIVIEW **view, LPCWSTR table, column_info *columns, column_info *values, BOOL temp)
UINT	UPDATE_CreateView (MSIDATABASE *db, MSIVIEW **view, LPWSTR table, column_info *list, struct expr *expr)
UINT	DELETE_CreateView (MSIDATABASE *db, MSIVIEW **view, MSIVIEW *table)
UINT	ALTER_CreateView (MSIDATABASE *db, MSIVIEW **view, LPCWSTR name, column_info *colinfo, int hold)
UINT	STREAMS_CreateView (MSIDATABASE *db, MSIVIEW **view)
UINT	STORAGES_CreateView (MSIDATABASE *db, MSIVIEW **view)
UINT	DROP_CreateView (MSIDATABASE *db, MSIVIEW **view, LPCWSTR name)
int	sqliteGetToken (const WCHAR *z, int *tokenType, int *skip)
MSIRECORD *	msi_query_merge_record (UINT fields, const column_info *vl, MSIRECORD *rec)
UINT	msi_create_table (MSIDATABASE *db, LPCWSTR name, column_info *col_info, MSICONDITION persistent, BOOL hold)
UINT	msi_select_update (MSIVIEW *view, MSIRECORD *rec, UINT row)
UINT	msi_view_refresh_row (MSIDATABASE *db, MSIVIEW *view, UINT row, MSIRECORD *rec)

Macro Definition Documentation

EXPR_COL_NUMBER

#define EXPR_COL_NUMBER   3

Definition at line 49 of file query.h.

EXPR_COL_NUMBER32

#define EXPR_COL_NUMBER32   11

Definition at line 56 of file query.h.

EXPR_COL_NUMBER_STRING

#define EXPR_COL_NUMBER_STRING   10

Definition at line 55 of file query.h.

EXPR_COLUMN

#define EXPR_COLUMN   2

Definition at line 48 of file query.h.

EXPR_COMPLEX

#define EXPR_COMPLEX   1

Definition at line 47 of file query.h.

EXPR_IVAL

#define EXPR_IVAL   4

Definition at line 50 of file query.h.

EXPR_STRCMP

#define EXPR_STRCMP   7

Definition at line 53 of file query.h.

EXPR_SVAL

#define EXPR_SVAL   5

Definition at line 51 of file query.h.

EXPR_UNARY

#define EXPR_UNARY   12

Definition at line 57 of file query.h.

EXPR_UVAL

#define EXPR_UVAL   6

Definition at line 52 of file query.h.

EXPR_WILDCARD

#define EXPR_WILDCARD   9

Definition at line 54 of file query.h.

OP_AND

#define OP_AND   2

Definition at line 37 of file query.h.

OP_EQ

#define OP_EQ   1

Definition at line 36 of file query.h.

OP_GE

#define OP_GE   7

Definition at line 42 of file query.h.

OP_GT

#define OP_GT   4

Definition at line 39 of file query.h.

OP_ISNULL

#define OP_ISNULL   9

Definition at line 44 of file query.h.

OP_LE

#define OP_LE   6

Definition at line 41 of file query.h.

OP_LT

#define OP_LT   5

Definition at line 40 of file query.h.

OP_NE

#define OP_NE   8

Definition at line 43 of file query.h.

OP_NOTNULL

#define OP_NOTNULL   10

Definition at line 45 of file query.h.

OP_OR

#define OP_OR   3

Definition at line 38 of file query.h.

Function Documentation

ALTER_CreateView()

UINT ALTER_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view,
		LPCWSTR	name,
		column_info *	colinfo,
		int	hold
	)

Definition at line 160 of file alter.c.

{
    struct alter_view *av;
    UINT r;
 
    TRACE("%p %p %s %d\n", view, colinfo, debugstr_w(name), hold );
 
    av = calloc( 1, sizeof *av );
    if( !av )
        return ERROR_FUNCTION_FAILED;
 
    r = TABLE_CreateView( db, name, &av->table );
    if (r != ERROR_SUCCESS)
    {
        free( av );
        return r;
    }
 
    if (colinfo)
        colinfo->table = name;
 
    /* fill the structure */
    av->view.ops = &alter_ops;
    av->db = db;
    av->hold = hold;
    av->colinfo = colinfo;
 
    *view = &av->view;
 
    return ERROR_SUCCESS;
}

CREATE_CreateView()

UINT CREATE_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view,
		LPCWSTR	table,
		column_info *	col_info,
		BOOL	hold
	)

Definition at line 160 of file create.c.

{
    struct create_view *cv = NULL;
    UINT r;
    column_info *col;
    BOOL temp = TRUE;
    BOOL tempprim = FALSE;
 
    TRACE("%p\n", cv );
 
    r = check_columns( col_info );
    if( r != ERROR_SUCCESS )
        return r;
 
    cv = calloc( 1, sizeof *cv );
    if( !cv )
        return ERROR_FUNCTION_FAILED;
 
    for( col = col_info; col; col = col->next )
    {
        if (!col->table)
            col->table = table;
 
        if( !(col->type & MSITYPE_TEMPORARY) )
            temp = FALSE;
        else if ( col->type & MSITYPE_KEY )
            tempprim = TRUE;
    }
 
    if ( !temp && tempprim )
    {
        free( cv );
        return ERROR_FUNCTION_FAILED;
    }
 
    /* fill the structure */
    cv->view.ops = &create_ops;
    msiobj_addref( &db->hdr );
    cv->db = db;
    cv->name = table;
    cv->col_info = col_info;
    cv->bIsTemp = temp;
    cv->hold = hold;
    *view = (MSIVIEW*) cv;
 
    return ERROR_SUCCESS;
}

DELETE_CreateView()

UINT DELETE_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view,
		MSIVIEW *	table
	)

Definition at line 190 of file delete.c.

{
    struct delete_view *dv = NULL;
 
    TRACE("%p\n", dv );
 
    dv = calloc( 1, sizeof *dv );
    if( !dv )
        return ERROR_FUNCTION_FAILED;
 
    /* fill the structure */
    dv->view.ops = &delete_ops;
    dv->db = db;
    dv->table = table;
 
    *view = &dv->view;
 
    return ERROR_SUCCESS;
}

DISTINCT_CreateView()

UINT DISTINCT_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view,
		MSIVIEW *	table
	)

Definition at line 273 of file distinct.c.

{
    struct distinct_view *dv = NULL;
    UINT count = 0, r;
 
    TRACE("%p\n", dv );
 
    r = table->ops->get_dimensions( table, NULL, &count );
    if( r != ERROR_SUCCESS )
    {
        ERR("can't get table dimensions\n");
        return r;
    }
 
    dv = calloc( 1, sizeof *dv );
    if( !dv )
        return ERROR_FUNCTION_FAILED;
 
    /* fill the structure */
    dv->view.ops = &distinct_ops;
    msiobj_addref( &db->hdr );
    dv->db = db;
    dv->table = table;
    dv->translation = NULL;
    dv->row_count = 0;
    *view = (MSIVIEW*) dv;
 
    return ERROR_SUCCESS;
}

DROP_CreateView()

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

Definition at line 118 of file drop.c.

{
    struct drop_view *dv;
    UINT r;
 
    TRACE("%p %s\n", view, debugstr_w(name));
 
    dv = calloc(1, sizeof *dv);
    if(!dv)
        return ERROR_FUNCTION_FAILED;
 
    r = TABLE_CreateView(db, name, &dv->table);
    if (r != ERROR_SUCCESS)
    {
        free( dv );
        return r;
    }
 
    dv->view.ops = &drop_ops;
    dv->db = db;
 
    *view = (MSIVIEW *)dv;
 
    return ERROR_SUCCESS;
}

INSERT_CreateView()

UINT INSERT_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view,
		LPCWSTR	table,
		column_info *	columns,
		column_info *	values,
		BOOL	temp
	)

Definition at line 351 of file insert.c.

{
    struct insert_view *iv = NULL;
    UINT r;
    MSIVIEW *tv = NULL, *sv = NULL;
 
    TRACE("%p\n", iv );
 
    /* there should be one value for each column */
    if ( count_column_info( columns ) != count_column_info(values) )
        return ERROR_BAD_QUERY_SYNTAX;
 
    r = TABLE_CreateView( db, table, &tv );
    if( r != ERROR_SUCCESS )
        return r;
 
    r = SELECT_CreateView( db, &sv, tv, columns );
    if( r != ERROR_SUCCESS )
    {
        if( tv )
            tv->ops->delete( tv );
        return r;
    }
 
    iv = calloc( 1, sizeof *iv );
    if( !iv )
        return ERROR_FUNCTION_FAILED;
 
    /* fill the structure */
    iv->view.ops = &insert_ops;
    msiobj_addref( &db->hdr );
    iv->table = tv;
    iv->db = db;
    iv->vals = values;
    iv->bIsTemp = temp;
    iv->sv = sv;
    *view = (MSIVIEW*) iv;
 
    return ERROR_SUCCESS;
}

msi_create_table()

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

Definition at line 707 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 = malloc( sizeof(MSITABLE) + wcslen(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 = malloc( table->col_count * sizeof(*table->colinfo) );
    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_ParseSQL()

UINT MSI_ParseSQL	(	MSIDATABASE *	db,
		LPCWSTR	command,
		MSIVIEW **	phview,
		struct list *	mem
	)

Referenced by MSI_DatabaseOpenViewW().

msi_query_merge_record()

MSIRECORD * msi_query_merge_record	(	UINT	fields,
		const column_info *	vl,
		MSIRECORD *	rec
	)

Definition at line 66 of file insert.c.

{
    MSIRECORD *merged;
    DWORD wildcard_count = 1, i;
 
    merged = MSI_CreateRecord( fields );
    for( i=1; i <= fields; i++ )
    {
        if( !vl )
        {
            TRACE("Not enough elements in the list to insert\n");
            goto err;
        }
        switch( vl->val->type )
        {
        case EXPR_SVAL:
            TRACE( "field %lu -> %s\n", i, debugstr_w(vl->val->u.sval) );
            MSI_RecordSetStringW( merged, i, vl->val->u.sval );
            break;
        case EXPR_IVAL:
            MSI_RecordSetInteger( merged, i, vl->val->u.ival );
            break;
        case EXPR_WILDCARD:
            if( !rec )
                goto err;
            MSI_RecordCopyField( rec, wildcard_count, merged, i );
            wildcard_count++;
            break;
        default:
            ERR("Unknown expression type %d\n", vl->val->type);
        }
        vl = vl->next;
    }
 
    return merged;
err:
    msiobj_release( &merged->hdr );
    return NULL;
}

Referenced by INSERT_execute(), and UPDATE_execute().

msi_select_update()

UINT msi_select_update	(	MSIVIEW *	view,
		MSIRECORD *	rec,
		UINT	row
	)

Definition at line 251 of file select.c.

{
    struct select_view *sv = (struct select_view *)view;
    UINT r, i, col, type, val;
    IStream *stream;
    LPCWSTR str;
 
    for (i = 0; i < sv->num_cols; i++)
    {
        col = sv->cols[i];
 
        r = SELECT_get_column_info(view, i + 1, NULL, &type, NULL, NULL);
        if (r != ERROR_SUCCESS)
        {
            ERR("Failed to get column information: %d\n", r);
            return r;
        }
 
        if (MSITYPE_IS_BINARY(type))
        {
            if (MSI_RecordGetIStream(rec, i + 1, &stream))
                return ERROR_FUNCTION_FAILED;
            r = sv->table->ops->set_stream(sv->table, row, col, stream);
            IStream_Release(stream);
        }
        else if (type & MSITYPE_STRING)
        {
            int len;
            str = msi_record_get_string(rec, i + 1, &len);
            r = sv->table->ops->set_string(sv->table, row, col, str, len);
        }
        else
        {
            val = MSI_RecordGetInteger(rec, i + 1);
            r = sv->table->ops->set_int(sv->table, row, col, val);
        }
 
        if (r != ERROR_SUCCESS)
        {
            ERR("Failed to modify record: %d\n", r);
            return r;
        }
    }
 
    return ERROR_SUCCESS;
}

Referenced by SELECT_modify(), and UPDATE_execute().

msi_view_refresh_row()

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

Definition at line 287 of file msiquery.c.

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

Referenced by msi_view_get_row(), and SELECT_modify().

ORDER_CreateView()

UINT ORDER_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view,
		MSIVIEW *	table,
		column_info *	columns
	)

SELECT_CreateView()

UINT SELECT_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view,
		MSIVIEW *	table,
		const column_info *	columns
	)

Definition at line 425 of file select.c.

{
    struct select_view *sv = NULL;
    UINT count = 0, r = ERROR_SUCCESS;
 
    TRACE("%p\n", sv );
 
    count = select_count_columns( columns );
 
    sv = calloc( 1, offsetof( struct select_view, cols[count] ) );
    if( !sv )
        return ERROR_FUNCTION_FAILED;
 
    /* fill the structure */
    sv->view.ops = &select_ops;
    sv->db = db;
    sv->table = table;
    sv->num_cols = 0;
    sv->max_cols = count;
 
    while( columns )
    {
        r = SELECT_AddColumn( sv, columns->column, columns->table );
        if( r )
            break;
        columns = columns->next;
    }
 
    if( r == ERROR_SUCCESS )
        *view = &sv->view;
    else
        free( sv );
 
    return r;
}

Referenced by INSERT_CreateView(), and UPDATE_CreateView().

sqliteGetToken()

int sqliteGetToken	(	const WCHAR *	z,
		int *	tokenType,
		int *	skip
	)

Definition at line 172 of file tokenize.c.

                                                             {
  int i;
 
  *skip = 0;
  switch( *z ){
    case ' ': case '\t': case '\n': case '\f':
      for(i=1; isSpace(z[i]); i++){}
      *tokenType = TK_SPACE;
      return i;
    case '-':
      if( z[1]==0 ) return -1;
      *tokenType = TK_MINUS;
      return 1;
    case '(':
      *tokenType = TK_LP;
      return 1;
    case ')':
      *tokenType = TK_RP;
      return 1;
    case '*':
      *tokenType = TK_STAR;
      return 1;
    case '=':
      *tokenType = TK_EQ;
      return 1;
    case '<':
      if( z[1]=='=' ){
        *tokenType = TK_LE;
        return 2;
      }else if( z[1]=='>' ){
        *tokenType = TK_NE;
        return 2;
      }else{
        *tokenType = TK_LT;
        return 1;
      }
    case '>':
      if( z[1]=='=' ){
        *tokenType = TK_GE;
        return 2;
      }else{
        *tokenType = TK_GT;
        return 1;
      }
    case '!':
      if( z[1]!='=' ){
        *tokenType = TK_ILLEGAL;
        return 2;
      }else{
        *tokenType = TK_NE;
        return 2;
      }
    case '?':
      *tokenType = TK_WILDCARD;
      return 1;
    case ',':
      *tokenType = TK_COMMA;
      return 1;
    case '`': case '\'': {
      int delim = z[0];
      for(i=1; z[i]; i++){
        if( z[i]==delim )
          break;
      }
      if( z[i] ) i++;
      if( delim == '`' )
        *tokenType = TK_ID;
      else
        *tokenType = TK_STRING;
      return i;
    }
    case '.':
      if( !isDigit(z[1]) ){
        *tokenType = TK_DOT;
        return 1;
      }
      /* Fall through */
    case '0': case '1': case '2': case '3': case '4':
    case '5': case '6': case '7': case '8': case '9':
      *tokenType = TK_INTEGER;
      for(i=1; isDigit(z[i]); i++){}
      return i;
    case '[':
      for(i=1; z[i] && z[i-1]!=']'; i++){}
      *tokenType = TK_ID;
      return i;
    default:
      if( !isIdChar[*z] ){
        break;
      }
      for(i=1; isIdChar[z[i]]; i++){}
      *tokenType = sqliteKeywordCode(z, i);
      if( *tokenType == TK_ID && z[i] == '`' ) *skip = 1;
      return i;
  }
  *tokenType = TK_ILLEGAL;
  return 1;
}

STORAGES_CreateView()

UINT STORAGES_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view
	)

Definition at line 515 of file storages.c.

{
    struct storages_view *sv;
    INT rows;
 
    TRACE("(%p, %p)\n", db, view);
 
    sv = calloc(1, sizeof(*sv));
    if (!sv)
        return ERROR_FUNCTION_FAILED;
 
    sv->view.ops = &storages_ops;
    sv->db = db;
 
    rows = add_storages_to_table(sv);
    if (rows < 0)
    {
        free(sv);
        return ERROR_FUNCTION_FAILED;
    }
    sv->num_rows = rows;
 
    *view = (MSIVIEW *)sv;
 
    return ERROR_SUCCESS;
}

Referenced by TABLE_CreateView().

STREAMS_CreateView()

UINT STREAMS_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view
	)

Definition at line 539 of file streams.c.

{
    struct streams_view *sv;
    UINT r;
 
    TRACE("(%p, %p)\n", db, view);
 
    r = load_streams( db );
    if (r != ERROR_SUCCESS)
        return r;
 
    if (!(sv = calloc( 1, sizeof(*sv) )))
        return ERROR_OUTOFMEMORY;
 
    sv->view.ops = &streams_ops;
    sv->num_cols = NUM_STREAMS_COLS;
    sv->db = db;
 
    *view = (MSIVIEW *)sv;
 
    return ERROR_SUCCESS;
}

Referenced by TABLE_CreateView().

TABLE_CreateView()

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

Definition at line 2191 of file table.c.

{
    struct table_view *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( struct table_view, name[lstrlenW( name ) + 1] );
    tv = calloc( 1, sz );
    if( !tv )
        return ERROR_FUNCTION_FAILED;
 
    r = get_table( db, name, &tv->table );
    if( r != ERROR_SUCCESS )
    {
        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 = 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(), TABLE_add_column(), TABLE_drop(), table_load_transform(), TABLE_remove_column(), TransformView_Create(), UPDATE_CreateView(), and WHERE_CreateView().

UPDATE_CreateView()

UINT UPDATE_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view,
		LPWSTR	table,
		column_info *	list,
		struct expr *	expr
	)

Definition at line 220 of file update.c.

{
    struct update_view *uv = NULL;
    UINT r;
    MSIVIEW *sv = NULL, *wv = NULL;
 
    TRACE("%p\n", uv );
 
    if (expr)
        r = WHERE_CreateView( db, &wv, table, expr );
    else
        r = TABLE_CreateView( db, table, &wv );
 
    if( r != ERROR_SUCCESS )
        return r;
 
    /* then select the columns we want */
    r = SELECT_CreateView( db, &sv, wv, columns );
    if( r != ERROR_SUCCESS )
    {
        wv->ops->delete( wv );
        return r;
    }
 
    uv = calloc( 1, sizeof *uv );
    if( !uv )
    {
        wv->ops->delete( wv );
        return ERROR_FUNCTION_FAILED;
    }
 
    /* fill the structure */
    uv->view.ops = &update_ops;
    msiobj_addref( &db->hdr );
    uv->db = db;
    uv->vals = columns;
    uv->wv = sv;
    *view = (MSIVIEW*) uv;
 
    return ERROR_SUCCESS;
}

WHERE_CreateView()

UINT WHERE_CreateView	(	MSIDATABASE *	db,
		MSIVIEW **	view,
		LPWSTR	tables,
		struct expr *	cond
	)

Definition at line 1225 of file where.c.

{
    MSIWHEREVIEW *wv = NULL;
    UINT r, valid = 0;
    WCHAR *ptr;
 
    TRACE("(%s)\n", debugstr_w(tables) );
 
    wv = calloc(1, sizeof *wv);
    if( !wv )
        return ERROR_FUNCTION_FAILED;
 
    /* fill the structure */
    wv->view.ops = &where_ops;
    msiobj_addref( &db->hdr );
    wv->db = db;
    wv->cond = cond;
 
    while (*tables)
    {
        struct join_table *table;
 
        if ((ptr = wcschr(tables, ' ')))
            *ptr = '\0';
 
        table = malloc(sizeof(*table));
        if (!table)
        {
            r = ERROR_OUTOFMEMORY;
            goto end;
        }
 
        r = TABLE_CreateView(db, tables, &table->view);
        if (r != ERROR_SUCCESS)
        {
            WARN("can't create table: %s\n", debugstr_w(tables));
            free(table);
            r = ERROR_BAD_QUERY_SYNTAX;
            goto end;
        }
 
        r = table->view->ops->get_dimensions(table->view, NULL,
                                             &table->col_count);
        if (r != ERROR_SUCCESS)
        {
            ERR("can't get table dimensions\n");
            table->view->ops->delete(table->view);
            free(table);
            goto end;
        }
 
        wv->col_count += table->col_count;
        table->table_index = wv->table_count++;
 
        table->next = wv->tables;
        wv->tables = table;
 
        if (!ptr)
            break;
 
        tables = ptr + 1;
    }
 
    if( cond )
    {
        r = WHERE_VerifyCondition( wv, cond, &valid );
        if( r != ERROR_SUCCESS )
            goto end;
        if( !valid ) {
            r = ERROR_FUNCTION_FAILED;
            goto end;
        }
    }
 
    *view = (MSIVIEW*) wv;
 
    return ERROR_SUCCESS;
end:
    WHERE_delete(&wv->view);
 
    return r;

Referenced by UPDATE_CreateView().