diff --git a/src/main/java/io/aiven/connect/jdbc/dialect/MySqlDatabaseDialect.java b/src/main/java/io/aiven/connect/jdbc/dialect/MySqlDatabaseDialect.java
index 20894e3f..ca914620 100644
--- a/src/main/java/io/aiven/connect/jdbc/dialect/MySqlDatabaseDialect.java
+++ b/src/main/java/io/aiven/connect/jdbc/dialect/MySqlDatabaseDialect.java
@@ -22,6 +22,7 @@
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.Collection;
+import java.util.Properties;
 
 import org.apache.kafka.connect.data.Date;
 import org.apache.kafka.connect.data.Decimal;
@@ -123,6 +124,14 @@ protected String getSqlType(final SinkRecordField field) {
         }
     }
 
+    @Override
+    protected Properties addConnectionProperties(final Properties properties) {
+        properties.put("allowLoadLocalInFile", Boolean.FALSE.toString());
+        properties.put("allowUrlInLocalInfile", Boolean.FALSE.toString());
+        properties.put("autoDeserialize", Boolean.FALSE.toString());
+        return properties;
+    }
+
     @Override
     public String buildUpsertQueryStatement(
         final TableId table,