diff --git a/src/mysql/connection.cr b/src/mysql/connection.cr index fec3ad6..fbcca34 100644 --- a/src/mysql/connection.cr +++ b/src/mysql/connection.cr @@ -23,17 +23,17 @@ class MySql::Connection < DB::Connection else initial_catalog = nil end - + if !context.uri.query.nil? params = HTTP::Params.parse(context.uri.query.to_s) end - + if !params.nil? && params.has_key?("socket") @socket = UNIXSocket.new(params["socket"]) else @socket = TCPSocket.new(host, port) end - + handshake = read_packet(Protocol::HandshakeV10) write_packet(1) do |packet|