data_sources.sqlite_schema Class Reference

Inheritance diagram for data_sources.sqlite_schema:

Public Member Functions
def	__init__ (self, sqlite_file_name)
def	data (self)
Public Member Functions inherited from data_sources.data_source
def	__init__ (self)
def	__repr__ (self)
def	get_data (self)
Public Member Functions inherited from data_sources.node
def	__init__ (self, data=None)
def	__str__ (self)
def	add_child (self, node_data)
def	child (self, index)
def	children (self)
def	data (self)
def	is_leaf (self)
def	left_child (self)
def	right_child (self)

Private Attributes
	_data
	_file_name

Detailed Description

Definition at line 79 of file data_sources.py.

Constructor & Destructor Documentation

__init__()

def data_sources.sqlite_schema.__init__	(		self,
			sqlite_file_name
	)

Definition at line 81 of file data_sources.py.

    def __init__(self, sqlite_file_name):
        self._file_name = sqlite_file_name
        # import sqlite3 and connect to the database file
        import sqlite3
        connection = sqlite3.connect(self._file_name)
        cursor = connection.cursor()
        if query_object == None:
            # try to query the file to get table and column data
            tables = cursor.execute("select name from sqlite_master where type = 'table'")

            # now build a mapping of tables to columns - with a dictionary
            table_to_columns = {}
            for table in tables.fetchall():
                table_to_columns[table[0]] = []
                # now query columns for this table
                columns = cursor.execute("pragma table_info(%s)" % table[0])
                for column in columns.fetchall():
                    table_to_columns[table[0]].append(str(column[1]))

            # now query with the mapping
            table_to_data = {}
            for table in table_to_columns:
                # query with all columns
                column_string = ",".join(table_to_columns[table])
                sql_query = "select %s from %s" % (column_string, table)
                results = cursor.execute(sql_query).fetchall()
                for n in range(0, len(results)):
                    results[n] = dict(list(zip(table_to_columns[table], list(map(str, results[n])))))
                table_to_data[str(table)] = results
            self._data = json_data_node.make(table_to_data)
        else:
            sql_query = query_object.to_sql()

Member Function Documentation

data()

def data_sources.sqlite_schema.data

(

self

)

Definition at line 114 of file data_sources.py.

References data_sources.node._data, and conddb2hdf5.DBPayload._data.

Referenced by data_sources.json_list.as_dicts(), data_sources.json_list.as_table(), data_sources.json_list.get_members(), and data_sources.json_list.last().

    def data(self):
        return self._data

# used for chaining json-navigation methods
# when a method is called initially on the data, an object of this class is returned,
# then the methods on that object return an object of this class again.

Member Data Documentation

_data

data_sources.sqlite_schema._data

private

Definition at line 110 of file data_sources.py.

Referenced by XML2Python.DataNode.__init__(), data_sources.json_list.__next__(), python.XML2Python.DataNode.__nonzero__(), XML2Python.DataNode.__nonzero__(), python.XML2Python.DataNode.__repr__(), XML2Python.DataNode.__repr__(), XML2Python.DataNode.__str__(), python.XML2Python.DataNode.__str__(), data_sources.json_data_node.__str__(), data_sources.json_list.add_child(), data_sources.json_dict.add_key(), data_sources.json_data_node.data(), data_sources.json_data_node.find(), data_sources.json_data_node.raw(), data_sources.json_data_node.set(), and XML2Python.DataNode.stringify().

_file_name

data_sources.sqlite_schema._file_name

private

Definition at line 82 of file data_sources.py.