import com.twitter.finagle.mysql.*;
public class MySQLClientExample {
public static void main(String[] args) {
MysqlClient client = Mysql.client().newRichClient("localhost:3306");
String query = "SELECT * FROM users";
QueryResult result = client.query(query);
result.onSuccess(queryResult -> {
for (Row row : queryResult.rows()) {
System.out.println(row.getString("name"));
}
}).onFailure(exception ->
System.out.println("Query failed: " + exception.getMessage())
);
client.close();
}
}
Mysql.Client client = Mysql.client().withCredentials("username", "password")
.withConnectTimeout(Duration.apply(10, TimeUnit.SECONDS))
.withPoolConfig(ConnectionPoolConfig.apply(5, 10))
.newRichClient("localhost:3306");
