Package org.apache.metamodel.schema

Examples of org.apache.metamodel.schema.MutableTable


    @Override
    protected void setUp() throws Exception {
        super.setUp();
        schema = new MutableSchema("sch");
        table = new MutableTable("foo").setSchema(schema);
        schema.addTable(table);
        col = new MutableColumn("bar").setTable(table);
        table.addColumn(col);
    }
View Full Code Here


                queryString);
    }

    public void testFullyQualifiedColumnNames() throws Exception {
        final MutableSchema schema = new MutableSchema("sch");
        final MutableTable table = new MutableTable("tab", TableType.TABLE, schema);
        final MutableColumn nameColumn = new MutableColumn("name", ColumnType.VARCHAR).setTable(table);
        final MutableColumn ageColumn = new MutableColumn("age", ColumnType.INTEGER).setTable(table);
        schema.addTable(table);
        table.addColumn(nameColumn);
        table.addColumn(ageColumn);

        final Query q = new Query();
        q.select(ageColumn).selectCount();
        q.from(table);
        q.where(ageColumn, OperatorType.GREATER_THAN, 18);
View Full Code Here

                + "GROUP BY sch.tab.age HAVING COUNT(sch.tab.name) < 100 ORDER BY sch.tab.age ASC", sql);
    }

    public void testFullyQualifiedColumnNamesWithFilterItemContainingTimestamp() throws Exception {
        final MutableSchema schema = new MutableSchema("sch");
        final MutableTable table = new MutableTable("tab", TableType.TABLE, schema);
        final MutableColumn nameColumn = new MutableColumn("name", ColumnType.VARCHAR).setTable(table);
        final MutableColumn dateColumn = new MutableColumn("age", ColumnType.TIMESTAMP).setTable(table);
        schema.addTable(table);
        table.addColumn(nameColumn);
        table.addColumn(dateColumn);

        final Query q = new Query();
        q.select(dateColumn).selectCount();
        q.from(table);
        q.where(dateColumn, OperatorType.GREATER_THAN, "2012-10-31 08:09:54");
View Full Code Here

        // Sort table names by moving them to a treeset
        final Set<String> tableNames = new TreeSet<String>(_tableBuilders.keySet());

        for (final String tableName : tableNames) {
            final MutableTable table = buildTable(getTableBuilder(tableName));
            table.setSchema(schema);
            schema.addTable(table);
        }

        return schema;
    }
View Full Code Here

    public MutableTable toTable() {
        String name = getName();
        String[] columnNames = getColumnNames();
        ColumnType[] columnTypes = getColumnTypes();

        MutableTable table = new MutableTable(name, TableType.TABLE);

        for (int i = 0; i < columnNames.length; i++) {
            table.addColumn(new MutableColumn(columnNames[i], columnTypes[i], table, i, true));
        }
        return table;
    }
View Full Code Here

        return sourceCollectionName;
    }
   
    @Override
    protected MutableTable buildTable(InferentialTableBuilder tableBuilder) {
        final MutableTable table = super.buildTable(tableBuilder);
        CouchDbTableCreationBuilder.addMandatoryColumns(table);
        return table;
    }
View Full Code Here

        super(updateCallback, schema, name);
    }

    @Override
    public Table execute() throws MetaModelException {
        MutableTable table = getTable();

        String name = table.getName();

        CouchDbInstance instance = getUpdateCallback().getDataContext().getCouchDbInstance();
        instance.createDatabase(name);

        addMandatoryColumns(table);

        MutableSchema schema = (MutableSchema) table.getSchema();
        schema.addTable(table);

        return table;
    }
View Full Code Here

    @Override
    public MutableSchema build() {
        final MutableSchema schema = new MutableSchema(_schemaName);
        for (final SimpleTableDef simpleTableDef : _simpleTableDefs) {
            final MutableTable table = simpleTableDef.toTable();
            schema.addTable(table);
            table.setSchema(schema);
        }
        return schema;
    }
View Full Code Here

        final int tableObservations = getObservationCount();

        // sort column names by copying them to a TreeSet
        final Set<String> columnNames = new TreeSet<String>(_columnBuilders.keySet());

        final MutableTable table = new MutableTable(_tableName);
        int columnNumber = 0;
        for (final String columnName : columnNames) {
            final InferentialColumnBuilder columnBuilder = getColumnBuilder(columnName);
            final MutableColumn column = columnBuilder.build();
            column.setTable(table);
            column.setColumnNumber(columnNumber);

            final int columnObservations = columnBuilder.getObservationCount();
            if (tableObservations > columnObservations) {
                // there may be nulls - some records does not even contain the
                // column
                column.setNullable(true);
            }

            table.addColumn(column);

            columnNumber++;
        }

        return table;
View Full Code Here

    }

    @Override
    public MutableSchema build() {
        MutableSchema schema = new MutableSchema(_schemaName);
        MutableTable table = new MutableTable(_tableName, schema);
        table.addColumn(new MutableColumn(_columnName, ColumnType.MAP, table, 1, null, null, false, null, false, null));
        schema.addTable(table);
        return schema;
    }
View Full Code Here

TOP

Related Classes of org.apache.metamodel.schema.MutableTable

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.