refactor some core class part5 (#5)

Author: liubao68

src/main/java/io/r2dbc/gaussdb/GaussDBColumnMetadata.java

@@ -110,7 +110,7 @@ public int hashCode() {
 
     @Override
     public String toString() {
-        return "PostgresqlColumnMetadata{" +
+        return "GaussDBColumnMetadata{" +
             ", name='" + this.name + '\'' +
             ", nativeType=" + this.nativeType +
             ", precision=" + this.precision +

src/main/java/io/r2dbc/gaussdb/GaussDBConnectionFactory.java

@@ -186,7 +186,7 @@ private Throwable cannotConnect(Throwable throwable, ConnectionStrategy strategy
             return throwable;
         }
 
-        return new PostgresConnectionException(String.format("Cannot connect to %s", strategy), throwable);
+        return new GaussDBConnectionException(String.format("Cannot connect to %s", strategy), throwable);
     }
 
     @Override
@@ -221,13 +221,13 @@ private Mono<IsolationLevel> getIsolationLevel(io.r2dbc.gaussdb.api.GaussDBConne
             })).defaultIfEmpty(IsolationLevel.READ_COMMITTED).last();
     }
 
-    static class PostgresConnectionException extends R2dbcNonTransientResourceException implements GaussDBException {
+    static class GaussDBConnectionException extends R2dbcNonTransientResourceException implements GaussDBException {
 
         private static final String CONNECTION_DOES_NOT_EXIST = "08003";
 
         private final ErrorDetails errorDetails;
 
-        public PostgresConnectionException(String reason, @Nullable Throwable cause) {
+        public GaussDBConnectionException(String reason, @Nullable Throwable cause) {
             super(reason, CONNECTION_DOES_NOT_EXIST, 0, null, cause);
             this.errorDetails = ErrorDetails.fromCodeAndMessage(CONNECTION_DOES_NOT_EXIST, reason);
         }

src/main/java/io/r2dbc/gaussdb/GaussDBCopyIn.java

@@ -129,7 +129,7 @@ private void copyFail(Sinks.Many<FrontendMessage> sink, AtomicBoolean stop, Stri
 
     @Override
     public String toString() {
-        return "PostgresqlCopyIn{" +
+        return "GaussDBCopyIn{" +
             "context=" + this.context +
             '}';
     }

src/main/java/io/r2dbc/gaussdb/GaussDBReplicationStream.java

@@ -44,7 +44,7 @@
 
 final class GaussDBReplicationStream implements ReplicationStream {
 
-    public static final long POSTGRES_EPOCH_2000_01_01 = 946684800000L;
+    public static final long GAUSSDB_EPOCH_2000_01_01 = 946684800000L;
 
     private static final char KEEP_ALIVE = 'k';
 
@@ -175,7 +175,7 @@ private ByteBuf prepareUpdateStatus(LogSequenceNumber received, LogSequenceNumbe
 
         long now = TimeUnit.NANOSECONDS.toMillis(System.nanoTime());
         // consider range bounds
-        long systemClock = TimeUnit.MICROSECONDS.convert((now - POSTGRES_EPOCH_2000_01_01), TimeUnit.MICROSECONDS);
+        long systemClock = TimeUnit.MICROSECONDS.convert((now - GAUSSDB_EPOCH_2000_01_01), TimeUnit.MICROSECONDS);
 
         return new KeepAliveMessage(received, flushed, applied, systemClock, replyRequired).encode(this.allocator);
     }

src/main/java/io/r2dbc/gaussdb/GaussDBResult.java

@@ -159,7 +159,7 @@ public ReferenceCounted touch(Object hint) {
 
     @Override
     public String toString() {
-        return "PostgresqlResult{" +
+        return "GaussDBResult{" +
             "context=" + this.resources +
             ", messages=" + this.messages +
             '}';

src/main/java/io/r2dbc/gaussdb/GaussDBSegmentResult.java

@@ -73,20 +73,20 @@ private GaussDBSegmentResult(Flux<Segment> segments) {
             }).handle((message, sink) -> {
 
                 if (message instanceof ErrorResponse) {
-                    sink.next(new PostgresErrorSegment((ErrorResponse) message, factory));
+                    sink.next(new GaussDBErrorSegment((ErrorResponse) message, factory));
                     return;
                 }
 
                 if (message instanceof NoticeResponse) {
-                    sink.next(new PostgresNoticeSegment((NoticeResponse) message, factory));
+                    sink.next(new GaussDBNoticeSegment((NoticeResponse) message, factory));
                     return;
                 }
 
                 if (message instanceof CommandComplete) {
 
                     Long rowCount = ((CommandComplete) message).getRows();
                     if (rowCount != null) {
-                        sink.next(new PostgresqlUpdateCountSegment(rowCount));
+                        sink.next(new GaussDBUpdateCountSegment(rowCount));
                     }
                     return;
                 }
@@ -102,11 +102,11 @@ private GaussDBSegmentResult(Flux<Segment> segments) {
                     }
 
                     if (metadata == null) {
-                        sink.error(new IllegalStateException("DataRow without PostgresqlRowMetadata"));
+                        sink.error(new IllegalStateException("DataRow without GaussDBRowMetadata"));
                         return;
                     }
 
-                    sink.next(new PostgresqlRowSegment(GaussDBRow.toRow(resources, (DataRow) message, metadata, rowDescription), (DataRow) message));
+                    sink.next(new GaussDBRowSegment(GaussDBRow.toRow(resources, (DataRow) message, metadata, rowDescription), (DataRow) message));
                     return;
                 }
 
@@ -120,8 +120,8 @@ public Mono<Long> getRowsUpdated() {
             .<Integer>handle((segment, sink) -> {
 
                 try {
-                    if (segment instanceof PostgresErrorSegment) {
-                        sink.error(((PostgresErrorSegment) segment).exception());
+                    if (segment instanceof GaussDBErrorSegment) {
+                        sink.error(((GaussDBErrorSegment) segment).exception());
                         return;
                     }
 
@@ -156,8 +156,8 @@ public <T> Flux<T> map(BiFunction<Row, RowMetadata, ? extends T> f) {
             .handle((segment, sink) -> {
 
                 try {
-                    if (segment instanceof PostgresErrorSegment) {
-                        sink.error(((PostgresErrorSegment) segment).exception());
+                    if (segment instanceof GaussDBErrorSegment) {
+                        sink.error(((GaussDBErrorSegment) segment).exception());
                         return;
                     }
 
@@ -222,7 +222,7 @@ public ReferenceCounted touch(Object hint) {
 
     @Override
     public String toString() {
-        return "PostgresqlSegmentResult{" +
+        return "GaussDBSegmentResult{" +
             "segments=" + this.segments +
             '}';
     }
@@ -231,13 +231,13 @@ static GaussDBSegmentResult toResult(ConnectionResources resources, Flux<Backend
         return new GaussDBSegmentResult(resources, messages, factory);
     }
 
-    static class PostgresqlRowSegment extends AbstractReferenceCounted implements Result.RowSegment {
+    static class GaussDBRowSegment extends AbstractReferenceCounted implements Result.RowSegment {
 
         private final Row row;
 
         private final ReferenceCounted releaseable;
 
-        public PostgresqlRowSegment(Row row, ReferenceCounted releaseable) {
+        public GaussDBRowSegment(Row row, ReferenceCounted releaseable) {
             this.row = row;
             this.releaseable = releaseable;
         }
@@ -259,11 +259,11 @@ public ReferenceCounted touch(Object hint) {
 
     }
 
-    static class PostgresqlUpdateCountSegment implements Result.UpdateCount {
+    static class GaussDBUpdateCountSegment implements Result.UpdateCount {
 
         private final long value;
 
-        public PostgresqlUpdateCountSegment(long value) {
+        public GaussDBUpdateCountSegment(long value) {
             this.value = value;
         }
 
@@ -274,13 +274,13 @@ public long value() {
 
     }
 
-    static class PostgresErrorSegment implements Result.Message {
+    static class GaussDBErrorSegment implements Result.Message {
 
         private final ExceptionFactory factory;
 
         private final ErrorDetails details;
 
-        public PostgresErrorSegment(ErrorResponse response, ExceptionFactory factory) {
+        public GaussDBErrorSegment(ErrorResponse response, ExceptionFactory factory) {
             this.factory = factory;
             this.details = new ErrorDetails(response.getFields());
         }
@@ -307,13 +307,13 @@ public String message() {
 
     }
 
-    static class PostgresNoticeSegment implements Result.Message {
+    static class GaussDBNoticeSegment implements Result.Message {
 
         private final ExceptionFactory factory;
 
         private final ErrorDetails details;
 
-        public PostgresNoticeSegment(NoticeResponse response, ExceptionFactory factory) {
+        public GaussDBNoticeSegment(NoticeResponse response, ExceptionFactory factory) {
             this.factory = factory;
             this.details = new ErrorDetails(response.getFields());
         }

src/main/java/io/r2dbc/gaussdb/GaussDBStatement.java

@@ -173,7 +173,7 @@ public GaussDBStatement fetchSize(int rows) {
 
     @Override
     public String toString() {
-        return "PostgresqlStatement{" +
+        return "GaussDBStatement{" +
             "bindings=" + this.bindings +
             ", context=" + this.resources +
             ", sql='" + this.parsedSql.getSql() + '\'' +

src/main/java/io/r2dbc/gaussdb/MultiHostConnectionStrategy.java

@@ -96,9 +96,9 @@ public Mono<Client> connect(TargetServerType targetServerType) {
             .switchIfEmpty(Mono.error(() -> {
                 Throwable error = exceptionRef.get();
                 if (error == null) {
-                    return new GaussDBConnectionFactory.PostgresConnectionException(String.format("No server matches target type '%s'", targetServerType), null);
+                    return new GaussDBConnectionFactory.GaussDBConnectionException(String.format("No server matches target type '%s'", targetServerType), null);
                 } else {
-                    return new GaussDBConnectionFactory.PostgresConnectionException(String.format("Cannot connect to a host of %s", this.addresses), error);
+                    return new GaussDBConnectionFactory.GaussDBConnectionException(String.format("Cannot connect to a host of %s", this.addresses), error);
                 }
             }));
     }

src/main/java/io/r2dbc/gaussdb/api/CopyInBuilder.java

@@ -32,7 +32,7 @@
 public interface CopyInBuilder {
 
     /**
-     * Postgres parse limit for large messages {@code 2^30 - 1} bytes.
+     * GaussDB parse limit for large messages {@code 2^30 - 1} bytes.
      */
     int MAX_FRAME_SIZE = 0x3fffffff - 1;
 

src/main/java/io/r2dbc/gaussdb/api/GaussDBTransactionDefinition.java

@@ -28,7 +28,7 @@
 public interface GaussDBTransactionDefinition extends TransactionDefinition {
 
     /**
-     * The {@code DEFERRABLE} transaction_mode is a PostgreSQL language extension.
+     * The {@code DEFERRABLE} transaction_mode is a GaussDB language extension.
      */
     Option<Boolean> DEFERRABLE = Option.valueOf("deferrable");
 

src/main/java/io/r2dbc/gaussdb/api/Notification.java

@@ -19,7 +19,7 @@
 import reactor.util.annotation.Nullable;
 
 /**
- * Postgres notification received via {@code LISTEN}.
+ * GaussDB notification received via {@code LISTEN}.
  */
 public interface Notification {
 

src/main/java/io/r2dbc/gaussdb/api/package-info.java

@@ -15,7 +15,7 @@
  */
 
 /**
- * R2DBC driver API with Postgres-specific extensions.
+ * R2DBC driver API with GaussDB-specific extensions.
  */
 
 @NonNullApi

src/main/java/io/r2dbc/gaussdb/client/AbstractPostgresSSLHandlerAdapter.java src/main/java/io/r2dbc/gaussdb/client/AbstractGaussDBSSLHandlerAdapter.java

@@ -33,7 +33,7 @@
 import java.net.SocketAddress;
 import java.util.concurrent.CompletableFuture;
 
-abstract class AbstractPostgresSSLHandlerAdapter extends ChannelInboundHandlerAdapter implements GenericFutureListener<Future<Channel>> {
+abstract class AbstractGaussDBSSLHandlerAdapter extends ChannelInboundHandlerAdapter implements GenericFutureListener<Future<Channel>> {
 
     private final SSLConfig sslConfig;
 
@@ -43,7 +43,7 @@ abstract class AbstractPostgresSSLHandlerAdapter extends ChannelInboundHandlerAd
 
     private final CompletableFuture<Void> handshakeFuture;
 
-    AbstractPostgresSSLHandlerAdapter(ByteBufAllocator alloc, SocketAddress socketAddress, SSLConfig sslConfig) {
+    AbstractGaussDBSSLHandlerAdapter(ByteBufAllocator alloc, SocketAddress socketAddress, SSLConfig sslConfig) {
         this.sslConfig = sslConfig;
 
         SSLEngine sslEngine = sslConfig.getSslProvider().get().newEngine(alloc);
@@ -93,7 +93,7 @@ SslHandler getSslHandler() {
     }
 
     /**
-     * Postgres-specific {@link R2dbcPermissionDeniedException}.
+     * GaussDB-specific {@link R2dbcPermissionDeniedException}.
      */
     static final class GaussDBSslException extends R2dbcPermissionDeniedException implements GaussDBException {
 

src/main/java/io/r2dbc/gaussdb/client/BalancedResolverGroup.java

@@ -39,7 +39,7 @@ final class BalancedResolverGroup extends AddressResolverGroup<InetSocketAddress
     static {
 
         INSTANCE = new BalancedResolverGroup();
-        Runtime.getRuntime().addShutdownHook(new Thread(INSTANCE::close, "R2DBC-Postgresql-BalancedResolverGroup-ShutdownHook"));
+        Runtime.getRuntime().addShutdownHook(new Thread(INSTANCE::close, "R2DBC-GaussDB-BalancedResolverGroup-ShutdownHook"));
     }
 
     @Override

src/main/java/io/r2dbc/gaussdb/client/ConnectionContext.java

@@ -28,7 +28,7 @@
  * Value object capturing diagnostic connection context. Allows for log-message post-processing with {@link #getMessage(String) if the logger category for
  * {@code ConnectionContext} is enabled for DEBUG/TRACE logs.
  * <p>
- * Captures also the Postgres process Id.
+ * Captures also the GaussDB process Id.
  *
  * @since 0.8.6
  */
@@ -135,7 +135,7 @@ public ConnectionContext withSslSession(Supplier<SSLSession> sslSession) {
     /**
      * Create a new {@link ConnectionContext} by associating the {@code processId}.
      *
-     * @param processId the Postgres processId.
+     * @param processId the GaussDB processId.
      * @return a new {@link ConnectionContext} with all previously set values and the associated {@code processId}.
      */
     public ConnectionContext withProcessId(int processId) {

src/main/java/io/r2dbc/gaussdb/client/GaussDBStartupParameterProvider.java

@@ -56,7 +56,7 @@ public void accept(StartupMessage.ParameterWriter writer) {
         writer.write("client_encoding", "utf8");
         writer.write("DateStyle", "ISO");
         writer.write("extra_float_digits", "2");
-        writer.write("TimeZone", TimeZoneUtils.createPostgresTimeZone(this.timeZone));
+        writer.write("TimeZone", TimeZoneUtils.createGaussDBTimeZone(this.timeZone));
 
         if (this.options != null) {
             for (Map.Entry<String, String> option : this.options.entrySet()) {

src/main/java/io/r2dbc/gaussdb/client/MultiHostConfiguration.java

@@ -27,7 +27,7 @@
 import static io.r2dbc.gaussdb.GaussDBConnectionConfiguration.DEFAULT_PORT;
 
 /**
- * Connection configuration information for connecting to a cluster of Postgres servers.
+ * Connection configuration information for connecting to a cluster of GaussDB servers.
  *
  * @since 1.0
  */