<dependency>
<groupId>com.twitter</groupId>
<artifactId>finagle-mysql_2.11</artifactId>
<version>19.6.0</version>
</dependency>
properties
finagle {
}
import com.twitter.finagle.Mysql;
Mysql.Client client = Mysql.client
.withCredentials("username", "password")
.newRichClient("localhost:3306");
import com.twitter.finagle.Mysql;
import com.twitter.util.Future;
import com.twitter.finagle.mysql.Client;
import com.twitter.finagle.mysql.Row;
import com.twitter.finagle.mysql.Result;
import com.twitter.finagle.mysql.ResultSet;
Future<Result> resultFuture = client
.query("SELECT * FROM users")
.onSuccess(result -> {
ResultSet resultSet = result.asInstanceOf[ResultSet];
while (resultSet.hasNext()) {
Row row = resultSet.next();
int id = row.getInt("id");
String name = row.getString("name");
String email = row.getString("email");
System.out.println("User: " + id + ", " + name + ", " + email);
}
});
import com.twitter.finagle.Mysql;
import com.twitter.util.Future;
import com.twitter.finagle.mysql.Client;
import com.twitter.finagle.mysql.Result;
Future<Result> resultFuture = client
.query("INSERT INTO users (name, email) VALUES ('John Doe', 'john@example.com')")
.onSuccess(result -> {
System.out.println("New user inserted!");
});
