Set TRANSACTION_ISOLATION_LEVEL config in MySQL, PostgreSQL & SQL Server plugins

Author: sgarg-CS

mssql-plugin/docs/SQL Server-connector.md

@@ -22,12 +22,14 @@ authentication. Optional for databases that do not require authentication.
 
 **Password:** Password to use to connect to the specified database.
 
-**Transaction Isolation Level** The transaction isolation level of the databse connection
-- TRANSACTION_READ_COMMITTED: No dirty reads. Non-repeatable reads and phantom reads are possible.
+**Transaction Isolation Level** The transaction isolation level of the database connection
+- TRANSACTION_READ_COMMITTED (default): No dirty reads. Non-repeatable reads and phantom reads are possible.
 - TRANSACTION_SERIALIZABLE: No dirty reads. Non-repeatable and phantom reads are prevented.
 - TRANSACTION_REPEATABLE_READ: No dirty reads. Prevents non-repeatable reads, but phantom reads are still possible.
 - TRANSACTION_READ_UNCOMMITTED: Allows dirty reads (reading uncommitted changes from other transactions). Non-repeatable reads and phantom reads are possible.
 
+For more details on the Transaction Isolation Levels supported in SQL Server, refer to the [SQL Server documentation](https://learn.microsoft.com/en-us/sql/t-sql/statements/set-transaction-isolation-level-transact-sql?view=sql-server-ver16)
+
 **Authentication Type:** Indicates which authentication method will be used for the connection. Use 'SQL Login'. to
 connect to a SQL Server using username and password properties. Use 'Active Directory Password' to connect to an Azure
 SQL Database/Data Warehouse using an Azure AD principal name and password.

mssql-plugin/docs/SqlServer-batchsink.md

@@ -46,12 +46,14 @@ an Azure SQL Database/Data Warehouse using an Azure AD principal name and passwo
 
 **Password:** Password to use to connect to the specified database.
 
-**Transaction Isolation Level** The transaction isolation level of the databse connection
-- TRANSACTION_READ_COMMITTED: No dirty reads. Non-repeatable reads and phantom reads are possible.
+**Transaction Isolation Level** The transaction isolation level of the database connection
+- TRANSACTION_READ_COMMITTED (default): No dirty reads. Non-repeatable reads and phantom reads are possible.
 - TRANSACTION_SERIALIZABLE: No dirty reads. Non-repeatable and phantom reads are prevented.
 - TRANSACTION_REPEATABLE_READ: No dirty reads. Prevents non-repeatable reads, but phantom reads are still possible.
 - TRANSACTION_READ_UNCOMMITTED: Allows dirty reads (reading uncommitted changes from other transactions). Non-repeatable reads and phantom reads are possible.
 
+For more details on the Transaction Isolation Levels supported in SQL Server, refer to the [SQL Server documentation](https://learn.microsoft.com/en-us/sql/t-sql/statements/set-transaction-isolation-level-transact-sql?view=sql-server-ver16)
+
 **Instance Name:** SQL Server instance name to connect to. When it is not specified, a
 connection is made to the default instance. For the case where both the instanceName and port are specified,
 see the notes for port. If you specify a Virtual Network Name in the Server connection property, you cannot

mssql-plugin/docs/SqlServer-batchsource.md

@@ -56,12 +56,14 @@ an Azure SQL Database/Data Warehouse using an Azure AD principal name and passwo
 
 **Password:** Password to use to connect to the specified database.
 
-**Transaction Isolation Level** The transaction isolation level of the databse connection
-- TRANSACTION_READ_COMMITTED: No dirty reads. Non-repeatable reads and phantom reads are possible.
+**Transaction Isolation Level** The transaction isolation level of the database connection
+- TRANSACTION_READ_COMMITTED (default): No dirty reads. Non-repeatable reads and phantom reads are possible.
 - TRANSACTION_SERIALIZABLE: No dirty reads. Non-repeatable and phantom reads are prevented.
 - TRANSACTION_REPEATABLE_READ: No dirty reads. Prevents non-repeatable reads, but phantom reads are still possible.
 - TRANSACTION_READ_UNCOMMITTED: Allows dirty reads (reading uncommitted changes from other transactions). Non-repeatable reads and phantom reads are possible.
 
+For more details on the Transaction Isolation Levels supported in SQL Server, refer to the [SQL Server documentation](https://learn.microsoft.com/en-us/sql/t-sql/statements/set-transaction-isolation-level-transact-sql?view=sql-server-ver16)
+
 **Instance Name:** SQL Server instance name to connect to. When it is not specified, a
 connection is made to the default instance. For the case where both the instanceName and port are specified,
 see the notes for port. If you specify a Virtual Network Name in the Server connection property, you cannot

mssql-plugin/src/main/java/io/cdap/plugin/mssql/SqlServerSink.java

@@ -177,6 +177,11 @@ public Map<String, String> getDBSpecificArguments() {
                                                          packetSize, queryTimeout);
     }
 
+    @Override
+    public String getTransactionIsolationLevel() {
+      return connection.getTransactionIsolationLevel();
+    }
+
     @Override
     public String getConnectionString() {
       return String.format(SqlServerConstants.SQL_SERVER_CONNECTION_STRING_FORMAT,

mysql-plugin/docs/MySQL-connector.md

@@ -25,9 +25,11 @@ authentication. Optional for databases that do not require authentication.
 **Transaction Isolation Level** The transaction isolation level of the databse connection
 - TRANSACTION_READ_COMMITTED: No dirty reads. Non-repeatable reads and phantom reads are possible.
 - TRANSACTION_SERIALIZABLE: No dirty reads. Non-repeatable and phantom reads are prevented.
-- TRANSACTION_REPEATABLE_READ: No dirty reads. Prevents non-repeatable reads, but phantom reads are still possible.
+- TRANSACTION_REPEATABLE_READ (default): No dirty reads. Prevents non-repeatable reads, but phantom reads are still possible.
 - TRANSACTION_READ_UNCOMMITTED: Allows dirty reads (reading uncommitted changes from other transactions). Non-repeatable reads and phantom reads are possible.
 
+For more details on the Transaction Isolation Levels supported in MySQL, refer to the  [MySQL documentation](https://dev.mysql.com/doc/refman/8.4/en/innodb-transaction-isolation-levels.html)
+
 **Connection Arguments:** A list of arbitrary string tag/value pairs as connection arguments. These arguments
 will be passed to the JDBC driver, as connection arguments, for JDBC drivers that may need additional configurations.
 This is a semicolon-separated list of key-value pairs, where each pair is separated by a equals '=' and specifies

mysql-plugin/docs/Mysql-batchsink.md

@@ -42,9 +42,11 @@ You also can use the macro function ${conn(connection-name)}.
 **Transaction Isolation Level** The transaction isolation level of the databse connection
 - TRANSACTION_READ_COMMITTED: No dirty reads. Non-repeatable reads and phantom reads are possible.
 - TRANSACTION_SERIALIZABLE: No dirty reads. Non-repeatable and phantom reads are prevented.
-- TRANSACTION_REPEATABLE_READ: No dirty reads. Prevents non-repeatable reads, but phantom reads are still possible.
+- TRANSACTION_REPEATABLE_READ (default): No dirty reads. Prevents non-repeatable reads, but phantom reads are still possible.
 - TRANSACTION_READ_UNCOMMITTED: Allows dirty reads (reading uncommitted changes from other transactions). Non-repeatable reads and phantom reads are possible.
 
+For more details on the Transaction Isolation Levels supported in MySQL, refer to the  [MySQL documentation](https://dev.mysql.com/doc/refman/8.4/en/innodb-transaction-isolation-levels.html)
+
 **Connection Arguments:** A list of arbitrary string key/value pairs as connection arguments. These arguments
 will be passed to the JDBC driver as connection arguments for JDBC drivers that may need additional configurations.
 

mysql-plugin/docs/Mysql-batchsource.md

@@ -49,12 +49,14 @@ For example, 'SELECT MIN(id),MAX(id) FROM table'. Not required if numSplits is s
 
 **Password:** Password to use to connect to the specified database.
 
-**Transaction Isolation Level** The transaction isolation level of the databse connection
+**Transaction Isolation Level** The transaction isolation level of the database connection
 - TRANSACTION_READ_COMMITTED: No dirty reads. Non-repeatable reads and phantom reads are possible.
 - TRANSACTION_SERIALIZABLE: No dirty reads. Non-repeatable and phantom reads are prevented.
-- TRANSACTION_REPEATABLE_READ: No dirty reads. Prevents non-repeatable reads, but phantom reads are still possible.
+- TRANSACTION_REPEATABLE_READ (default): No dirty reads. Prevents non-repeatable reads, but phantom reads are still possible.
 - TRANSACTION_READ_UNCOMMITTED: Allows dirty reads (reading uncommitted changes from other transactions). Non-repeatable reads and phantom reads are possible.
 
+For more details on the Transaction Isolation Levels supported in MySQL, refer to the  [MySQL documentation](https://dev.mysql.com/doc/refman/8.4/en/innodb-transaction-isolation-levels.html)
+
 **Connection Arguments:** A list of arbitrary string key/value pairs as connection arguments. These arguments
 will be passed to the JDBC driver as connection arguments for JDBC drivers that may need additional configurations.
 

mysql-plugin/src/main/java/io/cdap/plugin/mysql/MysqlSink.java

@@ -194,6 +194,11 @@ public Map<String, String> getDBSpecificArguments() {
                                                      trustCertificateKeyStorePassword, false);
     }
 
+    @Override
+    public String getTransactionIsolationLevel() {
+      return connection.getTransactionIsolationLevel();
+    }
+
     @Override
     public MysqlConnectorConfig getConnection() {
       return connection;

mysql-plugin/widgets/MySQL-connector.json

@@ -42,7 +42,7 @@
               "TRANSACTION_REPEATABLE_READ",
               "TRANSACTION_SERIALIZABLE"
             ],
-            "default": "TRANSACTION_SERIALIZABLE"
+            "default": "TRANSACTION_REPEATABLE_READ"
           }
         }
       ]

mysql-plugin/widgets/Mysql-batchsink.json

@@ -76,7 +76,7 @@
               "TRANSACTION_REPEATABLE_READ",
               "TRANSACTION_SERIALIZABLE"
             ],
-            "default": "TRANSACTION_SERIALIZABLE"
+            "default": "TRANSACTION_REPEATABLE_READ"
           }
         },
         {