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"));