11from abc import ABC
22from typing import List , Union
33
4- from sqlalchemy import and_ , select , update , text
4+ from sqlalchemy import and_ , select , text
55from sqlalchemy .dialects .postgresql import insert
66from sqlalchemy .sql .elements import BinaryExpression
77from sqlalchemy .sql .schema import Table
@@ -302,7 +302,7 @@ def upsert(self, *,
302302 unique_fields : List [str ],
303303 upsert_one = True ,
304304 ) -> BinaryExpression :
305- raise NotImplemented ( 'upsert only support PostgreSQL' )
305+ raise NotImplementedError
306306
307307
308308class SQLAlchemyMySQLQueryService (SQLAlchemyGeneralSQLQueryService ):
@@ -324,7 +324,7 @@ def upsert(self, *,
324324 unique_fields : List [str ],
325325 upsert_one = True ,
326326 ) -> BinaryExpression :
327- raise NotImplemented ( 'upsert only support PostgreSQL' )
327+ raise NotImplementedError
328328
329329
330330class SQLAlchemyMariaDBQueryService (SQLAlchemyGeneralSQLQueryService ):
@@ -346,7 +346,7 @@ def upsert(self, *,
346346 unique_fields : List [str ],
347347 upsert_one = True ,
348348 ) -> BinaryExpression :
349- raise NotImplemented ( 'upsert only support PostgreSQL' )
349+ raise NotImplementedError
350350
351351
352352class SQLAlchemyOracleQueryService (SQLAlchemyGeneralSQLQueryService ):
@@ -368,7 +368,7 @@ def upsert(self, *,
368368 unique_fields : List [str ],
369369 upsert_one = True ,
370370 ) -> BinaryExpression :
371- raise NotImplemented ( 'upsert only support PostgreSQL' )
371+ raise NotImplementedError
372372
373373
374374class SQLAlchemyMSSqlQueryService (SQLAlchemyGeneralSQLQueryService ):
@@ -390,7 +390,7 @@ def upsert(self, *,
390390 unique_fields : List [str ],
391391 upsert_one = True ,
392392 ) -> BinaryExpression :
393- raise NotImplemented ( 'upsert only support PostgreSQL' )
393+ raise NotImplementedError
394394
395395
396396class SQLAlchemyNotSupportQueryService (SQLAlchemyGeneralSQLQueryService ):
@@ -412,4 +412,4 @@ def upsert(self, *,
412412 unique_fields : List [str ],
413413 upsert_one = True ,
414414 ) -> BinaryExpression :
415- raise NotImplemented ( 'upsert only support PostgreSQL' )
415+ raise NotImplementedError
0 commit comments