import com.twitter.finagle.mysql.Client; import com.twitter.finagle.mysql.Result; import com.twitter.util.Future; ... futureResult.onSuccess(result -> { List<Row> rows = result.rows(); for (Row row : rows) { String username = row.getString("username"); int age = row.getInt("age"); ... } }).onFailure(throwable -> { ... }); import com.twitter.finagle.mysql.Client; import com.twitter.finagle.mysql.ClientConfig; import com.twitter.finagle.mysql.util.Defaults; import com.twitter.io.Reader; ... ClientConfig config = ClientConfig .builder() .host("localhost") .user("root") .password("password") .database("mydb") .connectTimeout(Defaults.CONNECT_TIMEOUT) .requestTimeout(Defaults.REQUEST_TIMEOUT) .build(); ClientConnect.setClient(Client .configured(config) .readTimeout(Reader.EOFTimeout) .newRichClient("mysql"));


上一篇:
下一篇:
切换中文