AtlTriggerDBCopy.SQLiteInserter Class Reference

Collaboration diagram for AtlTriggerDBCopy.SQLiteInserter:

Public Member Functions
	__init__ (self, filename=None)
	commit (self)
	insert (self, statement, data)
	insertBulk (self, statement, data)
	createSchema (self, creationFileName)

Public Attributes
	filename = filename
	connection = None
bool	activeTransaction = False
int	insCountInTrans = 0
int	maxInsertsPerTransaction = 1000
	cursor = self.connection.cursor()

Detailed Description

Definition at line 53 of file AtlTriggerDBCopy.py.

Constructor & Destructor Documentation

__init__()

AtlTriggerDBCopy.SQLiteInserter.__init__	(		self,
			filename = None )

Definition at line 55 of file AtlTriggerDBCopy.py.

    def __init__(self, filename = None):
        self.filename = filename
        self.connection = None
        self.activeTransaction = False
        self.insCountInTrans = 0
        self.maxInsertsPerTransaction = 1000
        if self.filename is None:
            print("Not connected to an output file, will print the insert commands instead")
        import os
        if filename and os.path.exists(filename):
            print(f"Target file {filename} exists already, will abort in order to prevent overwriting")
            raise RuntimeError("Target file already exists")
        if self.filename is not None:
            self.connection = sqlite3.connect(self.filename)
            self.cursor = self.connection.cursor()

Member Function Documentation

commit()

AtlTriggerDBCopy.SQLiteInserter.commit

(

self

)

Definition at line 70 of file AtlTriggerDBCopy.py.

    def commit(self):
        if self.activeTransaction:
            self.cursor.execute('COMMIT')
            self.activeTransaction = False
            self.insCountInTrans = 0
 

createSchema()

AtlTriggerDBCopy.SQLiteInserter.createSchema	(		self,
			creationFileName )

Definition at line 93 of file AtlTriggerDBCopy.py.

    def createSchema(self, creationFileName):
        if self.connection is None:
            return
        with open(creationFileName) as fh:
            print("Creating sqlite db %s from %s" % (self.filename, creationFileName) )
            self.cursor.executescript( fh.read() )
 
 
# class to handle the extraction of schema and data on the oracle side

insert()

AtlTriggerDBCopy.SQLiteInserter.insert	(		self,
			statement,
			data )

Definition at line 76 of file AtlTriggerDBCopy.py.

    def insert(self, statement, data):
        if self.connection is None:
            return            
        if not self.activeTransaction:
            self.cursor.execute('BEGIN TRANSACTION')
            self.activeTransaction = True
        self.cursor.execute(statement, data)
        self.insCountInTrans += 1
        if self.insCountInTrans==self.maxInsertsPerTransaction:
            self.commit()
 

insertBulk()

AtlTriggerDBCopy.SQLiteInserter.insertBulk	(		self,
			statement,
			data )

Definition at line 87 of file AtlTriggerDBCopy.py.

    def insertBulk(self, statement, data):
        if self.connection is None:
            return
        self.cursor.executemany(statement, iter(data))
        self.connection.commit()
 

Member Data Documentation

activeTransaction

bool AtlTriggerDBCopy.SQLiteInserter.activeTransaction = False

Definition at line 58 of file AtlTriggerDBCopy.py.

connection

AtlTriggerDBCopy.SQLiteInserter.connection = None

Definition at line 57 of file AtlTriggerDBCopy.py.

cursor

AtlTriggerDBCopy.SQLiteInserter.cursor = self.connection.cursor()

Definition at line 69 of file AtlTriggerDBCopy.py.

filename

AtlTriggerDBCopy.SQLiteInserter.filename = filename

Definition at line 56 of file AtlTriggerDBCopy.py.

insCountInTrans

int AtlTriggerDBCopy.SQLiteInserter.insCountInTrans = 0

Definition at line 59 of file AtlTriggerDBCopy.py.

maxInsertsPerTransaction

int AtlTriggerDBCopy.SQLiteInserter.maxInsertsPerTransaction = 1000

Definition at line 60 of file AtlTriggerDBCopy.py.

---

The documentation for this class was generated from the following file:

• AtlTriggerDBCopy.py