首页 > 代码库 > 用vertx compose写链式操作
用vertx compose写链式操作
public static void handleAddCollection(RoutingContext routingContext){ Future<Void> futn=Future.future(); futn.setHandler(a->{ System.out.println("4最后一步:"); sendData(routingContext,"ok"); return; }); Future<UpdateResult> fut1 = Future.future(); JsonArray params=new JsonArray().add("123").add("测试标题").add("http://baidu.com").add(""); String sql="insert into mytable (userid,title,url,pic) values (?,?,?,?)"; myDBConnecton.updateWithParams(sql,params,fut1.completer()); fut1.compose(v-> { if(v.getUpdated()>0)System.out.println("2 插入成功了"); else System.out.println("2 插入失败了"); Future<ResultSet> fut2 = Future.future(); myDBConnecton.query("select * from mytable", fut2.completer()); return fut2; }).compose(v -> { List<JsonObject> data=http://www.mamicode.com/v.getRows();"3查询结果为:"+data.toString()); Future<Void> fut3 = Future.future(); myDBConnecton.updateWithParams(sql,params,fut1.completer()); futn.complete(); },futn); }
执行结果显示:
2 插入成功了 3查询结果为:[{"id":1,"userid":120,"title":"测试标题","url":"http://baidu.com","pic":"","add_time":null}, {"id":2,"userid":120,"title":"测试标题","url":"http://baidu.com","pic":"","add_time":null}] 4最后一步:
本文出自 “北京看看” 博客,谢绝转载!
用vertx compose写链式操作
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。