new SqlCommand() //
.setDebugMode(true)
.setConnection(Connector.get())
.setCommandText("SELECT" +
" e.entry_id," +
" e.entry_name," +
" e.entry_english_name," +
" e.entry_description," +
" e.entry_sop_path," +
" e.entry_cordon," +
" e.role_name," +
" e.entry_enabled," +
" e.group_id," +
" e.group_name" +
" FROM mv_wrk e" +
" WHERE" +
" (&entry_id IS NULL OR UPPER(e.entry_id) LIKE UPPER(&entry_id))" +
" AND (&entry_name IS NULL OR UPPER(e.entry_name) LIKE UPPER(&entry_name))" +
" AND (&entry_english_name IS NULL OR UPPER(e.entry_english_name) LIKE UPPER(&entry_english_name))" +
" AND (&entry_enabled IS NULL OR e.entry_enabled = &entry_enabled)" +
" ORDER BY e.entry_id ASC")
.addParameter("&entry_id", OracleDataType.VARCHAR2)
.addParameter("&entry_name", OracleDataType.VARCHAR2, null)
.addParameter(new SqlParameter("&entry_english_name", OracleDataType.VARCHAR2))
.addParameter(new SqlParameter("&entry_enabled", OracleDataType.NUMBER).setValue(null))
.setAdapter(new QueryAdapter() {
@Override
public void executedQuery(SqlArgument arg) throws Exception {
ResultSet rs;
if ((rs = ((QueryArgument) arg).resultset) == null)
return;
while (rs.next()) {
System.err.println(DataMap.fill(rs));
}
}
})
.query();
batch
new SqlCommand()
.setDebugMode(true)
.setDebugOut(System.err)
.setConnection(ConnectionUtil.get())
.addCommand("/* 1. &name 2. &aid 3. &time */ INSERT INTO access_log VALUES(&aid, &name, &time)", CommandType.Text, CommandMode.Batch)
.addCommand("SELECT * FROM access_log WHERE rownum < &rows ORDER BY time DESC")
.addParameter("&rows", OracleDataType.INT, 5)
.setAdapter(new QueryListener() {
@Override
public boolean executingQuery(SqlArgument arg) throws Exception {
if (arg.first && arg.mode == CommandMode.Batch)
for (int i = 0; i < 3; i++) {
arg.addBatchParameters(
new SqlParameter("&name", OracleDataType.VARCHAR2, "bruce"),
new SqlParameter("&aid", OracleDataType.VARCHAR2, UUID.randomUUID().toString()),
new SqlParameter("&time", OracleDataType.DATE, DateTime.now().toTimestamp())
);
}
return true;
}
@Override
public void executedQuery(SqlArgument arg) throws Exception {
if (arg.first) {
UpdateArgument ua = (UpdateArgument) arg;
System.err.println(Arrays.toString(ua.batchResult));
} else {
QueryArgument argument = (QueryArgument) arg;
if (argument.resultset != null)
while (argument.resultset.next()) {
System.err.println(DataMap.fill(argument.resultset));
}
}
}
})
.query();
Posts
