import com.twitter.finagle.Mysql;
import com.twitter.finagle.mysql.Client;
import com.twitter.finagle.mysql.Result;
import com.twitter.util.Future;
public class FinagleMySQLExample {
public static void main(String[] args) {
Client client = Mysql.client().newRichClient("localhost:3306");
Future<Client> connectFuture = client.connect();
connectFuture.onSuccess(c -> {
Future<Result> queryFuture = c.query("SELECT * FROM users");
queryFuture.onSuccess(result -> {
System.out.println(result.rows());
});
c.close();
});
connectFuture.get();
}
}
import com.twitter.finagle.Mysql;
import com.twitter.finagle.mysql.Client;
import com.twitter.util.Duration;
public class FinagleMySQLConfigExample {
public static void main(String[] args) {
ClientConfig config = ClientConfig
.defaultConfig()
.withConnectionPoolSize(10)
.withConnectTimeout(Duration.fromSeconds(10));
Client client = Mysql.client().withCustomConfiguration(config).newRichClient("localhost:3306");
// ...
}
}
