我想用Python创建Postgres数据库.
con = psql.connect(dbname='postgres', user=self.user_name, host='', password=self.password) cur = con.cursor() cur.execute("CREATE DATABASE %s ;" % self.db_name)
我收到以下错误:
InternalError: CREATE DATABASE cannot run inside a transaction block
我正在使用psycopg2进行连接.我不明白这是什么问题.我想做的是连接到数据库(Postgres):
psql -postgres -U UserName
然后创建另一个数据库:
create database test;
这就是我通常所做的,我想通过创建Python脚本来自动执行此操作.
使用ISOLATION_LEVEL_AUTOCOMMIT,一个psycopg2扩展:
发出命令时不启动任何事务,并且不需要commit()或rollback().
import psycopg2 from psycopg2 import sql from psycopg2.extensions import ISOLATION_LEVEL_AUTOCOMMIT # <-- ADD THIS LINE con = psycopg2.connect(dbname='postgres', user=self.user_name, host='', password=self.password) con.set_isolation_level(ISOLATION_LEVEL_AUTOCOMMIT) # <-- ADD THIS LINE cur = con.cursor() # Use the psycopg2.sql module instead of string concatenation # in order to avoid sql injection attacs. cur.execute(sql.SQL("CREATE DATABASE {}").format( sql.Identifier(self.db_name)) )
如另一个答案所示,连接必须处于自动提交模式.使用它的另一种方法psycopg2
是通过autocommit
属性:
import psycopg2 con = psycopg2.connect(...) con.autocommit = True cur = con.cursor() cur.execute('CREATE DATABASE {};'.format(self.db_name))