实时数仓Hologres：传输加密

使用PSQL命令行连接Hologres

• 连接语句。

  PG_USER=<AccessKey ID> 
  PG_PASSWORD=<AccessKey Secret> 
  PG_SSLMODE=<SSL Mode> 
  PG_SSLROOTCERT=<certificate folder> 
  PGSSLMODE=$PG_SSLMODE PGSSLROOTCERT=$PG_SSLROOTCERT PGUSER=$PG_USER PGPASSWORD=$PG_PASSWORD psql -p <Port> -h <Endpoint> -d <Database>

• 参数说明。

  参数	描述
  AccessKey ID	当前阿里云账号的AccessKey ID。 您可以单击AccessKey 管理，获取AccessKey ID。 建议您使用环境变量的方式调用用户名和密码，降低密码泄露风险。
  AccessKey Secret	当前阿里云账号的AccessKey Secret。 您可以单击AccessKey 管理，获取AccessKey Secret。 建议您使用环境变量的方式调用用户名和密码，降低密码泄露风险。
  SSL Mode	PSQL连接Hologres时传输加密的模式配置，取值及其含义如下。 require：使用传输加密，只对数据链路加密。 verify-ca：加密数据链路，同时验证Hologres实例的真实性。 verify-full：加密数据链路，验证Hologres实例的真实性，同时比对证书内的CN或DNS与连接时配置的数据库连接地址是否一致。 disable：不使用传输加密。
  certificate folder	CA证书的存储路径。 如果SSL Mode参数配置的值为verify-ca或verify-full，需要配置此参数。
  Port	Hologres实例的公共网络端口。 示例取值80。
  Endpoint	Hologres实例的公共网络地址。 示例取值xxx-cn-hangzhou.hologres.aliyuncs.com。
  Database	Hologres的数据库名称。 开通Hologres实例后，系统自动创建postgres数据库。 您可以使用postgres数据库链接Hologres，但是该数据库分配到的资源较少，开发实际业务建议您新建数据库。详情请参见创建数据库。 示例取值mydb。

• 连接验证。

  如果将PGSSLMODE设置为require，连接Hologres时出现如下提示，则表示已经使用SSL传输加密连接。

使用JDBC连接Hologres

您使用JDBC连接Hologres时，可以通过连接配置参数ssl和sslmode控制是否使用SSL传输加密。各参数的取值不同，在Hologres中的结果也不同，如下所示。

代码样例如下。

 // 设置Hologres实例的连接地址
 String hostname = "hgxxxxxxx-cn-hangzhou-vpc.hologres.aliyuncs.com:80";
 // 设置Hologres实例的连接端口
 String port = "80";
 // 设置待连接的数据库名
 String dbname = "postgres";

 String jdbcUrl = "jdbc:postgresql://" + hostname + ":" + port + "/" + dbname+"?binaryTransfer=true";

 Properties properties = new Properties();
 // 设置连接数据库的用户名，建议通过环境变量调用。
 properties.setProperty("user", "accessid");
 //设置连接数据库的密码，建议通过环境变量调用。
 properties.setProperty("password", "accesskey");

  // 配置以ssl访问
  properties.setProperty("ssl", "true");

  //设置证书授权机构的公钥名
  properties.setProperty("sslrootcert", path + "/" + "hologres_certificate.crt");

  // 配置ssl模式，可选值为require、verify-ca、verify-full
  properties.setProperty("sslmode", "verify-full");

  try {
      Class.forName("org.postgresql.Driver");
      Connection connection = DriverManager.getConnection(jdbcUrl, properties);
      //本示例中，假设在postgres数据库中存在表example，此处以查询表example数据为例。
      PreparedStatement preparedStatement = connection.prepareStatement("select * from " +
              "example");
      ResultSet resultSet = preparedStatement.executeQuery();
      while (resultSet.next()) {
          ResultSetMetaData rsmd = resultSet.getMetaData();
          int columnCount = rsmd.getColumnCount();
          Map map = new HashMap();
          for (int i = 0; i < columnCount; i++) {
              map.put(rsmd.getColumnName(i + 1).toLowerCase(), resultSet.getObject(i + 1));
          }
          System.out.println(map);
      }
  } catch (Exception exception) {
      exception.printStackTrace();
  }