test_class.declarator: pgConnection
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private PgConnection pgConnection;
test_class.type: PgConnection
test_class.var_name: pgConnection
test_class.declarator: pgReplicationConnection
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private PGReplicationConnection pgReplicationConnection;
test_class.type: PGReplicationConnection
test_class.var_name: pgReplicationConnection
test_class.declarator: chainedStreamBuilder
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private ChainedStreamBuilder chainedStreamBuilder;
test_class.type: ChainedStreamBuilder
test_class.var_name: chainedStreamBuilder
test_class.declarator: chainedLogicalStreamBuilder
test_class.modifier: @Mock
      private
test_class.original_string: @Mock
      private ChainedLogicalStreamBuilder chainedLogicalStreamBuilder;
test_class.type: ChainedLogicalStreamBuilder
test_class.var_name: chainedLogicalStreamBuilder
test_class.declarator: logicalReplication
test_class.modifier: private
test_class.original_string: private LogicalReplication logicalReplication;
test_class.type: LogicalReplication
test_class.var_name: logicalReplication
test_class.file: shardingsphere-scaling/shardingsphere-scaling-postgresql/src/test/java/org/apache/shardingsphere/scaling/postgresql/wal/LogicalReplicationTest.java
test_class.identifier: LogicalReplicationTest
test_case.body: @Test
      public void assertCreatePgConnectionSuccess() throws SQLException {
          Connection pgConnection = logicalReplication.createPgConnection(
                  new JDBCScalingDataSourceConfiguration("jdbc:h2:mem:test;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=PostgreSQL", "root", "root"));
          assertFalse(pgConnection.isClosed());
      }
test_case.class_method_signature: LogicalReplicationTest.assertCreatePgConnectionSuccess()
test_case.full_signature: @Test public void assertCreatePgConnectionSuccess()
test_case.identifier: assertCreatePgConnectionSuccess
test_case.invocations: createPgConnection assertFalse isClosed
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void assertCreatePgConnectionSuccess()
focal_class.file: shardingsphere-scaling/shardingsphere-scaling-postgresql/src/main/java/org/apache/shardingsphere/scaling/postgresql/wal/LogicalReplication.java
focal_class.identifier: LogicalReplication
focal_class.class_method_signature: LogicalReplication.createPgConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_class.full_signature: public Connection createPgConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_class.identifier: createPgConnection
focal_class.modifiers: public
focal_class.parameters: (final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_class.return: Connection
focal_class.signature: Connection createPgConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_class.class_method_signature: LogicalReplication.createConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_class.full_signature: private Connection createConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_class.identifier: createConnection
focal_class.modifiers: private
focal_class.parameters: (final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_class.return: Connection
focal_class.signature: Connection createConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_class.class_method_signature: LogicalReplication.createReplicationStream(final Connection pgConnection, final String slotName, final LogSequenceNumber startPosition)
focal_class.full_signature: public PGReplicationStream createReplicationStream(final Connection pgConnection, final String slotName, final LogSequenceNumber startPosition)
focal_class.identifier: createReplicationStream
focal_class.modifiers: public
focal_class.parameters: (final Connection pgConnection, final String slotName, final LogSequenceNumber startPosition)
focal_class.return: PGReplicationStream
focal_class.signature: PGReplicationStream createReplicationStream(final Connection pgConnection, final String slotName, final LogSequenceNumber startPosition)
focal_method.body: public Connection createPgConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig) throws SQLException {
          return createConnection(jdbcDataSourceConfig);
      }
focal_method.class_method_signature: LogicalReplication.createPgConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_method.full_signature: public Connection createPgConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_method.identifier: createPgConnection
focal_method.invocations: createConnection
focal_method.modifiers: public
focal_method.parameters: (final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)
focal_method.return: Connection
focal_method.signature: Connection createPgConnection(final JDBCScalingDataSourceConfiguration jdbcDataSourceConfig)