• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号
登陆 注册

Java SchemaCrawlerException类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中schemacrawler.schemacrawler.SchemaCrawlerException类的典型用法代码示例。如果您正苦于以下问题：Java SchemaCrawlerException类的具体用法？Java SchemaCrawlerException怎么用？Java SchemaCrawlerException使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



SchemaCrawlerException类属于schemacrawler.schemacrawler包，在下文中一共展示了SchemaCrawlerException类的19个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: lint

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
/**
 * The lint that does the job
 * @param table table
 * @param connection connection
 */
@Override
protected void lint(final Table table, final Connection connection) throws SchemaCrawlerException{

    try (Statement stmt = connection.createStatement()){

        List<Column> columns = getColumns(table);
        int columnDataType;
        int count;
        int distinctCount;

        for (Column column : columns) {
            columnDataType = column.getColumnDataType().getJavaSqlType().getJavaSqlType();
            if(columnDataType == Types.BINARY || columnDataType == Types.BLOB) {
                inspectBlobData(stmt, table, column);
            }
        }
    }catch (SQLException ex) {
        LOGGER.severe(ex.getMessage());
        throw new SchemaCrawlerException(ex.getMessage(), ex);
    }

}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:28，代码来源:LinterCompressBlob.java


示例2: lint

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
/**
 * The lint that does the job
 *
 * @param table      table
 * @param connection connection
 */
@Override
protected void lint(final Table table, final Connection connection) throws SchemaCrawlerException {
    try {
        if ("PostgreSQL".equalsIgnoreCase(connection.getMetaData().getDatabaseProductName()) && "9.4".compareTo(connection.getMetaData().getDatabaseProductVersion()) <= 0) {
            List<Column> columns = getColumns(table);
            for (Column column : columns) {
                LOGGER.log(Level.INFO, "Checking {0}...", column.getFullName() + " - " + column.getColumnDataType().getDatabaseSpecificTypeName());
                if (Objects.equals("bytea", column.getColumnDataType().getDatabaseSpecificTypeName())) {
                    addLint(table, getDescription(), column.getFullName());
                }
            }
        }
    } catch (SQLException ex) {
        LOGGER.severe(ex.getMessage());
        throw new SchemaCrawlerException(ex.getMessage(), ex);
    }
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:24，代码来源:LinterByteaTypeColumn.java


示例3: lint

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
/**
 * The lint that does the job
 * @param table table
 * @param connection connection
 */
@Override
protected void lint(final Table table, Connection connection) throws SchemaCrawlerException
{
    requireNonNull(table, "No table provided");
    
    try {
        if("PostgreSQL".equalsIgnoreCase(connection.getMetaData().getDatabaseProductName()) &&
                "9.4".compareTo(connection.getMetaData().getDatabaseProductVersion()) <= 0){
            List<String> names = findJsonTypeColumn(getColumns(table));
            for (String name : names) {
                addLint(table, getDescription(), name);
            }
        }
        
    } catch (SQLException e) {
        LOGGER.log(Level.SEVERE, "Unable to get database product name info. Lint will not be executed.");
        throw new SchemaCrawlerException(e.getMessage(), e);
    }
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:25，代码来源:LinterJsonTypeColumn.java


示例4: getSelectCount

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
private static int getSelectCount(Statement stmt, Table table, Column column) throws SchemaCrawlerException{
    String tableName = table.getName().replaceAll("\"", "");
    String columnName = column.getName().replaceAll("\"", "");

    String sql = "select count (\"" + columnName + "\") as countRow from \"" + tableName +"\"";
    LOGGER.log(Level.CONFIG, "SQL : {0}", sql);

    int count = 0;
    try(ResultSet rs = stmt.executeQuery(sql)){
        if(rs.next()){
            count = rs.getInt("countRow");
        }
    }catch (SQLException ex) {
        LOGGER.severe(ex.getMessage());
        throw new SchemaCrawlerException(ex.getMessage(), ex);
    }
    return count;
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:19，代码来源:LinterBooleanContent.java


示例5: getSelectDistinctCount

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
private static int getSelectDistinctCount(Statement stmt, Table table, Column column) throws SchemaCrawlerException{
    String tableName = table.getName().replaceAll("\"", "");
    String columnName = column.getName().replaceAll("\"", "");
    
    String sql = "select count (distinct \"" + columnName + "\") as countDistinctRow from \"" + tableName +"\"";
    LOGGER.log(Level.CONFIG, "SQL : {0}", sql);
    
    int count = 0;
    try(ResultSet rs = stmt.executeQuery(sql)){
        if(rs.next()){
            count = rs.getInt("countDistinctRow");
        }
    }catch (SQLException ex) {
        LOGGER.severe(ex.getMessage());
        throw new SchemaCrawlerException(ex.getMessage(), ex);
    }
    return count;
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:19，代码来源:LinterBooleanContent.java


示例6: getDbSpecificOptionsBuilder

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
@Override
public DatabaseSpecificOverrideOptionsBuilder getDbSpecificOptionsBuilder(Connection conn, PhysicalSchema physicalSchema) {
    try {
        DatabaseConnectorRegistry registry = new DatabaseConnectorRegistry();
        DatabaseConnector databaseConnector = registry.lookupDatabaseConnector(conn);
        return databaseConnector.getDatabaseSpecificOverrideOptionsBuilder();
    } catch (SchemaCrawlerException e) {
        throw new RuntimeException(e);
    }
}
开发者ID:goldmansachs，项目名称:obevo，代码行数:11，代码来源:AbstractMetadataDialect.java


示例7: lint

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
/**
 * The lint that does the job
 * @param table table
 * @param connection connection
 * @throws SchemaCrawlerException SchemaCrawlerException
 */
@Override
protected void lint(final Table table, final Connection connection)
        throws SchemaCrawlerException {
    
    requireNonNull(table, "No table provided");
    findMismatchedForeignKeys(table);
    
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:15，代码来源:LinterForeignKeyMismatchLazy.java


示例8: lint

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
/**
 * The lint that does the job
 * @param table table
 * @param connection connection
 * @throws SchemaCrawlerException SchemaCrawlerException
 */
@Override
protected void lint(final Table table, final Connection connection)
        throws SchemaCrawlerException {
    
    try (Statement stmt = connection.createStatement()){
        
        List<Column> columns = getColumns(table);
        int columnDataType;
        int count;
        int distinctCount;

        for (Column column : columns) {
            //skip column if PK or FK
            if(!column.isPartOfPrimaryKey() && !column.isPartOfForeignKey()) {

                columnDataType = column.getColumnDataType().getJavaSqlType().getJavaSqlType();
                if (LintUtils.isSqlTypeNumericBased(columnDataType)) {
                    LOGGER.log(Level.INFO, "Checking {0}...", column.getFullName());
                    count = getSelectCount(stmt, table, column);
                    if (count > 2) {
                        distinctCount = getSelectDistinctCount(stmt, table, column);
                        if (distinctCount == 2) {
                            checkIfBooleanValuesAndLint(stmt, table, column);
                        }
                    }
                }

            }
        }
    }catch (SQLException ex) {
        LOGGER.severe(ex.getMessage());
        throw new SchemaCrawlerException(ex.getMessage(), ex);
    }
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:41，代码来源:LinterBooleanContent.java


示例9: checkIfBooleanValuesAndLint

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
private void checkIfBooleanValuesAndLint(Statement stmt, final Table table, Column column) throws SchemaCrawlerException{
    String tableName = table.getName().replaceAll("\"", "");
    String columnName = column.getName().replaceAll("\"", "");
    
    String sql = "select distinct \"" + columnName + "\" from \"" + tableName + "\"" ;
    LOGGER.log(Level.CONFIG, "SQL : {0}", sql);
    
    try(ResultSet rs = stmt.executeQuery(sql)){
       
        boolean trueFound = false;
        boolean falseFound = false;
        while (rs.next()) {
            if(rs.getObject(columnName) != null) {
                int data = ((Number) rs.getObject(columnName)).intValue();
                if(data == 1)
                    trueFound = true;
                else if(data == 0)
                    falseFound = true;
            }
        }
        
        if(trueFound && falseFound){
            addLint(table, getDescription(), column.getFullName());
        }
        
    }catch (SQLException ex) {
        LOGGER.severe(ex.getMessage());
        throw new SchemaCrawlerException(ex.getMessage(), ex);
    }
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:31，代码来源:LinterBooleanContent.java


示例10: DatabaseImporter

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
public DatabaseImporter(String jdbcUrl, String schema, String storeDir, Rules rules) throws SQLException, SchemaCrawlerException {
    this.storeDir = storeDir;
    this.rules = rules;
    Connection conn = DriverManager.getConnection(jdbcUrl);
    tables = MetaDataReader.extractTables(conn, schema, rules);
    reader = new DataReader(conn);
}
开发者ID:jexp，项目名称:neo4j-rdbms-import，代码行数:8，代码来源:DatabaseImporter.java


示例11: main

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
public static void main(String[] args) throws SQLException, SchemaCrawlerException, ClassNotFoundException {

        Driver driver = DriverManager.getDriver("jdbc:derby:memory:test;create=true");
        Connection connection = DriverManager.getConnection("jdbc:derby:memory:test;create=true", new Properties());
        Statement statement = connection.createStatement();
        // id INT NOT NULL GENERATED ALWAYS AS IDENTITY (START WITH 0, INCREMENT BY 1)
        statement.execute("CREATE TABLE USERS (id INT NOT NULL, name varchar(20), constraint users_pk_id primary key(id))");
        statement.execute("CREATE TABLE FRIENDS (id1 INT, id2 INT, " +
                " constraint fk_users_id1 foreign key(id1) references users(id)," +
                " constraint fk_users_id2 foreign key(id2) references users(id)" +
                ")");

        final SchemaCrawlerOptions options = new SchemaCrawlerOptions();
        options.setSchemaInfoLevel(SchemaInfoLevel.standard());

        final Catalog catalog = SchemaCrawlerUtility.getCatalog(connection, options);

        for (final Schema schema : catalog.getSchemas()) {
            System.out.println(schema);
            for (final Table table : catalog.getTables(schema)) {
                System.out.println("o--> " + table + " pk " + table.getPrimaryKey() + " fks " + table.getForeignKeys() + " type " + table.getTableType());
                for (final Column column : table.getColumns()) {
                    System.out.println("     o--> " + column + " pk: " + column.isPartOfPrimaryKey() + " fk: " + column.isPartOfForeignKey());
                }
            }
        }
    }
开发者ID:jexp，项目名称:neo4j-rdbms-import，代码行数:28，代码来源:SchemaCrawlerTest.java


示例12: crawl

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
private Database crawl(Connection dbconn, SchemaCrawlerOptions options) {
    try {
        SchemaCrawler crawler = new SchemaCrawler(dbconn);
        return crawler.crawl(options);
    } catch (SchemaCrawlerException e) {
        throw new RuntimeException(e);
    }
}
开发者ID:huherto，项目名称:springyRecords，代码行数:9，代码来源:SchemaCrawlerGenerator.java


示例13: inspectBlobData

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
private void inspectBlobData(Statement stmt, Table table, Column column) throws SchemaCrawlerException{
    String tableName = table.getName().replaceAll("\"", "");
    String columnName = column.getName().replaceAll("\"", "");

    String sql = "select " + columnName + " from " + tableName ;
    LOGGER.log(Level.CONFIG, "SQL : {0}", sql);

    InputStream byte_stream;
    try(ResultSet rs = stmt.executeQuery(sql)){
        if(rs.next()){
            File file = new File("target/file");

            try(FileOutputStream fos = new FileOutputStream(file)){
                byte[] buffer = new byte[1];
                byte_stream = rs.getBinaryStream(columnName);
                int nbBytes = 0;
                while (byte_stream.read(buffer) > 0 && nbBytes < 512000) {
                    fos.write(buffer);
                    nbBytes++;
                }
                byte_stream.close();
                int extract_size = nbBytes-1;

                /* Create Output Stream that will have final zip files */
                OutputStream zip_output = new FileOutputStream(new File("target/zip_output.zip"));
                /* Create Archive Output Stream that attaches File Output Stream / and specifies type of compression */
                ArchiveOutputStream logical_zip = null;
                logical_zip = new ArchiveStreamFactory().createArchiveOutputStream(ArchiveStreamFactory.ZIP, zip_output);
                /* Create Archieve entry - write header information*/
                logical_zip.putArchiveEntry(new ZipArchiveEntry("target/file"));
                /* Copy input file */
                IOUtils.copy(new FileInputStream(new File("target/file")), logical_zip);
                /* Close Archieve entry, write trailer information */
                logical_zip.closeArchiveEntry();
                /* Finish addition of entries to the file */
                logical_zip.finish();
                /* Close output stream, our files are zipped */
                zip_output.close();

                File zip_file = new File("target/zip_output.zip");
                if(zip_file.length() < extract_size) {
                    double rate = (zip_file.length() - extract_size)*100/extract_size;
                    if (Math.abs(rate) >= minCompressionPercent) {
                        LOGGER.info("Extract size :" + extract_size + "ko, zip file size :" + zip_file.length() + " rate :" +rate+"%");
                        addLint(table, "Blob should be compressed", column.getFullName());
                    }
                }

            } catch (IOException | ArchiveException e){
                LOGGER.severe(e.getMessage());
                throw new SchemaCrawlerException(e.getMessage(), e);
            }
        }
    }catch (SQLException ex) {
        LOGGER.severe(ex.getMessage());
        throw new SchemaCrawlerException(ex.getMessage(), ex);
    }
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:59，代码来源:LinterCompressBlob.java


示例14: testLint_getDescription

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
@Test
public void testLint_getDescription () throws SchemaCrawlerException{
    final LinterRegistry registry = new LinterRegistry();
    LinterJsonContent linter = (LinterJsonContent)registry.newLinter(LinterJsonContent.class.getName());
    Assert.assertEquals("should be JSON or JSONB type", linter.getDescription());
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:7，代码来源:LinterJsonContentTest.java


示例15: testLint_getSummary

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
@Test
public void testLint_getSummary () throws SchemaCrawlerException{
    final LinterRegistry registry = new LinterRegistry();
    LinterJsonContent linter = (LinterJsonContent)registry.newLinter(LinterJsonContent.class.getName());
    Assert.assertEquals(linter.getSummary(), linter.getDescription());
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:7，代码来源:LinterJsonContentTest.java


示例16: testLint_getDescription

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
@Test
public void testLint_getDescription () throws SchemaCrawlerException{
    final LinterRegistry registry = new LinterRegistry();
    LinterColumnSize linter = (LinterColumnSize)registry.newLinter(LinterColumnSize.class.getName());
    Assert.assertEquals("Column is oversized regarding its content", linter.getDescription());
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:7，代码来源:LinterColumnSizeTest.java


示例17: testLint_getSummary

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
@Test
public void testLint_getSummary () throws SchemaCrawlerException{
    final LinterRegistry registry = new LinterRegistry();
    LinterColumnSize linter = (LinterColumnSize)registry.newLinter(LinterColumnSize.class.getName());
    Assert.assertEquals("oversized column", linter.getSummary());
}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:7，代码来源:LinterColumnSizeTest.java


示例18: extractTables

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
static TableInfo[] extractTables(Connection conn, final String schemaName, Rules rules) throws SchemaCrawlerException, SQLException {
        ArrayList<TableInfo> tableList = new ArrayList<TableInfo>(100);

        final SchemaCrawlerOptions options = new SchemaCrawlerOptions();
        options.setSchemaInfoLevel(SchemaInfoLevel.standard());
        System.out.println("my catalog =" + conn.getCatalog());
        options.setSchemaInclusionRule(new InclusionRule() {
            @Override public boolean test(String anObject) {
                return schemaName.equals(anObject);
            }
        });

        final Catalog catalog = SchemaCrawlerUtility.getCatalog(conn, options);
        System.out.println("schem ! ");


        final Schema schema = catalog.getSchema(schemaName);
        System.out.println("Schema: " + schema);

        for (final Table table : catalog.getTables(schema)) {
            String tableName = table.getName();

            System.out.println(table + " pk " + table.getPrimaryKey() + " fks " + table.getForeignKeys() + " type " + table.getTableType());
            if (rules.skipTable(tableName) || table.getTableType().isView()) {
                System.out.println("SKIPPED");
                continue;
            }
            List<Column> columns = table.getColumns();
            List<String> fields = new ArrayList<>(columns.size());
            for (final Column column : columns) {
//                    System.out.println("     o--> " + column + " pk: "+ column.isPartOfPrimaryKey() + " fk: " + column.isPartOfForeignKey());
                String columnName = column.getName();
                if (column.isPartOfPrimaryKey() && rules.skipPrimaryKey(tableName, columnName)) {
                    // skip, todo strategy
                } else if (column.isPartOfForeignKey()) {
                    // skip, todo strategy
                } else {
                    fields.add(columnName);
                }
            }
            Map<List<String>, String> fks = extractForeignKeys(table);
            tableList.add(TableInfo.add(tableName, extractPrimaryKeys(table, fks), fields, fks));
        }

        return tableList.toArray(new TableInfo[tableList.size()]);
    }
开发者ID:jexp，项目名称:neo4j-rdbms-import，代码行数:47，代码来源:MetaDataReader.java


示例19: lint

import schemacrawler.schemacrawler.SchemaCrawlerException; //导入依赖的package包/类
@Override
protected void lint(Table table, Connection connection) throws SchemaCrawlerException {

    LOGGER.log(Level.CONFIG, "<"+PREFIX_CONFIG_PARAM+"> parameter set to {0}%", prefix);
    LOGGER.log(Level.CONFIG, "<"+SUFFIX_CONFIG_PARAM+"> parameter set to {0}%", suffix);

    requireNonNull(table, "No table provided");
    findMismatchedForeignKeys(table);

}
开发者ID:mbarre，项目名称:schemacrawler-additional-lints，代码行数:11，代码来源:LinterForeignKeyName.java



注：本文中的schemacrawler.schemacrawler.SchemaCrawlerException类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java MembershipListener类代码示例发布时间：2022-05-23
下一篇：
Java DataSourceFactory类代码示例发布时间：2022-05-23
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap