#NEWLINE# def create_marker_table( self ) : #NEWLINE# #INDENT# "\n        Create marker table if it doesn't exist.\n        Use a separate connection since the transaction might have to be reset.\n        " #NEWLINE# connection = self . connect ( ) #NEWLINE# try : #NEWLINE# #INDENT# connection . execute_non_query ( ' CREATE TABLE {marker_table} (\n                        id            BIGINT    NOT NULL IDENTITY(1,1),\n                        update_id     VARCHAR(128)  NOT NULL,\n                        target_table  VARCHAR(128),\n                        inserted      DATETIME DEFAULT(GETDATE()),\n                        PRIMARY KEY (update_id)\n                    )\n                ' . format ( marker_table = self . marker_table ) ) #NEWLINE# #UNINDENT# except _mssql . MSSQLDatabaseException as e : #NEWLINE# #INDENT# if ( e . number == 2714 ) : #NEWLINE# #INDENT# pass #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# raise #NEWLINE# #UNINDENT# #UNINDENT# connection . close ( )