소스 검색

bug fix: sql writer::apply

Steve Nyemba 4 년 전
부모
커밋
898455f23c
1개의 변경된 파일4개의 추가작업 그리고 4개의 파일을 삭제
  1. 4 4
      transport/sql.py

+ 4 - 4
transport/sql.py

@@ -60,12 +60,12 @@ class SQLRW :
         """
         cursor = self.conn.cursor()
         try:
-            if "insert" in _sql .lower() or "update" in _sql.lower() :
-                # Executing a command i.e no expected return values ...
-                cursor.execute(_sql)
-            else:
+            if "select" in _sql.lower() :
                 cursor.close()
                 return pd.read_sql(_sql,self.conn)
+            else:
+                # Executing a command i.e no expected return values ...
+                cursor.execute(_sql)
             
         finally:
             cursor.close()