Merge pull request zim32#32 from hotdang-ca/feature/unix_socket_conne…

…ction_support Feature/unix socket connection support
bigedev · Jul 27, 2022 · d086f12 · d086f12
2 parents 3ecfc76 + 500df64
commit d086f12
Show file tree

Hide file tree

Showing 2 changed files with 482 additions and 3 deletions.
diff --git a/lib/src/mysql_client/connection.dart b/lib/src/mysql_client/connection.dart
@@ -70,16 +70,20 @@ class MySQLConnection {
   /// SET @@collation_connection=$_collation, @@character_set_client=utf8, @@character_set_connection=utf8, @@character_set_results=utf8
   /// ```
   static Future<MySQLConnection> createConnection({
-    required String host,
+    required dynamic host,
     required int port,
     required String userName,
     required String password,
     bool secure = true,
     String? databaseName,
     String collation = 'utf8_general_ci',
   }) async {
-    final socket = await Socket.connect(host, port);
-    socket.setOption(SocketOption.tcpNoDelay, true);
+    final Socket socket = await Socket.connect(host, port);
+
+    if (socket.address.type != InternetAddressType.unix) {
+      // no support for extensions on sockets
+      socket.setOption(SocketOption.tcpNoDelay, true);
+    }
 
     final client = MySQLConnection._(
       socket: socket,