org.nuxeo.ecm.core.storage.sql.jdbc
Class SQLInfo

java.lang.Object
  org.nuxeo.ecm.core.storage.sql.jdbc.SQLInfo

public class SQLInfo
extends Object

This singleton generates and holds the actual SQL DDL and DML statements for the operations needed by the Mapper, given a Model.

It is specific to one SQL dialect.

Nested Class Summary

static class	SQLInfo.ColumnMapMaker Builds the map from a result set given a list of columns and column keys.
static interface	SQLInfo.MapMaker Knows how to build a result map for a row given a ResultSet.
static class	SQLInfo.SQLInfoSelect

Field Summary

Database	database
Dialect	dialect

Constructor Summary

SQLInfo(Model model, Dialect dialect)
Generates and holds the needed SQL statements given a Model and a Dialect.

Method Summary

void	executeSQLStatements(String category, JDBCConnection jdbc) Executes the SQL statements for the given category.
List<Column>	getClusterInvalidationsColumns()
List<Column>	getCopyHierColumns(boolean explicitName, boolean createVersion)
String	getCopyHierSql(boolean explicitName, boolean createVersion)
Column	getCopyHierWhereColumn()
Column	getCopyIdColumn(String tableName)
String	getCopySql(String tableName)
Database	getDatabase()
String	getDeleteSql(String tableName) Returns the SQL DELETE to delete a row.
List<Column>	getInsertColumns(String tableName) Returns the list of columns to use for an statement getInsertSql(java.lang.String).
List<Column>	getInsertRootIdColumns()
String	getInsertRootIdSql()
String	getInsertSql(String tableName) Returns the SQL INSERT to add a row.
int	getMaximumArgsForIn()
String	getSelectByChildNameSql(Boolean complexProp)
List<Column>	getSelectByChildNameWhatColumns(Boolean complexProp)
List<Column>	getSelectByChildNameWhereColumns(Boolean complexProp)
String	getSelectChildrenIdsAndTypesSql(boolean onlyComplex)
List<Column>	getSelectChildrenIdsAndTypesWhatColumns()
SQLInfo.SQLInfoSelect	getSelectFragmentsByIds(String tableName, int nids) Select by ids for all values of several fragments.
SQLInfo.SQLInfoSelect	getSelectFragmentsByIds(String tableName, int nids, String[] orderBys, Set<String> skipColumns) Select by ids for all values of several fragments (maybe ordered along columns -- for collection fragments retrieval).
String	getSelectRootIdSql()
Column	getSelectRootIdWhatColumn()
SQLInfo.SQLInfoSelect	getUpdateById(String tableName, Collection<String> keys)
Update	getUpdateByIdForKeys(String tableName, List<String> keys)
void	initSQLStatements(Map<String,Serializable> testProps)
SQLInfo.SQLInfoSelect	makeJoinSelect(Table table, String[] freeColumns, Table joinTable, String[] joinCriteria) Joining SELECT T.x, T.y, T.z FROM T, U WHERE T.id = U.id AND T.a = ? and U.b = ?
SQLInfo.SQLInfoSelect	makeJoinSelect(Table table, String[] freeColumns, Table joinTable, String[] joinCriteria, String[] orderBys) Joining SELECT T.x, T.y, T.z FROM T, U WHERE T.id = U.id AND T.a = ? and U.b = ? ORDER BY x, y DESC
SQLInfo.SQLInfoSelect	makeSelect(Table table, String... freeColumns) Basic SELECT x, y, z FROM table WHERE a = ? AND b = ?
SQLInfo.SQLInfoSelect	makeSelect(Table table, String[] orderBys, String... freeColumns) Basic SELECT with optional ORDER BY x, y DESC

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

database

public final Database database

dialect

public final Dialect dialect

Constructor Detail

SQLInfo

public SQLInfo(Model model,
               Dialect dialect)
        throws StorageException

Generates and holds the needed SQL statements given a Model and a Dialect.

Parameters:

model - the model

dialect - the SQL dialect

Throws:

StorageException

Method Detail

getDatabase

public Database getDatabase()

getSelectRootIdSql

public String getSelectRootIdSql()

getSelectRootIdWhatColumn

public Column getSelectRootIdWhatColumn()

getInsertRootIdSql

public String getInsertRootIdSql()

getInsertRootIdColumns

public List<Column> getInsertRootIdColumns()

getSelectByChildNameSql

public String getSelectByChildNameSql(Boolean complexProp)

getSelectByChildNameWhatColumns

public List<Column> getSelectByChildNameWhatColumns(Boolean complexProp)

getSelectByChildNameWhereColumns

public List<Column> getSelectByChildNameWhereColumns(Boolean complexProp)

getSelectChildrenIdsAndTypesSql

public String getSelectChildrenIdsAndTypesSql(boolean onlyComplex)

getSelectChildrenIdsAndTypesWhatColumns

public List<Column> getSelectChildrenIdsAndTypesWhatColumns()

getClusterInvalidationsColumns

public List<Column> getClusterInvalidationsColumns()

getInsertSql

public String getInsertSql(String tableName)

Returns the SQL INSERT to add a row. The columns that represent sequences that are implicitly auto-incremented aren't included.

Parameters:

tableName - the table name

Returns:

the SQL INSERT statement

getInsertColumns

public List<Column> getInsertColumns(String tableName)

Returns the list of columns to use for an statement getInsertSql(java.lang.String).

Parameters:

tableName - the table name

Returns:

the list of columns

getUpdateById

public SQLInfo.SQLInfoSelect getUpdateById(String tableName,
                                           Collection<String> keys)

getUpdateByIdForKeys

public Update getUpdateByIdForKeys(String tableName,
                                   List<String> keys)

getSelectFragmentsByIds

public SQLInfo.SQLInfoSelect getSelectFragmentsByIds(String tableName,
                                                     int nids)

Select by ids for all values of several fragments.

getSelectFragmentsByIds

public SQLInfo.SQLInfoSelect getSelectFragmentsByIds(String tableName,
                                                     int nids,
                                                     String[] orderBys,
                                                     Set<String> skipColumns)

Select by ids for all values of several fragments (maybe ordered along columns -- for collection fragments retrieval).

getDeleteSql

public String getDeleteSql(String tableName)

Returns the SQL DELETE to delete a row. The primary key columns are free parameters.

Parameters:

tableName - the table name

Returns:

the SQL INSERT statement

getCopyHierSql

public String getCopyHierSql(boolean explicitName,
                             boolean createVersion)

getCopyHierColumns

public List<Column> getCopyHierColumns(boolean explicitName,
                                       boolean createVersion)

getCopyHierWhereColumn

public Column getCopyHierWhereColumn()

getCopySql

public String getCopySql(String tableName)

getCopyIdColumn

public Column getCopyIdColumn(String tableName)

makeSelect

public SQLInfo.SQLInfoSelect makeSelect(Table table,
                                        String... freeColumns)

Basic SELECT x, y, z FROM table WHERE a = ? AND b = ?

makeSelect

public SQLInfo.SQLInfoSelect makeSelect(Table table,
                                        String[] orderBys,
                                        String... freeColumns)

Basic SELECT with optional ORDER BY x, y DESC

makeJoinSelect

public SQLInfo.SQLInfoSelect makeJoinSelect(Table table,
                                            String[] freeColumns,
                                            Table joinTable,
                                            String[] joinCriteria)

Joining SELECT T.x, T.y, T.z FROM T, U WHERE T.id = U.id AND T.a = ? and U.b = ?

makeJoinSelect

public SQLInfo.SQLInfoSelect makeJoinSelect(Table table,
                                            String[] freeColumns,
                                            Table joinTable,
                                            String[] joinCriteria,
                                            String[] orderBys)

Joining SELECT T.x, T.y, T.z FROM T, U WHERE T.id = U.id AND T.a = ? and U.b = ? ORDER BY x, y DESC

initSQLStatements

public void initSQLStatements(Map<String,Serializable> testProps)
                       throws IOException

Throws:

IOException

executeSQLStatements

public void executeSQLStatements(String category,
                                 JDBCConnection jdbc)
                          throws SQLException

Executes the SQL statements for the given category.

Throws:

SQLException

getMaximumArgsForIn

public int getMaximumArgsForIn()