关于daocache 自定义sqlCallback 问题

RT
自定义的callback 在第二次访问的时候不能得到数据库值

Set<Integer> permIdSet = new HashSet();
		for (Integer roleId : roleIds) {
			Sql sqlPermIds = Sqls.create("select permission_id from $table $condition");
			sqlPermIds.vars().set("table", "t_role_permission");
			sqlPermIds.setCondition(Cnd.where("role_id", "=", roleId));
			sqlPermIds.setCallback(new SqlCallback() {

				@Override
				public Object invoke(Connection conn, ResultSet rs, Sql sql) throws SQLException {
					while (rs.next()) {
						permIdSet.add(rs.getInt(1));
					}
					return null;
				}
			});
			dao.execute(sqlPermIds);
		}

wendal

1楼•3073天前

那是肯定的, 因为callback不会执行了

得作为返回值

				@Override
				public Object invoke(Connection conn, ResultSet rs, Sql sql) throws SQLException {
				     Set<Integer> permIdSet = new HashSet();
					while (rs.next()) {
						permIdSet.add(rs.getInt(1));
					}
					return permIdSet;
				}

Rekoe

2楼•3073天前

那怎么得到这个数据

Rekoe

3楼•3073天前

@wendal
自定义sql的可以得到那个数据么如果用了缓存

wendal

4楼•3073天前

@Rekoe sql.getObject

来自炫酷的 NutzCN

Rekoe

5楼•3073天前

ok
方式如下

Sql sqlPermIds = Sqls.create("select permission_id from $table $condition");
			sqlPermIds.vars().set("table", "t_role_permission");
			sqlPermIds.setCondition(Cnd.where("role_id", "=", roleId));
			sqlPermIds.setCallback(new SqlCallback() {
				Set<Integer> permIdSet = new HashSet();

				@Override
				public Object invoke(Connection conn, ResultSet rs, Sql sql) throws SQLException {
					while (rs.next()) {
						permIdSet.add(rs.getInt(1));
					}
					return permIdSet;
				}
			});
			dao.execute(sqlPermIds);
			sqlPermIds.getObject(Set.class)

请先登陆