<dependency>
<groupId>com.twitter</groupId>
<artifactId>finagle-mysql_2.12</artifactId>
<version>21.2.0</version>
</dependency>
import com.twitter.finagle.mysql.Client;
import com.twitter.finagle.mysql.Mysql;
import com.twitter.util.Future;
import com.twitter.util.FutureEventListener;
public class FinagleMySQLExample {
public static void main(String[] args) {
Client client = Mysql.client().newRichClient("localhost:3306");
Future<Client> connectFuture = client.connect();
connectFuture.addEventListener(new FutureEventListener<Client>() {
@Override
public void onSuccess(Client client) {
Future<Object> queryFuture = client.query("SELECT * FROM users");
queryFuture.addEventListener(new FutureEventListener<Object>() {
@Override
public void onSuccess(Object result) {
System.out.println(result);
client.close();
}
@Override
public void onFailure(Throwable throwable) {
throwable.printStackTrace();
client.close();
}
});
}
@Override
public void onFailure(Throwable throwable) {
throwable.printStackTrace();
client.close();
}
});
}
}
