Flask и две БД

__author__ = 'Bogdan'
from flask import Flask, render_template, redirect
import sqlite3
from elasticsearch import Elasticsearch
app = Flask(__name__)
 
class ES(object):
    def __init__(self):
        self.es = Elasticsearch()
        self.id = 0
 
    def insert_es(self, id, good, description):
        doc = {
            'id': id,
            'good': good,
            'description': description
            }
        res = self.es.index(index="test-index", doc_type='description_goods', id=self.id, body=doc)
        print(res['created'])
        res = self.es.get(index="test-index", doc_type='description_goods', id=self.id)
        print(res['_source'])
        self.es.indices.refresh(index="test-index")
        self.id += 1
 
    def search_es(self, what, query):
        res = self.es.search(index="test-index", body={"query": {"match": {what: query}}})  #"author": 'kimchy'
        print("Got %d Hits" % res['hits']['total'])
        documents = []
        for hit in res['hits']['hits']:
            print hit
            documents.append(hit['_source'])
        return documents
 
    def del_by_query(self, query):
        res = self.es.delete_by_query(index="test-index", body={"query": {"match": {query}}}) #{"match_all": {}}
 
    def del_all(self):
        res = self.es.delete_by_query(index="test-index", body={"query": {"match_all": {}}}) #{"match_all": {}}
 
 
class SQL(object):
    def __init__(self, test_db):
        self.connection = sqlite3.connect(test_db)
        self.cursor = self.connection.cursor()
        self.table = 'CREATE TABLE goods(id INTEGER, NAME TEXT, WEIGHT INTEGER, NUM INTEGER)'
        self.cursor.execute(self.table)
        #closed method
        #self.__data
 
    def insert(self, id, good, weight, num):
        query = 'INSERT into goods VALUES ({}, "{}", {}, {})'.format(id, good, weight, num)
        self.cursor.execute(query)
        self.connection.commit()
 
    def search_sql(self, query):
        self.cursor.execute(query)
        return self.cursor.fetchall()
 
 
es = ES()
sql = SQL(':memory:')
 
#sql.insert(1, "Chair", 15, 33)
#sql.insert(10, "Table", 20, 17)
#print sql.search_sql('SELECT * FROM goods WHERE id=1')
 
 
@app.route('/')
def index(): return render_template('index.html')
 
@app.route('/insert')
def fill_in_dbs():
    es = ES() #я понимаю что объект здесь - глупо, но по-другому не работает
    es.insert_es(1, "Chair", "big")
    es.insert_es(2, "Table", 15)
    es.insert_es(3, "TV", 5)
    es.insert_es(8, "Bed", 15)
    es.insert_es(10, "Chair", 10)
 
    sql = SQL(':memory:')
    sql.insert(1, "Chair", 15, 33)
    sql.insert(10, "Table", 20, 17)
    return redirect('/search_form')
 
 
def execute_query(q):
    query = 'SELECT * FROM goods WHERE id={}'.format(q)
    f = sql.search_sql(query)
    return f
 
@app.route('/search_form')
def flask_search():
    if request.args:
        for k, v in request.args.items():
            if v:
                scores = es.search_es(k, v)
                for d in scores:
                    for key, value in d.items():
                        if key == 'id':
                            print key, value, type(value)
                            #print execute_query(value)
                            #return redirect('search_sql.html', f=f)
    return render_template('form.html')
 
@app.route('/delete_all_es')
def delete_all_es():
    es.del_all()
    return render_template('delete.html')
 
if __name__ == '__main__':
    app.run(debug=True)