copyPostGresToSQLite Namespace Reference

Functions
def	copyTable

Variables
list	readoutBoardsColumns
list	daqChannelsColumns
list	flangesColumns
list	pmtPlacementColumns
list	crtFEBChannelsColumns
list	topcrtFEBColumns
string	queryurl = "https://dbdata0vm.fnal.gov:9443/QE/hw/app/SQ/query"
tuple	dataQuery = DataQuery(queryurl)
string	dbName = "icarus_hardware_prd"
string	readoutBoardsTable = "readout_boards"
string	daqChannelsTable = "daq_channels"
string	flangesTable = "flanges"
string	pmtPlacementTable = "pmt_placements"
string	crtfebchannelsTable = "feb_channels"
string	topcrtfebTable = "crtfeb"
tuple	sqliteDB = sqlite3.connect("ChannelMapICARUS.db")
tuple	dbCurs = sqliteDB.cursor()

Function Documentation

def copyPostGresToSQLite.copyTable	(		postGres,
			dbCurs,
			dbName,
			table,
			columns
	)

Definition at line 132 of file copyPostGresToSQLite.py.

def copyTable(postGres, dbCurs, dbName, table, columns):
    createString = "CREATE TABLE " + table + " ("

    for columnIdx in range(len(columns)):
        if columnIdx > 0:
            createString += ", "
        createString += columns[columnIdx]

    createString += ")"

    print(createString)

    dbCurs.execute(createString)

    query = postGres.query(database=dbName, table=table, columns="*")

    for rowIdx in range(len(query)):
        rowList = query[rowIdx].split(',')
        if len(rowList) != len(columns):
            print("Length mismatch! Will skip this row (",rowIdx,")")
            continue
        insertString = "INSERT INTO " + table + " VALUES ("
        for idx in range(len(rowList)):
            if idx > 0:
                insertString += ", "
            if "text" in columns[idx]:
                fieldEntry = rowList[idx]
                if table == "daq_channels" and "plane" in columns[idx]:
                    fieldEntry = rowList[idx].upper()
                insertString += "\'" + fieldEntry + "\'"
            else:
                if "none" in rowList[idx]:
                    #print("Found none in column data, field:",columns[idx],", value: ",rowList[idx])
                    insertString += '0'
                else:
                    insertString += "\'" +rowList[idx]+ "\'"
        insertString += ")"
        if table == "daq_channels":
            print("idx:",rowIdx,"  -->",insertString)
        dbCurs.execute(insertString)