Examples of DbLoader

org.apache.cayenne.access.DbLoader
Utility class that does reverse engineering of the database. It can create DataMaps using database meta data obtained via JDBC driver. @author Michael Shengaout @author Andrus Adamchik
org.jasig.portal.tools.dbloader.DbLoader
A tool to set up a uPortal database. This tool was created so that uPortal developers would only have to maintain a single set of xml documents to define the uPortal database schema and data. Previously it was necessary to maintain different scripts for each database we wanted to support.

DbLoader reads the generic types that are specified in tables.xml and tries to map them to local types by querying the database metadata via methods implemented by the JDBC driver. Fallback mappings can be supplied in dbloader.xml for cases where the JDBC driver is not able to determine the appropriate mapping. Such cases will be reported to standard out.

An xsl transformation is used to produce the DROP TABLE and CREATE TABLE SQL statements. These statements can be altered by modifying tables.xsl

Generic data types (as defined in java.sql.Types) which may be specified in tables.xml include: BIT, TINYINT, SMALLINT, INTEGER, BIGINT, FLOAT, REAL, DOUBLE, NUMERIC, DECIMAL, CHAR, VARCHAR, LONGVARCHAR, DATE, TIME, TIMESTAMP, BINARY, VARBINARY, LONGVARBINARY, NULL, OTHER, JAVA_OBJECT, DISTINCT, STRUCT, ARRAY, BLOB, CLOB, REF, DATALINK, BOOLEAN
WARNING: YOU MAY WANT TO MAKE A BACKUP OF YOUR DATABASE BEFORE RUNNING DbLoader

DbLoader will perform the following steps:
1. Read configurable properties from dbloader.xml
2. Get database connection from RDBMServices (reads JDBC database settings from rdbm.properties).
3. Read tables.xml and issue corresponding DROP TABLE and CREATE TABLE SQL statements.
4. Read data.xml and issue corresponding INSERT/UPDATE/DELETE SQL statements.
@author Ken Weiner, kweiner@unicon.net @author Mark Boyd, mboyd@sungardsct.com @version $Revision: 1.31 $ @see java.sql.Types @since uPortal 2.0

Examples of org.apache.cayenne.access.DbLoader

        DbImportAction action = i.getInstance(DbImportAction.class);


        DbImportParameters parameters = new DbImportParameters();
        parameters.setUsePrimitives(true);


        DbLoader loader1 = action.createLoader(parameters, mock(DbAdapter.class), mock(Connection.class),
                mock(DbLoaderDelegate.class));


        DataMap map = new DataMap();


        DbEntity e1 = new DbEntity("e1");
        DbAttribute nonPk = new DbAttribute("nonPk", Types.INTEGER, e1);
        e1.addAttribute(nonPk);


        map.addDbEntity(e1);


        // DbLoader is so ugly and hard to test..
        Field dbEntityList = DbLoader.class.getDeclaredField("dbEntityList");
        dbEntityList.setAccessible(true);
        List<DbEntity> entities = (List<DbEntity>) dbEntityList.get(loader1);
        entities.add(e1);


        loader1.loadObjEntities(map);


        ObjEntity oe1 = map.getObjEntity("E1");


        ObjAttribute oa1 = (ObjAttribute) oe1.getAttribute("nonPk");
        assertEquals("int", oa1.getType());

View Full Code Here

Examples of org.apache.cayenne.access.DbLoader

        DbImportDbLoaderDelegate loaderDelegate = new DbImportDbLoaderDelegate();


        Connection connection = dataSource.getConnection();


        try {
            DbLoader loader = createLoader(parameters, adapter, connection, loaderDelegate);


            String[] types = loader.getDefaultTableTypes();
            loader.load(dataMap, parameters.getCatalog(), parameters.getSchema(), parameters.getTablePattern(), types);


            for (ObjEntity addedObjEntity : loaderDelegate.getAddedObjEntities()) {
                DeleteRuleUpdater.updateObjEntity(addedObjEntity);
            }


            if (parameters.isImportProcedures()) {
                loader.loadProcedures(dataMap, parameters.getCatalog(), parameters.getSchema(),
                        parameters.getProcedurePattern());
            }
        } finally {
            connection.close();
        }

View Full Code Here

Examples of org.apache.cayenne.access.DbLoader


        String meangfulPkExclude = parameters.getMeaningfulPkTables() != null ? null : "*";
        final NamePatternMatcher meaningfulPkFilter = new NamePatternMatcher(logger,
                parameters.getMeaningfulPkTables(), meangfulPkExclude);


        DbLoader loader = new DbLoader(connection, adapter, loaderDelegate) {
            @Override
            public boolean includeTableName(String tableName) {
                return nameFilter.isIncluded(tableName);
            }


            @Override
            protected EntityMergeSupport createEntityMerger(DataMap map) {
                EntityMergeSupport emSupport = new EntityMergeSupport(map, namingStrategy, true) {


                    @Override
                    protected boolean removePK(DbEntity dbEntity) {
                        return !meaningfulPkFilter.isIncluded(dbEntity.getName());
                    }
                };


                emSupport.setUsePrimitives(parameters.isUsePrimitives());
                return emSupport;
            }
        };


        // TODO: load via DI AdhocObjectFactory
        String namingStrategy = parameters.getNamingStrategy();
        if (namingStrategy != null) {
            NamingStrategy namingStrategyInst = (NamingStrategy) Class.forName(namingStrategy).newInstance();
            loader.setNamingStrategy(namingStrategyInst);
        }


        return loader;
    }

View Full Code Here

Examples of org.apache.cayenne.access.DbLoader


    public DbLoaderHelper(ProjectController mediator, Connection connection,
            DbAdapter adapter, String dbUserName) {
        this.dbUserName = dbUserName;
        this.mediator = mediator;
        this.loader = new DbLoader(connection, adapter, new LoaderDelegate());
    }

View Full Code Here

Examples of org.apache.cayenne.access.DbLoader

            // load driver taking custom CLASSPATH into account...
            DriverDataSource dataSource = new DriverDataSource((Driver) Class.forName(driver).newInstance(), url, username, password);


            // Load the data map and run the db importer.
            final LoaderDelegate loaderDelegate = new LoaderDelegate();
            final DbLoader loader = new DbLoader(dataSource.getConnection(), adapterInst, loaderDelegate);
            loader.setCreatingMeaningfulPK(meaningfulPk);


            if (namingStrategy != null) {
                final NamingStrategy namingStrategyInst = (NamingStrategy) Class.forName(namingStrategy).newInstance();
                loader.setNamingStrategy(namingStrategyInst);
            }


            mapFile = new File(map);
            final DataMap dataMap = mapFile.exists() ? loadDataMap() : new DataMap();
            loader.loadDataMapFromDB(schemaName, tablePattern, dataMap);


            for (ObjEntity addedObjEntity : loaderDelegate.getAddedObjEntities()) {
                DeleteRuleUpdater.updateObjEntity(addedObjEntity);
            }


            if (importProcedures) {
                loader.loadProceduresFromDB(schemaName, procedurePattern, dataMap);
            }


            // Write the new DataMap out to disk.
            mapFile.delete();
            PrintWriter pw = new PrintWriter(mapFile);

View Full Code Here

Examples of org.apache.cayenne.access.DbLoader


    public DbLoaderHelper(ProjectController mediator, Connection connection,
            DbAdapter adapter, String dbUserName) {
        this.dbUserName = dbUserName;
        this.mediator = mediator;
        this.loader = new DbLoader(connection, adapter, new LoaderDelegate());
    }

View Full Code Here

Examples of org.apache.cayenne.access.DbLoader

            // load driver taking custom CLASSPATH into account...
            DriverDataSource dataSource = new DriverDataSource((Driver) Class.forName(driver).newInstance(), url, userName, password);


            // Load the data map and run the db importer.
            final LoaderDelegate loaderDelegate = new LoaderDelegate();
            final DbLoader loader = new DbLoader(dataSource.getConnection(), adapter, loaderDelegate);
            loader.setCreatingMeaningfulPK(meaningfulPk);


            if (namingStrategy != null) {
                final NamingStrategy namingStrategyInst = (NamingStrategy) Class.forName(namingStrategy).newInstance();
                loader.setNamingStrategy(namingStrategyInst);
            }


            final DataMap dataMap = map.exists() ? loadDataMap() : new DataMap();
            loader.loadDataMapFromDB(schemaName, tablePattern, dataMap);


            for (ObjEntity addedObjEntity : loaderDelegate.getAddedObjEntities()) {
                DeleteRuleUpdater.updateObjEntity(addedObjEntity);
            }


            if (importProcedures) {
                loader.loadProceduresFromDB(schemaName, procedurePattern, dataMap);
            }


            // Write the new DataMap out to disk.
            map.delete();
            PrintWriter pw = new PrintWriter(map);

View Full Code Here

Examples of org.apache.cayenne.access.DbLoader


    public DbLoaderHelper(ProjectController mediator, Connection connection,
            DbAdapter adapter, String dbUserName) {
        this.dbUserName = dbUserName;
        this.mediator = mediator;
        this.loader = new DbLoader(connection, adapter, new LoaderDelegate());
    }

View Full Code Here

Examples of org.apache.cayenne.access.DbLoader


    public DbLoaderHelper(ProjectController mediator, Connection connection,
            DbAdapter adapter, String dbUserName) {
        this.dbUserName = dbUserName;
        this.mediator = mediator;
        this.loader = new DbLoader(connection, adapter, new LoaderDelegate());
    }

View Full Code Here

Examples of org.apache.cayenne.access.DbLoader

            DriverDataSource dataSource = new DriverDataSource((Driver) Class.forName(
                    driver).newInstance(), url, userName, password);


            // Load the data map and run the db importer.
            final LoaderDelegate loaderDelegate = new LoaderDelegate();
            final DbLoader loader = new DbLoader(
                    dataSource.getConnection(),
                    adapter,
                    loaderDelegate);
            loader.setCreatingMeaningfulPK(meaningfulPk);


            if (namingStrategy != null) {
                final NamingStrategy namingStrategyInst = (NamingStrategy) Class.forName(
                        namingStrategy).newInstance();
                loader.setNamingStrategy(namingStrategyInst);
            }


            final DataMap dataMap = map.exists() ? loadDataMap() : new DataMap();
            loader.loadDataMapFromDB(schemaName, tablePattern, dataMap);


            for (ObjEntity addedObjEntity : loaderDelegate.getAddedObjEntities()) {
                DeleteRuleUpdater.updateObjEntity(addedObjEntity);
            }


            if (importProcedures) {
                loader.loadProceduresFromDB(schemaName, procedurePattern, dataMap);
            }


            // Write the new DataMap out to disk.
            map.delete();
            PrintWriter pw = new PrintWriter(map);

View Full Code Here

0 1 2

TOP

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.