从 python 将点数组插入 postgres

Question

我有一个table，区域，已定义

 place_id     | integer    | 
 pts          | point[]    | 
 region_name  | text       | 
 region_id    | integer    | not null default nextval('region_region_id_seq'::regclass)

并想插入来自 python 的一行。我有一个数组 pgon

'{{-171.01155,-11.05869},{-171.01116,-11.06022},{-171.01138,-11.07814},{-171.01708,-11.08953},{-171.01963,-11.09463},{-171.03217,-11.10509},{-171.04886,-11.10929},{-171.07441,-11.11013},{-171.09834,-11.10787},{-171.10588,-11.10552},{-171.12063,-11.10091},{-171.13384,-11.09055},{-171.13385,-11.09055},{-171.13386,-11.09054},{-171.13387,-11.09053},{-171.13386,-11.09053},{-171.13384,-11.09053},{-171.13383,-11.09053},{-171.13529,-11.08719},{-171.13966,-11.07717},{-171.14112,-11.07383},{-171.14113,-11.07382},{-171.14114,-11.07382},{-171.14115,-11.07382},{-171.14191,-11.06076},{-171.14118,-11.04661},{-171.14116,-11.04622},{-171.13745,-11.03009},{-171.12577,-11.0156},{-171.1114,-11.00379},{-171.09488,-10.9978},{-171.08485,-10.9975},{-171.07463,-10.9972},{-171.05771,-10.99903},{-171.05163,-11.00014},{-171.03634,-11.00291},{-171.03358,-11.00409},{-171.0279,-11.00652},{-171.01928,-11.01225},{-171.01876,-11.01339},{-171.01407,-11.0237},{-171.01238,-11.04712}}'

place_id = 6, 姓名 = "American Samoa" 我的 python 命令行是：

cur.execute("insert into region (place_id,pts,region_name) values (%,%,%)",(place_id, pgon, name))

但是我明白了值错误："unsupported format character ',' (0x2c) at index 55"

我以前做过插入，但没有在目标中使用 point[]。有人可以告诉我我应该怎么做吗？谢谢

Answer 1

create table t (p point[]);

使用 adapter example from the documentation:

from psycopg2.extensions import adapt, register_adapter, AsIs

class Point(object):
    def __init__(self, x, y):
        self.x = x
        self.y = y

def adapt_point(point):
    x = adapt(point.x).getquoted()
    y = adapt(point.y).getquoted()
    return AsIs("'(%s, %s)'" % (x, y))

register_adapter(Point, adapt_point)

my_tuples_list = [(-171.01155,-11.05869),(-171.01116,-11.06022),(-171.01138,-11.07814),(-171.01708,-11.08953),(-171.01963,-11.09463),(-171.03217,-11.10509),(-171.04886,-11.10929),(-171.07441,-11.11013),(-171.09834,-11.10787),(-171.10588,-11.10552),(-171.12063,-11.10091),(-171.13384,-11.09055),(-171.13385,-11.09055),(-171.13386,-11.09054),(-171.13387,-11.09053),(-171.13386,-11.09053),(-171.13384,-11.09053),(-171.13383,-11.09053),(-171.13529,-11.08719),(-171.13966,-11.07717),(-171.14112,-11.07383),(-171.14113,-11.07382),(-171.14114,-11.07382),(-171.14115,-11.07382),(-171.14191,-11.06076),(-171.14118,-11.04661),(-171.14116,-11.04622),(-171.13745,-11.03009),(-171.12577,-11.0156),(-171.1114,-11.00379),(-171.09488,-10.9978),(-171.08485,-10.9975),(-171.07463,-10.9972),(-171.05771,-10.99903),(-171.05163,-11.00014),(-171.03634,-11.00291),(-171.03358,-11.00409),(-171.0279,-11.00652),(-171.01928,-11.01225),(-171.01876,-11.01339),(-171.01407,-11.0237),(-171.01238,-11.04712)]
my_point_list = [Point(p[0], p[1]) for p in my_tuples_list]

conn = psycopg2.connect(database='cpn')
cursor = conn.cursor()

insert = "insert into t (p) values (%s::point[])"
cursor.execute(insert, (my_point_list,))
conn.commit()

Answer 2

我明白了运行。代码如下。 point[] 到达 PG。现在不幸的是，cur.fetchall() 在 cur.execute("select * from test;")

之后抛出异常

#!/usr/bin/python
import psycopg2
from config import *

dbname="test"

try:
    dbconn = psycopg2.connect(dbname=dbname, host=dbHost, port=5432, user=dbUser,password=dbPassword)
    cur = dbconn.cursor()
except:
    print "Error : Unable to open database\n"

poly="-94.26958,33.56679 -94.26926,33.56763 -94.23197,33.55209"
poly=poly.replace(" ",")\",\"(")
poly="{\"("+poly+")\"}"
try:
    cur.execute("drop table if exists test;");
    cur.execute("CREATE TABLE test (id serial PRIMARY KEY, num integer, anum integer[],pt point, apt point[],nm text);")
    cur.execute("insert into test (num,apt,nm) values (%s,%s,%s) returning *",[1,poly,"fred"])
    dbconn.commit()
    cur.execute("select * from test;")
    print cur.fetchall()
except psycopg2.Error as e :
    print e.pgerror

Answer 3

targetConn = pg.connect(dbname='', user='', host='127.0.0.1', password='root')

targetCursor = targetConn.cursor()

class Point(object):
    def __init__(self, x, y):
        self.x = x
        self.y = y

def adapt_point(point):
    x = adapt(point.x)
    y = adapt(point.y)
    return AsIs("'(%s, %s)'" % (x, y))


register_adapter(Point, adapt_point)

targetCursor.execute("INSERT INTO point (point) VALUES (%s)",
      (Point(1.23, 4.56),))
targetConn.commit()

targetConn.close()

从 python 将点数组插入 postgres

Inserting an array of points into postgres from python

python

postgresql

psycopg2