Rename __check_open() -> _check_open()

Author: 1st1

asyncpg/connection.py

@@ -118,7 +118,7 @@ async def add_listener(self, channel, callback):
                 **channel**: name of the channel the notification was sent to;
                 **payload**: the payload.
         """
-        self.__check_open()
+        self._check_open()
         if channel not in self._listeners:
             await self.fetch('LISTEN {}'.format(channel))
             self._listeners[channel] = set()
@@ -182,7 +182,7 @@ def transaction(self, *, isolation='read_committed', readonly=False,
         .. _`PostgreSQL documentation`: https://www.postgresql.org/docs/\
                                         current/static/sql-set-transaction.html
         """
-        self.__check_open()
+        self._check_open()
         return transaction.Transaction(self, isolation, readonly, deferrable)
 
     async def execute(self, query: str, *args, timeout: float=None) -> str:
@@ -213,7 +213,7 @@ async def execute(self, query: str, *args, timeout: float=None) -> str:
         .. versionchanged:: 0.5.4
            Made it possible to pass query arguments.
         """
-        self.__check_open()
+        self._check_open()
 
         if not args:
             return await self._protocol.query(query, timeout)
@@ -244,7 +244,7 @@ async def executemany(self, command: str, args,
 
         .. versionadded:: 0.7.0
         """
-        self.__check_open()
+        self._check_open()
 
         if 'timeout' in kw:
             timeout = kw.pop('timeout')
@@ -317,7 +317,7 @@ def cursor(self, query, *args, prefetch=None, timeout=None):
 
         :return: A :class:`~cursor.CursorFactory` object.
         """
-        self.__check_open()
+        self._check_open()
         return cursor.CursorFactory(self, query, None, args,
                                     prefetch, timeout)
 
@@ -329,7 +329,7 @@ async def prepare(self, query, *, timeout=None):
 
         :return: A :class:`~prepared_stmt.PreparedStatement` instance.
         """
-        self.__check_open()
+        self._check_open()
         stmt = await self._get_statement(query, timeout, named=True)
         return prepared_stmt.PreparedStatement(self, query, stmt)
 
@@ -342,7 +342,7 @@ async def fetch(self, query, *args, timeout=None) -> list:
 
         :return list: A list of :class:`Record` instances.
         """
-        self.__check_open()
+        self._check_open()
         return await self._execute(query, args, 0, timeout)
 
     async def fetchval(self, query, *args, column=0, timeout=None):
@@ -359,7 +359,7 @@ async def fetchval(self, query, *args, column=0, timeout=None):
 
         :return: The value of the specified column of the first record.
         """
-        self.__check_open()
+        self._check_open()
         data = await self._execute(query, args, 1, timeout)
         if not data:
             return None
@@ -374,7 +374,7 @@ async def fetchrow(self, query, *args, timeout=None):
 
         :return: The first row as a :class:`Record` instance.
         """
-        self.__check_open()
+        self._check_open()
         data = await self._execute(query, args, 1, timeout)
         if not data:
             return None
@@ -395,7 +395,7 @@ async def set_type_codec(self, typename, *,
                         data.  If ``False`` (the default), the data is
                         expected to be encoded/decoded in text.
         """
-        self.__check_open()
+        self._check_open()
 
         if self._type_by_name_stmt is None:
             self._type_by_name_stmt = await self.prepare(
@@ -425,7 +425,7 @@ async def set_builtin_type_codec(self, typename, *,
                         (defaults to 'public')
         :param codec_name:  The name of the builtin codec.
         """
-        self.__check_open()
+        self._check_open()
 
         if self._type_by_name_stmt is None:
             self._type_by_name_stmt = await self.prepare(
@@ -470,13 +470,13 @@ def terminate(self):
         self._protocol.abort()
 
     async def reset(self):
-        self.__check_open()
+        self._check_open()
         self._listeners.clear()
         reset_query = self._get_reset_query()
         if reset_query:
             await self.execute(reset_query)
 
-    def __check_open(self):
+    def _check_open(self):
         if self.is_closed():
             raise exceptions.InterfaceError('connection is closed')
 

asyncpg/prepared_stmt.py

@@ -60,7 +60,7 @@ def get_parameters(self):
             #   (Type(oid=23, name='int4', kind='scalar', schema='pg_catalog'),
             #    Type(oid=25, name='text', kind='scalar', schema='pg_catalog'))
         """
-        self.__check_open()
+        self._check_open()
         return self._state._get_parameters()
 
     def get_attributes(self):
@@ -85,7 +85,7 @@ def get_attributes(self):
             #       type=Type(oid=26, name='oid', kind='scalar',
             #                 schema='pg_catalog')))
         """
-        self.__check_open()
+        self._check_open()
         return self._state._get_attributes()
 
     def cursor(self, *args, prefetch=None,
@@ -99,7 +99,7 @@ def cursor(self, *args, prefetch=None,
 
         :return: A :class:`~cursor.CursorFactory` object.
         """
-        self.__check_open()
+        self._check_open()
         return cursor.CursorFactory(self._connection, self._query,
                                     self._state, args, prefetch,
                                     timeout)
@@ -190,14 +190,14 @@ async def fetchrow(self, *args, timeout=None):
         return data[0]
 
     async def __bind_execute(self, args, limit, timeout):
-        self.__check_open()
+        self._check_open()
         protocol = self._connection._protocol
         data, status, _ = await protocol.bind_execute(
             self._state, args, '', limit, True, timeout)
         self._last_status = status
         return data
 
-    def __check_open(self):
+    def _check_open(self):
         if self._state.closed:
             raise exceptions.InterfaceError('prepared statement is closed')