# coding=utf-8
#author:        4N
#createtime:    2020/12/23
#email:         nheweijun@sina.com
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker,Session
from sqlalchemy.engine import ResultProxy
import multiprocessing
import threading

import time




# session:Session = get_db_session("postgresql://postgres:chinadci@172.26.99.168:5432/postgres")
# bbox="113.2470703125 22.840576171875,113.258056640625 22.8515625"
# # table="fs1kw_vacuate_0_000075"
# table="fs900w_1"
# sql ="SELECT geom  FROM {} WHERE geom && 'BOX3D({})'::box3d limit 100000".format(table,bbox)


def query_thread():
    def get_db_session(db_url, autocommit=False) -> Session:
        engine = create_engine(db_url, pool_size=100)

        system_session: Session = sessionmaker(bind=engine, autocommit=autocommit)()

        return system_session

    ses: Session = get_db_session("postgresql://postgres:chinadci@172.26.99.168:5432/postgres")
    bbox = "113.2470703125 22.840576171875,113.258056640625 {}"
    yy=  22.8515625

    table="fs1kw"

    left = True
    for i in range(1):
        if left:
            yy+=0.00001
            left=False

        else:
            yy-=0.00001
            left=True
        bbox = bbox.format(yy)
        sql = "SELECT geom  FROM {} WHERE geom && 'BOX3D({})'::box3d limit 100000".format(table, bbox)
        time1=time.time()
        dd = ses.execute(sql)
        for x in dd:
            dddd = x
        print(multiprocessing.current_process(),time.time()-time1)
    ses.close()
# query_thread()
if __name__ == '__main__':
    kk = [1,2,3,4,5,6,7,8,9,10,11]
    print(len(kk))
    print(kk[10:20])