分析型数据库如何进行业务系统连接并进行查询?

8.1 业务系统连接分析型数据库并进行查询


使用jdbc odbc php python R-Mysql等连接分析型数据库的例子和注意事项介绍，以及流控、retry链接、异常处理等方法。
分析型数据库集群系统部署在阿里云环境中，用户在部署业务应用系统时，尽可能保证业务系统与阿里云环境的网络联通性，如购买阿里云ECS主机（ https://www.aliyun.com/product/ecs/）作为业务系统的服务器。

JDBC直接连接分析型数据库


最简单直接的连接并访问分析型数据库的方式是通过JDBC，分析型数据库支持MySQL自带的客户端以及大部分版本的mysql-jdbc驱动。

支持的mysql jdbc驱动版本号

• 5.0系列： 5.0.2，5.0.3，5.0.4，5.0.5，5.0.7，5.0.8
• 5.1系列：5.1.1，5.1.2，5.1.3，5.1.4，5.1.5，5.1.6，5.1.7，5.1.8，5.1.11，5.1.12，5.1.13，5.1.14，5.1.15，5.1.16，5.1.17，5.1.18，5.1.19，5.1.20，5.1.21，5.1.22，5.1.23，5.1.24，5.1.25，5.1.26，5.1.27，5.1.28，5.1.29，5.1.31，5.1.32，5.1.33，5.1.34
• 5.4系列
• 5.5系列

1. Connection connection = null;
2. Statement statement = null;
3. ResultSet rs = null;
4. try {
5.     Class.forName("com.mysql.jdbc.Driver");
6.     String url = "jdbc:mysql://mydbname.ads-hz.aliyuncs.com:5544/my_ads_db?useUnicode=true&characterEncoding=UTF-8";
8.     Properties connectionProps = new Properties();
9.     connectionProps.put("user", "my_access_key_id");
10.     connectionProps.put("password", "my_access_key_secret");
12.     connection = DriverManager.getConnection(url, connectionProps);
13.     statement = connection.createStatement();
15.     String query = "select count(*) from information_schema.tables";
16.     rs = statement.executeQuery(query);
18.     while (rs.next()) {
19.         System.out.println(rs.getObject(1));
20.     }
22. } catch (ClassNotFoundException e) {
23.     e.printStackTrace();
24. } catch (SQLException e) {
25.     e.printStackTrace();
26. } catch (Exception e) {
27.     e.printStackTrace();
28. } finally {
29.     if (rs != null) {
30.         try {
31.             rs.close();
32.         } catch (SQLException e) {
33.             e.printStackTrace();
34.         }
35.     }
36.     if (statement != null) {
37.         try {
38.             statement.close();
39.         } catch (SQLException e) {
40.             e.printStackTrace();
41.         }
42.     }
43.     if (connection != null) {
44.         try {
45.             connection.close();
46.         } catch (SQLException e) {
47.             e.printStackTrace();
48.         }
49.     }
50. }

1. public static final int MAX_QUERY_RETRY_TIMES = 3;
3. public static Connection conn = null;
4. public static Statement statement = null;
5. public static ResultSet rs = null;
7. public static void main(String[] args) throws ClassNotFoundException {
8.     String yourDB = "user_db";
9.     String username = "my_access_key_id";
10.     String password = "my_access_key_secret";
12.     Class.forName("com.mysql.jdbc.Driver");
13.     String url = "jdbc:mysql://mydbname.ads-hz.aliyuncs.com:5544/" + yourDB + "?useUnicode=true&characterEncoding=UTF-8";
15.     Properties connectionProps = new Properties();
16.     connectionProps.put("user", username);
17.     connectionProps.put("password", password);
19.     String query = "select id from test4dmp.test limit 10";
21.     int retryTimes = 0;
22.     while (retryTimes < MAX_QUERY_RETRY_TIMES) {
23.         try {
24.             getConn(url, connectionProps);
25.             execQuery(query);
26.             break; // Query execution successfully, break out.
28.         } catch (SQLException