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();
}
 

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()});
}
 

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);
}