1

我使用 sqlalchemy 和 geoalchemy，并将我的结果转换为 geojson。用这样的正常方式：

print json.dumps([dict(r) for r in connection.execute(query)])

这是不可能的，因为 cx_Oracle.Objets 不可序列化！我可以通过像这样的单独属性进行访问：

result = connection.execute(query)
result2 = result.fetchone()[0]
print result2.SDO_ORDINATES

这是我的程序：

#!/usr/bin/env python
# coding: utf8
#from __future__ import absolute_import, division, print_function
from sqlalchemy import create_engine
from sqlalchemy import Table, MetaData
from sqlalchemy.sql import and_, select
from geoalchemy import Geometry, GeometryExtensionColumn
from geoalchemy import *
from geoalchemy.oracle import oracle_functions
from geoalchemy.oracle import OracleComparator
import cx_Oracle
import json
import sdo

#def main():
engine = create_engine('oracle+cx_oracle://TEST_3D:limo1013@10.40.33.160:1521/sdetest')
metadata = MetaData(engine)

# Loading tables 
building = Table(
    'building',
    metadata,
    GeometryExtensionColumn('centroid_geom', Geometry(2, srid= 431467)),
    autoload=True,
    autoload_with=engine
)
GeometryDDL(building)

thematic_surface = Table('thematic_surface', metadata, autoload=True)
surface_geometry = Table('surface_geometry', metadata, autoload=True)
objectclass = Table('objectclass', metadata, autoload=True)

connection = engine.connect()

# define the query
query = select([(surface_geometry.c.geometry)]  #building.c.id, surface_geometry.c.geometry, objectclass.c.classname
).where(
    and_(
        building.c.grid_id_400 == 4158,
        building.c.id == thematic_surface.c.building_id,
        thematic_surface.c.lod2_multi_surface_id == surface_geometry.c.root_id,
        surface_geometry.c.geometry != None,
        thematic_surface.c.objectclass_id == objectclass.c.id,
    )
)
# Execute and print the result of the query
#print json.dumps([dict(r) for r in connection.execute(query)])
result = connection.execute(query)

我将在 GeoJSON 中转换我的所有 cx_Oracle.Objects 但如何？在互联网上，是一个函数 sdo2geojson 可以在 sql developer 中正常工作，但当然这个函数对于 python 来说是未知的......

我希望有一个人可以帮助我？？？

4

1 回答 1

1

这是使用（尚未发布的）cx_Oracle 版本，它支持对象绑定和其他更高级的对象使用。使用随 cx_Oracle 提供的示例来演示几何的插入，以下代码会将以此方式创建的对象转换为 JSON。下面包含的 ObjectRepr() 函数应该适用于从 Oracle 返回的任何对象。它只是读取对象上的元数据并将对象转换为属性字典或值列表。

import cx_Oracle
import json

connection = cx_Oracle.Connection("user/pw@tns")
typeObj = connection.gettype("SDO_GEOMETRY")
cursor = connection.cursor()
cursor.execute("""
        select Geometry
        from TestGeometry
        where IntCol = 1""")
obj, = cursor.fetchone()

def ObjectRepr(obj):
    if obj.type.iscollection:
        returnValue = []
        for value in obj.aslist():
            if isinstance(value, cx_Oracle.Object):
                value = ObjectRepr(value)
            returnValue.append(value)
    else:
        returnValue = {}
        for attr in obj.type.attributes:
            value = getattr(obj, attr.name)
            if value is None:
                continue
            elif isinstance(value, cx_Oracle.Object):
                value = ObjectRepr(value)
            returnValue[attr.name] = value
    return returnValue

print("JSON:", json.dumps(ObjectRepr(obj)))
于 2016-07-15T15:45:47.167 回答