Advertisement
Guest User

Untitled

a guest
Jan 23rd, 2017
102
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.66 KB | None | 0 0
  1. JDBCClient client = JDBCClient.createShared(vertx, new JsonObject()
  2. .put("url", "jdbc:oracle:thin:@localhost:8787:TEST")
  3. .put("driver_class", "oracle.jdbc.OracleDriver")
  4. .put("user", "user")
  5. .put("password", "****"));
  6.  
  7. client.getConnection( connection -> {
  8. if (connection.succeeded()) {
  9. SQLConnection con = connection.result();
  10.  
  11. JsonObject params = new JsonObject()
  12. .put("query", "{ call ? := package.procedure(?) }")
  13. .put("paramsIn", new JsonArray().addNull().add(89))
  14. .put("paramsOut", new JsonArray().add(JDBCType.REF_CURSOR));
  15.  
  16. con.callWithParams(params.getString("query"), params.getJsonArray("paramsIn"), params.getJsonArray("paramsOut"), query -> {
  17. if(query.succeeded()){
  18. ResultSet rs = query.result();
  19. System.out.println(rs.toJson().toString())
  20. }else{
  21. System.out.println(req.body() + query.cause().toString());
  22. }
  23. });
  24. } else {
  25. System.out.println(connection.cause().toString())
  26. }
  27. });
  28.  
  29. CallableStatement stmt = conn.prepareCall("{ call ? := package.procedure(?) }");
  30.  
  31. stmt.registerOutParameter(1, OracleTypes.CURSOR);
  32. stmt.setInt(2, 89);
  33.  
  34. stmt.execute();
  35. ResultSet rs = (ResultSet)stmt.getObject(1);
  36.  
  37. JsonObject params = new JsonObject()
  38. .put("query", "{ call ? := package.procedure(?) }")
  39. .put("paramsOut", new JsonArray().add(JDBCType.REF_CURSOR));
  40. .put("paramsIn", new JsonArray().addNull().add(89))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement