Tests: Get rid of ResourceWarning messages about unclosed sockets

ResourceWarning: unclosed <socket.socket fd=12, family=AddressFamily.AF_INET, type=SocketKind.SOCK_STREAM, proto=6, laddr=('127.0.0.1', 52797), raddr=('127.0.0.1', 44209)>

Author: amotl

src/crate/client/doctests/blob.txt

@@ -39,9 +39,10 @@ Store from a file::
     >>> file_blob = container.put(f)
     >>> file_blob
     'ea6e03a4a4ee8a2366fe5a88af2bde61797973ea'
+    >>> f.close()
 
 If the blob data is not provided as a seekable stream the hash must be
-provided explicetely::
+provided explicitly::
 
     >>> import hashlib
     >>> string_data = b'String data'

src/crate/client/doctests/client.txt

@@ -13,6 +13,7 @@ The client provides a ``connect()`` function which is used to establish a
 connection, the first argument is the url of the server to connect to::
 
     >>> connection = client.connect(crate_host)
+    >>> connection.close()
 
 CrateDB is a clustered database providing high availability through
 replication. In order for clients to make use of this property it is
@@ -21,22 +22,26 @@ respond, the request is automatically routed to the next server::
 
     >>> invalid_host = 'http://not_responding_host:4200'
     >>> connection = client.connect([invalid_host, crate_host])
+    >>> connection.close()
 
 If no ``servers`` are given, the default one ``http://127.0.0.1:4200`` is used::
 
     >>> connection = client.connect()
     >>> connection.client._active_servers
     ['http://127.0.0.1:4200']
+    >>> connection.close()
 
 If the option ``error_trace`` is set to ``True``, the client will print a whole
 traceback if a server error occurs::
 
     >>> connection = client.connect([crate_host], error_trace=True)
+    >>> connection.close()
 
 It's possible to define a default timeout value in seconds for all servers
 using the optional parameter ``timeout``::
 
     >>> connection = client.connect([crate_host, invalid_host], timeout=5)
+    >>> connection.close()
 
 Authentication
 --------------
@@ -50,13 +55,15 @@ connect::
     >>> connection.client.username
     'trusted_me'
     >>> connection.client.password
+    >>> connection.close()
 
 The username for trusted users can also be provided in the URL::
 
     >>> connection = client.connect(['http://trusted_me@' + crate_host])
     >>> connection.client.username
     'trusted_me'
     >>> connection.client.password
+    >>> connection.close()
 
 To connect to CrateDB with as a user that requires password authentication, you
 also need to provide ``password`` as argument for the ``connect()`` call::
@@ -68,6 +75,7 @@ also need to provide ``password`` as argument for the ``connect()`` call::
     'me'
     >>> connection.client.password
     'my_secret_pw'
+    >>> connection.close()
 
 The authentication credentials can also be provided in the URL::
 
@@ -76,6 +84,7 @@ The authentication credentials can also be provided in the URL::
     'me'
     >>> connection.client.password
     'my_secret_pw'
+    >>> connection.close()
 
 
 Default Schema
@@ -86,6 +95,7 @@ provide the ``schema`` keyword argument in the ``connect()`` method, like so::
 
     >>> connection = client.connect([crate_host],
     ...                             schema='custom_schema')
+    >>> connection.close()
 
 Inserting Data
 ==============

src/crate/client/doctests/cursor.txt

@@ -263,6 +263,9 @@ For completeness' sake the cursor description is updated nonetheless::
     ...     "duration":123
     ... })
 
+.. Hidden: close connection
+
+    >>> connection.close()
 
 Usually ``executemany`` sends the ``bulk_args`` parameter to the crate sql 
 endpoint which was introduced with Crate 0.42.0.
@@ -313,3 +316,6 @@ closed connection an ``ProgrammingError`` exception will be raised::
     ...
     crate.client.exceptions.ProgrammingError: Cursor closed
 
+.. Hidden: close connection
+
+    >>> connection.close()

src/crate/client/sqlalchemy/doctests/itests.txt

@@ -220,3 +220,7 @@ Refresh "characters" table:
     >>> import pprint
     >>> pprint.pprint(char.details)
     {'name': {'first': 'Trillian', 'last': 'Dent'}, 'size': 45}
+
+.. Hidden: close connection
+
+    >>> connection.close()

src/crate/client/test_http.py

@@ -116,13 +116,15 @@ def test_connection_reset_exception(self):
     def test_no_connection_exception(self):
         client = Client()
         self.assertRaises(ConnectionError, client.sql, 'select foo')
+        client.close()
 
     @patch(REQUEST)
     def test_http_error_is_re_raised(self, request):
         request.side_effect = Exception
 
         client = Client()
         self.assertRaises(ProgrammingError, client.sql, 'select foo')
+        client.close()
 
     @patch(REQUEST)
     def test_programming_error_contains_http_error_response_content(self, request):
@@ -283,6 +285,7 @@ def test_socket_options_contain_keepalive(self):
         self.assertTrue(
             (socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1) in conn_kw['socket_options']
         )
+        client.close()
 
 
 @patch(REQUEST, fail_sometimes)

src/crate/client/tests.py

@@ -264,13 +264,11 @@ def do_GET(self):
             self.end_headers()
             self.wfile.write(payload)
 
-    def __init__(self):
+    def setUp(self):
         self.server = self.HttpsServer(
             (self.HOST, self.PORT),
             self.HttpsHandler
         )
-
-    def setUp(self):
         thread = threading.Thread(target=self.serve_forever)
         thread.daemon = True  # quit interpreter when only thread exists
         thread.start()
@@ -283,6 +281,7 @@ def serve_forever(self):
 
     def tearDown(self):
         self.server.shutdown()
+        self.server.server_close()
 
     def isUp(self):
         """