diff --git a/setup.py b/setup.py index dd4b292..ec4edf5 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ def read(fname): return open(os.path.join(os.path.dirname(__file__), fname)).read() args = { "name":"data-transport", - "version":"1.5.2", + "version":"1.5.3", "author":"The Phi Technology LLC","author_email":"info@the-phi.com", "license":"MIT", "packages":["transport"]} diff --git a/transport/sql.py b/transport/sql.py index d2b0b36..282938f 100644 --- a/transport/sql.py +++ b/transport/sql.py @@ -59,7 +59,7 @@ class SQLRW : # _info['host'] = 'localhost' if 'host' not in _args else _args['host'] # # _info['port'] = SQLWriter.PROVIDERS[_args['provider']] if 'port' not in _args else _args['port'] # _info['port'] = SQLWriter.REFERENCE[_provider]['port'] if 'port' not in _args else _args['port'] - + self.lock = False if 'lock' not in _args else _args['lock'] if 'username' in _args or 'user' in _args: key = 'username' if 'username' in _args else 'user' _info['user'] = _args[key] @@ -272,7 +272,8 @@ class SQLWriter(SQLRW,Writer): if _info.shape[0] == 0 : return - SQLRW.lock.acquire() + if self.lock : + SQLRW.lock.acquire() if self._engine is not None: # pd.to_sql(_info,self._engine) @@ -299,7 +300,8 @@ class SQLWriter(SQLRW,Writer): if self._engine is None : self.conn.commit() - SQLRW.lock.release() + if self.lock : + SQLRW.lock.release() # cursor.close() pass def close(self):