RxJava-Jdbc 0.5.7:如何获取最后插入id

Question

使用代码示例:https://github.com/davidmoten/rxjava-jdbc

如何从mysql获得最后插入id ?

database.update("insert into person(name,sex,age,dob) values(?,?,?,?)")
.parameters(person.getName(), person.isMale(), person.getAge(), person.getDob());

倾向于使用非阻塞响应模式

在JDBC中，我可以这样做:

Statement stmt = db.prepareStatement(query, Statement.RETURN_GENERATED_KEYS);
numero = stmt.executeUpdate();
ResultSet rs = stmt.getGeneratedKeys();
if (rs.next()){
    risultato=rs.getInt(1);
}

Answer 1

根据文档:

Observable<Integer> key = db.update("insert into note(text) values(?)")
  .parameter("hello", "there")
  .returnGeneratedKeys()
  .getAs(Integer.class);

所以，如果你想要具体的Integer值而不是Observable你可以这样做:

Observable<Integer> key = db.update("insert into note(text) values(?)")
  .parameter("hello", "there")
  .returnGeneratedKeys()
  .getAs(Integer.class);