Java SqlFunction类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: setDataSource

import org.springframework.jdbc.object.SqlFunction; //导入依赖的package包/类
/**
 * Set the datasource to use for this database interface.
 * <p>
 * @param ds The datasource as determined in the application context.
 */
   public void setDataSource(DataSource ds)
{
	mDatasource = ds;

	mLRPDRetriever = new SqlFunction(ds, GET_LRPD_SQL, new int[] {java.sql.Types.INTEGER}, String.class);
	mLRPDRetriever.compile();
}

开发者ID:iwethey，项目名称:iwethey，代码行数:13，代码来源:JdbcAdminManager.java

示例2: formatTimestamp

import org.springframework.jdbc.object.SqlFunction; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
@Override
public String formatTimestamp() {
    SqlFunction<String> sqlFunction =
            new SqlFunction<String>(localTransactionDataSource, "{ ? = call FORMAT_TIMESTAMP(?) }", new int[]{Types.TIMESTAMP});
    return (String) sqlFunction.runGeneric(new Date[]{new Date()});
}

开发者ID:vladmihalcea，项目名称:vladmihalcea.wordpress.com，代码行数:10，代码来源:SpringSqlFunctionTimeService.java

示例3: DeviationDAOCachedMergingMySQL

import org.springframework.jdbc.object.SqlFunction; //导入依赖的package包/类
public DeviationDAOCachedMergingMySQL(DataSource dataSource, SqlScriptService sqlScriptService) {
    super(sqlScriptService);
    setDataSource(dataSource);

    QUERY_GET_CACHED_DEVIATION = new DeviationQuery(getDataSource(),
            "SELECT * FROM so_deviation_cache WHERE tenantId = ? AND item1TypeId = ? AND item2TypeId = ? AND item1Id = ? and item2Id = ? LIMIT 1");
    QUERY_GET_CACHED_DEVIATION.declareParameter(new SqlParameter("tenantId", Types.INTEGER));
    QUERY_GET_CACHED_DEVIATION.declareParameter(new SqlParameter("item1TypeId", Types.INTEGER));
    QUERY_GET_CACHED_DEVIATION.declareParameter(new SqlParameter("item2TypeId", Types.INTEGER));
    QUERY_GET_CACHED_DEVIATION.declareParameter(new SqlParameter("item1Id", Types.INTEGER));
    QUERY_GET_CACHED_DEVIATION.declareParameter(new SqlParameter("item2Id", Types.INTEGER));
    QUERY_GET_CACHED_DEVIATION.compile();

    QUERY_GET_DEVIATION = new DeviationQuery(getDataSource(),
            "SELECT * FROM so_deviation WHERE tenantId = ? AND item1TypeId = ? AND item2TypeId = ? AND item1Id = ? and item2Id = ? LIMIT 1");
    QUERY_GET_DEVIATION.declareParameter(new SqlParameter("tenantId", Types.INTEGER));
    QUERY_GET_DEVIATION.declareParameter(new SqlParameter("item1TypeId", Types.INTEGER));
    QUERY_GET_DEVIATION.declareParameter(new SqlParameter("item2TypeId", Types.INTEGER));
    QUERY_GET_DEVIATION.declareParameter(new SqlParameter("item1Id", Types.INTEGER));
    QUERY_GET_DEVIATION.declareParameter(new SqlParameter("item2Id", Types.INTEGER));
    QUERY_GET_DEVIATION.compile();

    QUERY_ORDER_DEVIATION = makeOrderedDeviationsQuery(getDataSource(), false, false);
    QUERY_ORDER_DEVIATION.compile();

    QUERY_ORDER_DEVIATION_DENOM = makeOrderedDeviationsQuery(getDataSource(), true, false);
    QUERY_ORDER_DEVIATION_DENOM.compile();

    QUERY_ORDER_DEVIATION_LIMIT = makeOrderedDeviationsQuery(getDataSource(), false, true);
    QUERY_ORDER_DEVIATION_LIMIT.compile();

    QUERY_ORDER_DEVIATION_DENOMLIMIT = makeOrderedDeviationsQuery(getDataSource(), true, true);
    QUERY_ORDER_DEVIATION_DENOMLIMIT.compile();

    QUERY_GET_ITEMIDS = new MappingSqlQuery<Integer>(getDataSource(),
            "SELECT item1Id AS item FROM so_deviation WHERE tenantId = ? AND item1TypeId = ?\n" +
                    "UNION SELECT item2Id AS item FROM so_deviation WHERE tenantId = ? AND item2TypeId = ?") {
        @Override
        protected Integer mapRow(final ResultSet rs, final int rowNum) throws SQLException {
            return rs.getInt("item");
        }
    };
    QUERY_GET_ITEMIDS.declareParameter(new SqlParameter("tenantId1", Types.INTEGER));
    QUERY_GET_ITEMIDS.declareParameter(new SqlParameter("item1TypeId", Types.INTEGER));
    QUERY_GET_ITEMIDS.declareParameter(new SqlParameter("tenantId2", Types.INTEGER));
    QUERY_GET_ITEMIDS.declareParameter(new SqlParameter("item2TypeId", Types.INTEGER));
    QUERY_GET_ITEMIDS.compile();

    QUERY_INSERT_CACHED_DEVIATION = new SqlUpdate(getDataSource(),
            "INSERT INTO so_deviation_cache(tenantId, item1Id, item2Id, item1TypeId, item2TypeId, numerator, denominator, written)\n" +
                    "        VALUES (?, ?, ?, ?, ?, ?, ?, b'0')\n" +
                    "ON DUPLICATE KEY UPDATE\n" +
                    "        numerator = numerator + VALUES(numerator),\n" +
                    "        denominator = denominator + VALUES(denominator),\n" +
                    "        written = b'0'",
            new int[]{Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.INTEGER, Types.DOUBLE,
                    Types.BIGINT});
    QUERY_INSERT_CACHED_DEVIATION.compile();

    QUERY_INSERT_TEMP_DEVIATIONS = new InsertTempDeviationsQuery(getDataSource());

    QUERY_FLUSH_CACHE = new FlushCacheQuery(getDataSource());

    QUERY_GET_CACHE_SIZE = new SqlFunction(getDataSource(),
            "SELECT count(*) AS count FROM so_deviation_cache",
            NO_TYPES);
}

开发者ID:major2015，项目名称:easyrec_major，代码行数:68，代码来源:DeviationDAOCachedMergingMySQL.java

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