AtlTriggerDBCopy.SQLiteInserter Class Reference

Collaboration diagram for AtlTriggerDBCopy.SQLiteInserter:

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

Public Attributes
	filename
	connection
	activeTransaction
	insCountInTrans
	maxInsertsPerTransaction
	cursor

Detailed Description

Definition at line 53 of file AtlTriggerDBCopy.py.

Constructor & Destructor Documentation

__init__()

def 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()

def 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()

def 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()

def 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()

def 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

AtlTriggerDBCopy.SQLiteInserter.activeTransaction

Definition at line 58 of file AtlTriggerDBCopy.py.

connection

AtlTriggerDBCopy.SQLiteInserter.connection

Definition at line 57 of file AtlTriggerDBCopy.py.

cursor

AtlTriggerDBCopy.SQLiteInserter.cursor

Definition at line 69 of file AtlTriggerDBCopy.py.

filename

AtlTriggerDBCopy.SQLiteInserter.filename

Definition at line 56 of file AtlTriggerDBCopy.py.

insCountInTrans

AtlTriggerDBCopy.SQLiteInserter.insCountInTrans

Definition at line 59 of file AtlTriggerDBCopy.py.

maxInsertsPerTransaction

AtlTriggerDBCopy.SQLiteInserter.maxInsertsPerTransaction

Definition at line 60 of file AtlTriggerDBCopy.py.

---

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

• AtlTriggerDBCopy.py