#encoding: utf-8
__author__ = 'Administrator'
#import pymongo
from pymongo import MongoClient,GEO2D
import sqlite3
import sys
import psycopg2
import ppygis
import cx_Oracle
import datetime
reload(sys)
#中文错误
sys.setdefaultencoding( "utf-8" )
#mongo
client = MongoClient("192.98.12.245",30007)
db = client['tiledb']
tiles = db['tiles']
poi = db['poi']
#assert isinstance(tiles, object)
print(tiles.find_one())
#拉框查询函数
def doWithinQuery():
print(poi.find({"loc":{"$within":{"$box":[[75.23,20.32],[152.23,60]]}}}).count())
for p in poi.find({"loc":{"$within":{"$box":[[75.23,20.32],[152.23,60]]}}}):
print p['address']
def readSQLite2MongonDB():
#删除以前记录
poi.remove()
sql_txt = sqlite3.connect("c://POI.tdb")
cusor = sql_txt.cursor()
cusor.execute("select * from poi")
row = cusor.fetchone();
for _row in cusor.fetchall():
print _row
_p = {"name":_row[1],"address":_row[2],"loc":[_row[9],_row[10]]}
poi.insert(_p)
print("插入完毕...")
|