通过JDBC连接RDS for MySQL实例

使用SSL证书连接实例，即通过证书校验并连接数据库。RDS for MySQL实例不支持X509认证方式。

1. 下载CA证书或捆绑包。
   1. 在“实例管理”页面，单击实例名称进入“概览”页面。
   2. 单击“SSL”处的“下载”。

2. 使用keytool工具通过CA证书生成truststore文件。

   <keytool工具的安装路径> ./keytool.exe -importcert -alias <MySQLCACert> -­file <ca.pem> -keystore <truststore_file> -storepass <password>

   表1 变量说明

   变量	说明
   <keytool工具的安装路径>	请替换为JDK或JRE安装路径的bin目录，例如C:\Program Files (x86)\Java\jdk­11.0.7\bin。
   <MySQLCACert>	请设置truststore文件的名称。建议设置为具有业务意义的名称，便于后续识别。
   <ca.pem>	请替换为1中下载解压后CA证书的名称，例如ca.pem。
   <truststore_file>	请设置truststore文件的存放路径。
   <password>	请设置truststore文件的密码。

   代码示例（使用JDK安装路径下的keytool工具生成truststore文件）：

   Owner:  CN=MySQL_Server_5.7.17_Auto_Generated_CA_Certificate
   Issuer: CN=MySQL_Server_5.7.17_Auto_Generated_CA_Certificate 
   Serial number: 1
   Valid from: Thu Feb 16 11:42:43 EST 2017 until: Sun Feb 14 11:42:43 EST 2027 
   Certificate fingerprints:
        MD5: 18:87:97:37:EA:CB:0B:5A:24:AB:27:76:45:A4:78:C1
        SHA1: 2B:0D:D9:69:2C:99:BF:1E:2A:25:4E:8D:2D:38:B8:70:66:47:FA:ED 
        SHA256:C3:29:67:1B:E5:37:06:F7:A9:93:DF:C7:B3:27:5E:09:C7:FD:EE:2D:18:86:F4:9C:40:D8:26:CB:DA:95: A0:24
        Signature algorithm name: SHA256withRSA Subject Public Key Algorithm: 2048-bit RSA key 
        Version: 1
        Trust this certificate? [no]: y
        Certificate was added to keystore

3. 通过JDBC连接MySQL数据库，代码中的JDBC连接格式如下：

   jdbc:mysql://<instance_ip>:<instance_port>/<database_name>?param1=value1&param2=value2&param3=value3&param4=value4&param5=value5&param6=value6

   表2 参数说明

   参数	说明
   <instance_ip>	请替换为实例的IP地址。 说明： 如果通过弹性云服务器连接，“instance_ip”是实例的“内网地址”。您可以在该实例的“连接管理”页面查看。 如果通过公网连接，“instance_ip”为该实例已绑定的“弹性公网IP”。您可以在该实例的“连接管理”页面查看。
   <instance_port>	请替换为实例的数据库端口，默认为3306。 说明： 您可以在该实例的“连接管理”页面查看。
   <database_name>	请替换为连接实例使用的数据库名，默认为mysql。
   <param1>	requireSSL，用于设置服务端是否支持SSL连接。取值如下： true：支持。 false：不支持。 说明： requireSSL与其他连接参数、sslMode之间的关系请参考表3。
   <param2>	useSSL，用于设置客户端是否使用SSL连接服务端。取值如下： true：使用。 false：不使用。 说明： useSSL与其他连接参数、sslMode之间的关系请参考表3。
   <param3>	verifyServerCertificate，客户端是否校验服务端的证书。取值如下： true：校验。 false：不校验。 说明： verifyServerCertificate与其他连接参数、sslMode之间的关系请参考表3。
   <param4>	trustCertificateKeyStoreUrl，取值为file:<truststore_file>。 <truststore_file>请替换为2中truststore文件设置的存储路径。
   <param5>	trustCertificateKeyStorePassword，取值为2中truststore文件设置的密码。
   <param6>	allowMultiQueries，用于设置是否支持多语句执行。 设置为true：允许应用代码把多个SQL用分号拼接，批处理SQL语句。

   表3 连接参数与SSLMode的关系说明

   useSSL	requireSSL	verifyServerCertificate	sslMode
   false	不涉及	不涉及	DISABLED
   true	false	false	PREFERRED
   true	true	false	REQUIRED
   true	不涉及	true	VERIFY_CA

   代码示例（连接MySQL数据库的java代码）：

   import java.sql.Connection; 
   import java.sql.DriverManager; 
   import java.sql.ResultSet; 
   import java.sql.Statement;
   import java.sql.SQLException; 
   
   // 认证用的用户名和密码直接写到代码中有很大的安全风险，建议在配置文件或者环境变量中存放(密码应密文存放，使用时解密)，确保安全。
   // 本示例以用户名和密码保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量(环境变量名称请根据自身情况进行设置)EXAMPLE_USERNAME_ENV和EXAMPLE_PASSWORD_ENV。
   public class JDBCTest { 
      
   
       String USER = System.getenv("EXAMPLE_USERNAME_ENV");         
       String PASS = System.getenv("EXAMPLE_PASSWORD_ENV");
   
       public static void main(String[] args) {
           Connection conn = null; 
           Statement stmt = null;
   
          // url中所需的连接参数根据实际情况配置
          String url = "jdbc:mysql://<instance_ip>:<instance_port>/<database_name>?param1=value1&param2=value2";
    
           try { 
               Class.forName("com.mysql.cj.jdbc.Driver");
               conn = DriverManager.getConnection(url, USER, PASS);
    
               stmt = conn.createStatement(); 
               String sql = "show status like 'ssl%'";
               ResultSet rs = stmt.executeQuery(sql); 
   
               int columns = rs.getMetaData().getColumnCount();
               for (int i = 1; i <= columns; i++) {
                   System.out.print(rs.getMetaData().getColumnName(i));
                   System.out.print("\t");
               }
   
               while (rs.next()) { 
                   System.out.println(); 
                   for (int i = 1; i <= columns; i++) {
                       System.out.print(rs.getObject(i));
                       System.out.print("\t");
                   } 
               }
               rs.close(); 
               stmt.close(); 
               conn.close(); 
           } catch (SQLException se) { 
               se.printStackTrace(); 
           } catch (Exception e) { 
               e.printStackTrace(); 
           } finally { 
               // release resource .... 
           } 
       } 
   }

该方式不对服务端进行证书校验，用户无需下载SSL证书。

1. 通过JDBC连接RDS for MySQL数据库实例，代码中的JDBC连接格式如下：

   jdbc:mysql://<instance_ip>:<instance_port>/<database_name>?useSSL=false&param1=value1

   表4 变量说明

   变量	说明
   <instance_ip>	请替换为实例的IP地址。 说明： 如果通过弹性云服务器连接，“instance_ip”是实例的“内网地址”。您可以在该实例的“连接管理”页面查看。 如果通过公网连接，“instance_ip”为该实例已绑定的“弹性公网IP”。您可以在该实例的“连接管理”页面查看。
   <instance_port>	请替换为实例的数据库端口，默认为3306。 说明： 您可以在该实例的“连接管理”页面查看。
   <database_name>	请替换为连接实例使用的数据库名，默认为mysql。
   <param1>	allowMultiQueries，用于设置是否支持多语句执行。 设置为true：允许应用代码把多个SQL用分号拼接，批处理SQL语句。

   代码示例（连接MySQL数据库的java代码）：

   import java.sql.Connection;
   import java.sql.DriverManager;
   import java.sql.ResultSet;
   import java.sql.Statement;
   // 认证用的用户名和密码直接写到代码中有很大的安全风险，建议在配置文件或者环境变量中存放(密码应密文存放，使用时解密)，确保安全。
   // 本示例以用户名和密码保存在环境变量中为例，运行本示例前请先在本地环境中设置环境变量(环境变量名称请根据自身情况进行设置)EXAMPLE_USERNAME_ENV和EXAMPLE_PASSWORD_ENV。
   
   public class MyConnTest {
   	final public static void main(String[] args) {
   		Connection conn = null;
   
                   // url中所需的连接参数根据实际情况配置
                   String url = "jdbc:mysql://<instance_ip>:<instance_port>/<database_name>?param1=value1&param2=value2";
                   String USER = System.getenv("EXAMPLE_USERNAME_ENV");         
                   String PASS = System.getenv("EXAMPLE_PASSWORD_ENV");
   		try {
   			Class.forName("com.mysql.jdbc.Driver");
   			
                           conn = DriverManager.getConnection(url,USER,PASS);
   			System.out.println("Database connected");
   
   			Statement stmt = conn.createStatement();
   			ResultSet rs = stmt.executeQuery("SELECT * FROM mytable WHERE columnfoo = 500");
   			while (rs.next()) {
   				System.out.println(rs.getString(1));
   			}
   			rs.close();
   			stmt.close();
   			conn.close();
   		} catch (Exception e) {
   			e.printStackTrace();
   			System.out.println("Test failed");
   		} finally {
   			// release resource ....
   		}
   	}
   }