“/”处或附近的psycopg2模块语法错误

Question

我想通过psycopg2将csv文件导入PostgreSQL。但是，csv文件列名包含特殊字符。我可以用这些代码行通过psycopg2创建一个表。

cursor.execute('''CREATE TABLE crimnalRate(CrimeDate DATE, 
                                        CrimeTime TIME,
                                        CrimeCode TEXT,
                                        Location TEXT,
                                        Description TEXT,
                                        "Inside/Outside" TEXT,
                                        Weapon Text,
                                        Post INT,
                                        District TEXT,
                                        Neighborhood TEXT,
                                        Longitude DOUBLE PRECISION,
                                        Latitude DOUBLE PRECISION,
                                        "Location 1" TEXT,
                                        Premise TEXT,
                                        vri_name1 TEXT,
                                        "Total Incidents" INT)''')

当我想使用copy_from函数导入带有这些代码行的csv文件时。

df=open('BD1.csv','r')
cursor.copy_from(df,"crimnalRate", columns=('CrimeDate',
                                        'CrimeTime',
                                        'CrimeCode',
                                        'Location',
                                        'Description',
                                        'Inside/Outside',
                                        'Weapon',
                                        'Post',
                                        'District',
                                        'Neighborhood',
                                        'Longitude',
                                        'Latitude',
                                        'Location 1',
                                        'Premise',
                                        'vri_name1',
                                        'Total Incidents'),sep=",")

它总是返回错误psycopg2。错误。SyntaxError:在“/”处或附近出现语法错误

我尝试在特殊字符之前使用反斜杠，或者将特殊列名放在双引号中，但它仍然返回相同的错误消息。如何修复此错误？谁能给我一些建议吗？非常感谢。

Answer 1

这对我有效：

import io, sys, psycopg2
conn = psycopg2.connect(dbname='sweden')
c = conn.cursor()
c.execute('CREATE TEMPORARY TABLE t("x/y" INTEGER)')
f = io.StringIO('4711')
c.copy_from(f, 't', columns=['"x/y"'])
c.execute('SELECT * FROM t')
print(list(c))

也就是说，在“有趣”的列名中包含明确的双引号。恕我直言，你不得不这么做有点难看，但是再一次，文档明确表示表名需要这样做，所以列的工作方式是一样的。