|
@@ -7,7 +7,6 @@ import org.noear.solon.annotation.Inject;
|
|
|
import org.noear.solon.data.sql.SqlUtils;
|
|
|
|
|
|
import java.sql.SQLException;
|
|
|
-import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
|
|
|
@Component
|
|
@@ -19,8 +18,7 @@ public class JdbcDbRepository implements DbRepository {
|
|
|
public World getWorld(int id) {
|
|
|
try {
|
|
|
return sqlUtils.sql("SELECT id, randomnumber FROM world WHERE id = ?", id)
|
|
|
- .queryRow()
|
|
|
- .toBean(World.class, (r, t) -> new World((int) r.getObject(1), (int) r.getObject(2)));
|
|
|
+ .queryRow((rs) -> new World(rs.getInt(1), rs.getInt(2)));
|
|
|
} catch (Exception e) {
|
|
|
return null;
|
|
|
}
|
|
@@ -28,19 +26,16 @@ public class JdbcDbRepository implements DbRepository {
|
|
|
|
|
|
@Override
|
|
|
public void updateWorlds(List<World> worlds) throws SQLException {
|
|
|
- List<Object[]> values = new ArrayList<>();
|
|
|
- for (World w : worlds) {
|
|
|
- values.add(new Object[]{w.randomNumber, w.id});
|
|
|
- }
|
|
|
-
|
|
|
sqlUtils.sql("UPDATE world SET randomnumber = ? WHERE id = ?")
|
|
|
- .updateBatch(values);
|
|
|
+ .updateBatch(worlds, (ps, w) -> {
|
|
|
+ ps.setInt(1, w.randomNumber);
|
|
|
+ ps.setInt(2, w.id);
|
|
|
+ });
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public List<Fortune> fortunes() throws SQLException {
|
|
|
return sqlUtils.sql("SELECT id, message FROM fortune")
|
|
|
- .queryRowList()
|
|
|
- .toBeanList(Fortune.class, (r, t) -> new Fortune((int) r.getObject(1), (String) r.getObject(2)));
|
|
|
+ .queryRowList((r) -> new Fortune(r.getInt(1), r.getString(2)));
|
|
|
}
|
|
|
}
|