Verbindung zwischen Java und Alibaba Cloud RDS: Wie erreicht man hochverfügbare und skalierbare Datenbankdienste?

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class RDSConnectionExample {
   public static void main(String[] args) {
      // RDS连接参数
      String url = "jdbc:mysql://rdsxxx.mysql.rds.aliyuncs.com:3306/testdb";
      String username = "root";
      String password = "yourpassword";
   
      // 加载数据库驱动
      try {
         Class.forName("com.mysql.cj.jdbc.Driver");
      } catch (ClassNotFoundException e) {
         e.printStackTrace();
      }
      
      // 建立数据库连接
      try (Connection conn = DriverManager.getConnection(url, username, password)) {
         Statement stmt = conn.createStatement();
         String sql = "SELECT * FROM user";
         ResultSet rs = stmt.executeQuery(sql);
         
         // 处理数据结果集
         while(rs.next()){
            int id  = rs.getInt("id");
            String name = rs.getString("name");
            int age = rs.getInt("age");
            
            System.out.println("id: " + id + ", name: " + name + ", age: " + age);
         }
      } catch (SQLException e) {
         e.printStackTrace();
      }
   }
}

import com.mysql.cj.jdbc.MysqlDataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class RDSReadWriteSplitExample {
   public static void main(String[] args) {
      // RDS连接参数
      String url = "jdbc:mysql:loadbalance://rdsxxx.mysql.rds.aliyuncs.com:3306/testdb";
      String username = "root";
      String password = "yourpassword";

      // 创建读写分离数据源
      MysqlDataSource ds = new MysqlDataSource();
      ds.setURL(url);
      ds.setUser(username);
      ds.setPassword(password);
      ds.setReadOnlyPropagatesToServer(true);

      try (Connection conn = ds.getConnection()) {
         Statement stmt = conn.createStatement();
         String sql = "SELECT * FROM user";
         ResultSet rs = stmt.executeQuery(sql);

         // 处理数据结果集
         while (rs.next()) {
            int id = rs.getInt("id");
            String name = rs.getString("name");
            int age = rs.getInt("age");

            System.out.println("id: " + id + ", name: " + name + ", age: " + age);
         }
      } catch (SQLException e) {
         e.printStackTrace();
      }
   }
}

import org.apache.shardingsphere.driver.api.ShardingSphereDataSourceFactory;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;

public class RDSDataShardingExample {
   public static void main(String[] args) {
      // RDS连接参数
      String url = "jdbc:mysql://localhost:3306/shardingsphere_db";
      String username = "root";
      String password = "root";

      // 创建数据源配置
      Map<String, DataSource> dataSourceMap = new HashMap<>();
      dataSourceMap.put("ds0", createDataSource("ds0", url));
      dataSourceMap.put("ds1", createDataSource("ds1", url));

      // 创建ShardingSphere数据源
      DataSource dataSource;
      try {
         dataSource = ShardingSphereDataSourceFactory.createDataSource(dataSourceMap, getProperties());
      } catch (SQLException e) {
         throw new RuntimeException("Create data source error", e);
      }

      try (Connection conn = dataSource.getConnection()) {
         Statement stmt = conn.createStatement();
         String sql = "SELECT * FROM user";
         ResultSet rs = stmt.executeQuery(sql);

         // 处理数据结果集
         while (rs.next()) {
            int id = rs.getInt("id");
            String name = rs.getString("name");
            int age = rs.getInt("age");

            System.out.println("id: " + id + ", name: " + name + ", age: " + age);
         }
      } catch (SQLException e) {
         e.printStackTrace();
      }
   }

   // 创建数据源
   private static DataSource createDataSource(String dataSourceName, String url) {
      MysqlDataSource ds = new MysqlDataSource();
      ds.setURL(url);
      ds.setUser(username);
      ds.setPassword(password);
      return ds;
   }

   // 获取ShardingSphere属性配置
   private static Properties getProperties(){
      Properties properties = new Properties();
      properties.setProperty("sql.show", Boolean.TRUE.toString());
      return properties;
   }
}