diff --git a/mysql/lib/dialect/rds_multi_az_mysql_database_dialect.ts b/mysql/lib/dialect/rds_multi_az_mysql_database_dialect.ts
index c18a369a..2689604a 100644
--- a/mysql/lib/dialect/rds_multi_az_mysql_database_dialect.ts
+++ b/mysql/lib/dialect/rds_multi_az_mysql_database_dialect.ts
@@ -137,9 +137,9 @@ export class RdsMultiAZMySQLDatabaseDialect extends MySQLDatabaseDialect impleme
         RdsMultiAZMySQLDatabaseDialect.FETCH_WRITER_HOST_QUERY_COLUMN_NAME
       );
       // The above query returns the writer host id if it is a reader, nothing if the writer.
-      if ((!writerHostId)) {
+      if (!writerHostId) {
         const currentConnection = await this.identifyConnection(targetClient);
-        return currentConnection ? currentConnection : null;
+        return currentConnection ?? null;
       } else {
         return null;
       }
diff --git a/pg/lib/dialect/rds_multi_az_pg_database_dialect.ts b/pg/lib/dialect/rds_multi_az_pg_database_dialect.ts
index e7316113..6c11f86b 100644
--- a/pg/lib/dialect/rds_multi_az_pg_database_dialect.ts
+++ b/pg/lib/dialect/rds_multi_az_pg_database_dialect.ts
@@ -143,11 +143,7 @@ export class RdsMultiAZPgDatabaseDialect extends PgDatabaseDialect implements To
       );
       const currentConnection = await this.identifyConnection(targetClient);
 
-      if (currentConnection === writerHostId) {
-        return currentConnection ? currentConnection : null;
-      } else {
-        return null;
-      }
+      return (currentConnection && currentConnection === writerHostId) ? currentConnection : null;
     } catch (error: any) {
       throw new AwsWrapperError(Messages.get("RdsMultiAZPgDatabaseDialect.invalidQuery", error.message));
     }