import com.twitter.finagle.Mysql import com.twitter.finagle.mysql._ import com.twitter.util.{Await, Future} class MySQLClient { val client: ServiceFactory[Request, Result] = Mysql.client .withCredentials("username", "password") .newRichClient("localhost:3306") def executeQuery(query: String): String = { val request: Request = QueryRequest(query) val response: Future[Result] = client(request) val result: Result = Await.result(response) result.toString } } import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; class JDBCClient { Connection connection; public JDBCClient() { connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/database", "username", "password"); } public String executeQuery(String query) throws Exception { Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery(query); String result = ""; while (resultSet.next()) { result += resultSet.getString("column_name") + " "; } return result; } } import java.util.List; import org.apache.ibatis.session.SqlSession; import org.apache.ibatis.session.SqlSessionFactory; import org.apache.ibatis.session.SqlSessionFactoryBuilder; class MyBatisClient { SqlSession session; public MyBatisClient() { SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(MyBatisClient.class.getResourceAsStream("mybatis-config.xml")); session = factory.openSession(); } public String executeQuery(String query) { List<String> result = session.selectList("namespace.selectQuery", query); return result.toString(); } }


上一篇:
下一篇:
切换中文