空间数据库代码编写：连接、查询与插入操作指南

本文将介绍如何使用 Python 的 psycopg2 库连接到空间数据库（以 PostGIS 为例），并对已建好的表格执行查询和插入操作。

1. 连接到数据库

首先，使用 psycopg2.connect() 函数连接到数据库。您需要提供数据库名称、用户名、密码、主机地址和端口号等信息。

import psycopg2
from psycopg2 import sql

# 连接到数据库
conn = psycopg2.connect(database='your_database', user='your_username', password='your_password', host='your_host', port='your_port')
cur = conn.cursor()

请将上述代码中的占位符替换为您的实际数据库信息。

2. 查询操作

使用 cursor.execute() 方法执行 SQL 查询语句，并使用 fetchall() 方法获取所有查询结果。

# 查询操作
cur.execute('SELECT * FROM your_table')
rows = cur.fetchall()
for row in rows:
    print(row)

将 your_table 替换为您要查询的表格名称。

3. 插入操作

使用 sql.SQL() 和 ST_GeomFromText() 函数构建安全的 SQL 插入语句。ST_GeomFromText() 函数将空间几何对象转换为 PostGIS 支持的格式。

# 插入操作
insert_query = sql.SQL('INSERT INTO your_table (column1, column2, geom) VALUES (%s, %s, ST_GeomFromText(%s, 4326))')
data = ('value1', 'value2', 'POINT(10 20)')
cur.execute(insert_query, data)

将 your_table, column1, column2 替换为实际的表格和列名，并修改插入数据。

4. 提交事务和关闭连接

完成所有操作后，使用 conn.commit() 提交事务，并使用 cur.close() 和 conn.close() 关闭游标和数据库连接。

# 提交事务
conn.commit()

# 关闭连接
cur.close()
conn.close()

通过以上步骤，您可以使用 Python 代码连接到空间数据库，并对已有的表格执行查询和插入操作。请根据您的实际需求修改代码并使用。