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

Java Dialect类代码示例

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

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



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

示例1: setUpDatabase

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@BeforeClass
public static void setUpDatabase() throws Exception {
    config = new Config() {

        final Dialect dialect = new H2Dialect();

        @Override
        public Dialect getDialect() {
            return dialect;
        }

        @Override
        public DataSource getDataSource() {
            return database.getDataSource();
        }
    };
}
 
开发者ID:backpaper0,项目名称:sealion,代码行数:18,代码来源:EntityTest.java


示例2: config1

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@Bean
@Foo
Config config1() {
    return new Config() {

        @Override
        public String getDataSourceName() {
            return "foo";
        }

        @Override
        public Dialect getDialect() {
            return new StandardDialect();
        }

        @Override
        public DataSource getDataSource() {
            return new SimpleDataSource();
        }
    };
}
 
开发者ID:backpaper0,项目名称:spring-boot-doma-multi-config-sample,代码行数:22,代码来源:Application.java


示例3: config2

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@Bean
@Bar
Config config2() {
    return new Config() {

        @Override
        public String getDataSourceName() {
            return "bar";
        }

        @Override
        public Dialect getDialect() {
            return new StandardDialect();
        }

        @Override
        public DataSource getDataSource() {
            return new SimpleDataSource();
        }
    };
}
 
开发者ID:backpaper0,项目名称:spring-boot-doma-multi-config-sample,代码行数:22,代码来源:Application.java


示例4: getSqlFile

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@Override
public final SqlFile getSqlFile(Method method, String path, Dialect dialect) {
    if (method == null) {
        throw new DomaNullPointerException("method");
    }
    if (path == null) {
        throw new DomaNullPointerException("path");
    }
    if (!path.startsWith(Constants.SQL_PATH_PREFIX)) {
        throw new DomaIllegalArgumentException("path",
                "The path does not start with '"
                        + Constants.SQL_PATH_PREFIX + "'");
    }
    if (!path.endsWith(Constants.SQL_PATH_SUFFIX)) {
        throw new DomaIllegalArgumentException("path",
                "The path does not end with '" + Constants.SQL_PATH_SUFFIX
                        + "'");
    }
    if (dialect == null) {
        throw new DomaNullPointerException("dialect");
    }
    return getSqlFileWithCacheControl(method, path, dialect);
}
 
开发者ID:domaframework,项目名称:doma,代码行数:24,代码来源:AbstractSqlFileRepository.java


示例5: populateValues

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
public void populateValues(E entity,
        List<EntityPropertyType<E, ?>> targetPropertyTypes,
        EntityPropertyType<E, ?> versionPropertyType, SqlContext context) {
    Dialect dialect = config.getDialect();
    Naming naming = config.getNaming();
    for (EntityPropertyType<E, ?> propertyType : targetPropertyTypes) {
        Property<E, ?> property = propertyType.createProperty();
        property.load(entity);
        context.appendSql(propertyType.getColumnName(naming::apply,
                dialect::applyQuote));
        context.appendSql(" = ");
        context.appendParameter(property.asInParameter());
        if (propertyType.isVersion() && !versionIgnored) {
            context.appendSql(" + 1");
        }
        context.appendSql(", ");
    }
    context.cutBackSql(2);
}
 
开发者ID:domaframework,项目名称:doma,代码行数:20,代码来源:BatchUpdateQueryHelper.java


示例6: execute

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@Override
public RESULT execute() {
    Connection connection = JdbcUtil.getConnection(query.getConfig()
            .getDataSource());
    try {
        CallableStatement callableStatement = JdbcUtil.prepareCall(
                connection, sql);
        try {
            log();
            setupOptions(callableStatement);
            bindParameters(callableStatement);
            return executeInternal(callableStatement);
        } catch (SQLException e) {
            Dialect dialect = query.getConfig().getDialect();
            throw new SqlExecutionException(query.getConfig()
                    .getExceptionSqlLogType(), sql, e,
                    dialect.getRootCause(e));
        } finally {
            JdbcUtil.close(callableStatement, query.getConfig()
                    .getJdbcLogger());
        }
    } finally {
        JdbcUtil.close(connection, query.getConfig().getJdbcLogger());
    }
}
 
开发者ID:domaframework,项目名称:doma,代码行数:26,代码来源:ModuleCommand.java


示例7: prepareStatement

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
protected PreparedStatement prepareStatement(Connection connection,
        PreparedSql sql) {
    if (query.isAutoGeneratedKeysSupported()) {
        Config config = query.getConfig();
        Dialect dialect = config.getDialect();
        switch (dialect.getAutoGeneratedKeysType()) {
        case FIRST_COLUMN:
            return JdbcUtil
                    .prepareStatementForAutoGeneratedKeysOfFirstColumn(
                            connection, sql);
        case DEFAULT:
            return JdbcUtil.prepareStatementForAutoGeneratedKeys(connection,
                    sql);
        }
    }
    return JdbcUtil.prepareStatement(connection, sql);
}
 
开发者ID:domaframework,项目名称:doma,代码行数:18,代码来源:BatchModifyCommand.java


示例8: validateRows

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
protected void validateRows(PreparedStatement preparedStatement,
        PreparedSql sql, int[] rows) throws SQLException {
    Dialect dialect = query.getConfig().getDialect();
    if (dialect.supportsBatchUpdateResults()) {
        if (!query.isOptimisticLockCheckRequired()) {
            return;
        }
        for (int i = 0; i < rows.length; ++i) {
            if (rows[i] != 1) {
                throw new BatchOptimisticLockException(query.getConfig()
                        .getExceptionSqlLogType(), sql);
            }
        }
    } else if (preparedStatement.getUpdateCount() == rows.length) {
        Arrays.fill(rows, 1);
    } else {
        if (!query.isOptimisticLockCheckRequired()) {
            return;
        }
        throw new BatchOptimisticLockException(query.getConfig()
                .getExceptionSqlLogType(), sql);
    }
}
 
开发者ID:domaframework,项目名称:doma,代码行数:24,代码来源:BatchModifyCommand.java


示例9: config

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@Bean
public Config config() {
    return new Config() {

        @Override
        public Dialect getDialect() {
            return dialect();
        }

        @Override
        public DataSource getDataSource() {
            return dataSource();
        }

        @Override
        public SqlFileRepository getSqlFileRepository() {
            return sqlFileRepository();
        }
    };
}
 
开发者ID:deffence1776,项目名称:Spring-boot-doma-multPj,代码行数:21,代码来源:DataSourceConfiguration.java


示例10: expandColumns

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
protected List<String> expandColumns(ExpandNode node) {
	if (entityType == null) {
		SqlLocation location = node.getLocation();
		throw new JdbcException(Message.DOMA2144, location.getSql(), location.getLineNumber(),
				location.getPosition());
	}
	Naming naming = config.getNaming();
	Dialect dialect = config.getDialect();
	return entityType.getEntityPropertyTypes().stream()
			.map(p -> p.getColumnName(naming::apply, dialect::applyQuote)).collect(Collectors.toList());
}
 
开发者ID:lospatitos,项目名称:springboot-batch-doma,代码行数:12,代码来源:Parser.java


示例11: domaConfig

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@Bean
public Config domaConfig() {
    return new DomaAbstractConfig() {
        @Override
        public Dialect getDialect() {
            return dialect();
        }

        @Override
        public DataSource getDataSource() {
            return new TransactionAwareDataSourceProxy(dataSource());
        }
    };
}
 
开发者ID:matsumana,项目名称:spring-doma-junit4-dbunit-sample,代码行数:15,代码来源:AppConfig.java


示例12: validateGenerationStrategy

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
/**
 * 識別子の生成方法を検証します。
 * 
 * @param config
 *            識別子の生成に関する設定
 */
public void validateGenerationStrategy(IdGenerationConfig config) {
    Dialect dialect = config.getDialect();
    GenerationType generationType = idGenerator.getGenerationType();
    if (!isGenerationTypeSupported(generationType, dialect)) {
        EntityType<?> entityType = config.getEntityType();
        throw new JdbcException(Message.DOMA2021, entityType.getName(),
                name, generationType.name(), dialect.getName());
    }
}
 
开发者ID:domaframework,项目名称:doma,代码行数:16,代码来源:GeneratedIdPropertyType.java


示例13: isGenerationTypeSupported

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
/**
 * 識別子を生成する方法がサポートされているかどうかを返します。
 * 
 * @param generationType
 *            識別子の生成方法
 * @param dialect
 *            方言
 * @return サポートされている場合 {@code true}
 */
protected boolean isGenerationTypeSupported(GenerationType generationType,
        Dialect dialect) {
    switch (generationType) {
    case IDENTITY:
        return dialect.supportsIdentity();
    case SEQUENCE:
        return dialect.supportsSequence();
    default:
        return true;
    }
}
 
开发者ID:domaframework,项目名称:doma,代码行数:21,代码来源:GeneratedIdPropertyType.java


示例14: prepareSql

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
protected void prepareSql() {
    Naming naming = config.getNaming();
    Dialect dialect = config.getDialect();
    PreparedSqlBuilder builder = new PreparedSqlBuilder(config,
            SqlKind.BATCH_INSERT, sqlLogType);
    builder.appendSql("insert into ");
    builder.appendSql(entityType.getQualifiedTableName(naming::apply,
            dialect::applyQuote));
    builder.appendSql(" (");
    for (EntityPropertyType<ENTITY, ?> p : targetPropertyTypes) {
        builder.appendSql(p.getColumnName(naming::apply,
                dialect::applyQuote));
        builder.appendSql(", ");
    }
    builder.cutBackSql(2);
    builder.appendSql(") values (");
    for (EntityPropertyType<ENTITY, ?> propertyType : targetPropertyTypes) {
        Property<ENTITY, ?> property = propertyType.createProperty();
        property.load(currentEntity);
        builder.appendParameter(property.asInParameter());
        builder.appendSql(", ");
    }
    builder.cutBackSql(2);
    builder.appendSql(")");
    PreparedSql sql = builder.build(this::comment);
    sqls.add(sql);
}
 
开发者ID:domaframework,项目名称:doma,代码行数:28,代码来源:AutoBatchInsertQuery.java


示例15: expandColumns

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
protected List<String> expandColumns(ExpandNode node) {
    if (entityType == null) {
        SqlLocation location = node.getLocation();
        throw new JdbcException(Message.DOMA2144, location.getSql(),
                location.getLineNumber(), location.getPosition());
    }
    Naming naming = config.getNaming();
    Dialect dialect = config.getDialect();
    return entityType.getEntityPropertyTypes().stream()
            .map(p -> p.getColumnName(naming::apply, dialect::applyQuote))
            .collect(Collectors.toList());
}
 
开发者ID:domaframework,项目名称:doma,代码行数:13,代码来源:AbstractSelectQuery.java


示例16: getSqlFileWithCacheControl

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@Override
protected SqlFile getSqlFileWithCacheControl(Method method, String path,
        Dialect dialect) {
    SqlFile file = sqlFileMap.get(path);
    if (file != null) {
        return file;
    }
    file = createSqlFile(path, dialect);
    SqlFile current = sqlFileMap.putIfAbsent(path, file);
    return current != null ? current : file;
}
 
开发者ID:domaframework,项目名称:doma,代码行数:12,代码来源:GreedyCacheSqlFileRepository.java


示例17: createSql

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
protected Sql<?> createSql() {
    Naming naming = config.getNaming();
    Dialect dialect = config.getDialect();
    String catalogName = entityType.getCatalogName();
    String schemaName = entityType.getSchemaName();
    String tableName = entityType.getTableName(naming::apply);
    String idColumnName = entityType.getGeneratedIdPropertyType()
            .getColumnName(naming::apply);
    boolean isQuoteRequired = entityType.isQuoteRequired();
    boolean isIdColumnQuoteRequired = entityType.getGeneratedIdPropertyType()
    		.isQuoteRequired();
    return dialect.getIdentityReservationSql(catalogName, schemaName,
            tableName, idColumnName, isQuoteRequired,
            isIdColumnQuoteRequired, reservationSize);
}
 
开发者ID:domaframework,项目名称:doma,代码行数:16,代码来源:ReservedIdProvider.java


示例18: execute

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@Override
public int[] execute() {
    if (!query.isExecutable()) {
        JdbcLogger logger = query.getConfig().getJdbcLogger();
        logger.logSqlExecutionSkipping(query.getClassName(),
                query.getMethodName(), query.getSqlExecutionSkipCause());
        return new int[] {};
    }
    Connection connection = JdbcUtil.getConnection(query.getConfig()
            .getDataSource());
    try {
        PreparedSql sql = query.getSql();
        PreparedStatement preparedStatement = prepareStatement(connection,
                sql);
        try {
            setupOptions(preparedStatement);
            return executeInternal(preparedStatement, query.getSqls());
        } catch (SQLException e) {
            Dialect dialect = query.getConfig().getDialect();
            throw new BatchSqlExecutionException(query.getConfig()
                    .getExceptionSqlLogType(), sql, e,
                    dialect.getRootCause(e));
        } finally {
            JdbcUtil.close(preparedStatement, query.getConfig()
                    .getJdbcLogger());
        }
    } finally {
        JdbcUtil.close(connection, query.getConfig().getJdbcLogger());
    }
}
 
开发者ID:domaframework,项目名称:doma,代码行数:31,代码来源:BatchModifyCommand.java


示例19: executeBatch

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
protected int[] executeBatch(PreparedStatement preparedStatement,
        PreparedSql sql) throws SQLException {
    try {
        return preparedStatement.executeBatch();
    } catch (SQLException e) {
        Dialect dialect = query.getConfig().getDialect();
        if (dialect.isUniqueConstraintViolated(e)) {
            throw new BatchUniqueConstraintException(query.getConfig()
                    .getExceptionSqlLogType(), sql, e);
        }
        throw e;
    }
}
 
开发者ID:domaframework,项目名称:doma,代码行数:14,代码来源:BatchModifyCommand.java


示例20: execute

import org.seasar.doma.jdbc.dialect.Dialect; //导入依赖的package包/类
@Override
public Integer execute() {
    if (!query.isExecutable()) {
        JdbcLogger logger = query.getConfig().getJdbcLogger();
        logger.logSqlExecutionSkipping(query.getClassName(),
                query.getMethodName(), query.getSqlExecutionSkipCause());
        return Integer.valueOf(0);
    }
    Connection connection = JdbcUtil.getConnection(query.getConfig()
            .getDataSource());
    try {
        PreparedStatement preparedStatement = prepareStatement(connection);
        try {
            log();
            setupOptions(preparedStatement);
            bindParameters(preparedStatement);
            return executeInternal(preparedStatement);
        } catch (SQLException e) {
            Dialect dialect = query.getConfig().getDialect();
            throw new SqlExecutionException(query.getConfig()
                    .getExceptionSqlLogType(), sql, e,
                    dialect.getRootCause(e));
        } finally {
            JdbcUtil.close(preparedStatement, query.getConfig()
                    .getJdbcLogger());
        }
    } finally {
        JdbcUtil.close(connection, query.getConfig().getJdbcLogger());
    }
}
 
开发者ID:domaframework,项目名称:doma,代码行数:31,代码来源:ModifyCommand.java



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


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java AddressingDispositionHelper类代码示例发布时间:2022-05-22
下一篇:
Java PacketThreadUtil类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

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

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