Python-сообщество

# -*- coding: utf-8 -*-
"""
Класс для sqlite, чтобы просто работать
"""
import sqlite3
from pandas import DataFrame
class sqlite_file ():
    """
    Создание: sql = sqlite_file('test.db'), то есть указываем только имя файла
    Запись: sql.record (table = 'Имя таблицы', Поле1 = Значение1, Поле2 = Значение2)
    ... или, например:
    sql.record (table = 'config', login = 'root', password = 'bastard', enabled = 'Nope')
    """
    def __init__ (self, filename):
        self.mybase = sqlite3.connect(filename)
        self.columns = {}
        self.debug = '0'
# <--------------- Здесь кое-что пропущено -------------->
def read (self, table, **args):
        """
        Пример использования:
        mydata = sql.read (table = 'quotes', fields = ['secid', 'time', 'date', 'close', 'volume', 'oi'])
        а на выходе - таблица:
          secid   time        date   close volume    oi
        0  RIU3  11:00  27.09.2013  144741    412  1223
        1  RIU3  11:00  27.09.2013  144813    412  1223
        ...
        7  RIU3  11:00  27.09.2013  144576    412  1223
        8  RIU3  11:00  27.09.2013  144683    412  1223
        9  RIU3  11:00  27.09.2013  144874    412  1223
        """
        request = 'SELECT'
        for f in args['fields']: # Это если все, а если нет, то дописать!!!!
            request += ' [%s],' % f
        request = request[:-1] + ' FROM [%s]' % table
        try:
            sqlres = self.mybase.execute(request)
        except:
            print 'Empty table!'
            return -1
        result = []
        if sqlres:
            for res in sqlres:
                result.append (res)
            data = DataFrame (result, columns=args['fields'])
            return data

import mylib
sql = sqlite_file('test.db')
mydata = sql.read (table = 'quotes', fields = ['secid', 'time', 'date', 'close', 'volume', 'oi'])
print (mydata [0]['volume'])

mydata=hdf_opened_file["volume"][0]

print (mydata [0]['volume'])

import sqlite3
....
self.mybase = sqlite3.connect(filename)
...
sqlres = self.mybase.execute(request)

column_names=...
result={i:[] for i in column_names}
for vals in cursor:
   for k,v in zip(column_names,vals):
       result[k].append(v)

v=result["a"][0]