本文整理汇总了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；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论