PG8000 - Pure-Python PostgreSQL驱动程序

PG8000配有两个API，本机PG8000 API和DB-API 2.0 StandardAPI。这些是本机API的示例，DB-API 2.0在下一部分中的示例示例。

导入pg8000，连接数据库，创建一个表，添加一些行，然后添加一个表：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃使用用户名Postgres＆gt连接到数据库。＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃创建一个临时表＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。跑（＆＃34;创建临时表书（ID序列，标题文本）＆＃34;）[]＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃填充表格＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;在（＆＃34; enter＆＃39; same＆＃34 ;,＆＃34; magus＆＃34;）：...骗局的标题运行（＆＃34;插入到书籍（标题）值（：title）＆＃34;标题= title）[] [] []＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃打印表格中的所有行＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;在骗局中排行。 run（＆＃34;从书中选择*，从书中选择*）：...打印（行）[1，＆＃34; enter＆＃39; s游戏＆＃34;] [2，＆＃39; magus＆＃39 ;]

＆gt;＆gt;＆gt;进口PG8000.NAID＆gt;＆gt;＆gt;＆gt;＆gt;＆gt; CON = pg8000.native.Connection（＆＃34; postgres的＆＃34 ;,密码=＆＃34; cpsnow＆＃34;）＆GT;＆GT;＆GT;＆GT;＆GT;＆GT; con.run（＆＃34;开始交易＆＃34;）[]＆gt;＆gt; ＃创建一个临时表＆gt;＆gt;＆gt; con.run（＆＃34;创建临时表图书（ID序列，标题文本）＆＃34;）[]＆gt;＆gt;＆gt;在（＆＃34; enter＆＃39; s游戏中的标题和＃34;＆＃34; Magus＆＃34 ;,＆＃34; phineas finn＆＃34;）：...康明（＆＃34;插入书（标题）值（：标题）＆＃34;，标题=标题）[] [] [] [] [] []＆gt;＆gt;＆gt; con.run（＆＃34;提交＆＃34;）[]＆gt;＆gt;在Con.Run中的行（＆＃34;从书中选择*）：...打印（行）[1，＆＃34; Ender＆＃39; s游戏＆＃34;] [2，＆＃39 ; Magus＆＃39;] [3，＆＃39; phineas finn＆＃39;]

＆gt;＆gt;＆gt;进口PG8000.NAID＆gt;＆gt;＆gt;＆gt;＆gt;＆gt; CON = pg8000.native.Connection（＆＃34; postgres的＆＃34 ;,密码=＆＃34; cpsnow＆＃34;）＆GT;＆GT;＆GT;＆GT;＆GT;＆GT; ＃创建一个临时表＆gt;＆gt;＆gt; con.run（＆＃34;创建临时表图书（ID序列，标题文本）＆＃34;）[]＆gt;＆gt;＆gt;在（＆＃34; enter＆＃39; s游戏中的标题和＃34;＆＃34; Magus＆＃34 ;,＆＃34; phineas finn＆＃34;）：...康明（＆＃34; INSERT INTO书（标题）VALUES（：标题）＆＃34 ;,标题=标题）[] [] []＆GT;＆GT;＆GT;＆GT;＆GT;＆GT; con.run（＆＃34;开始交易＆＃34;）[]＆gt;＆gt; con.run（＆＃34;从标题=：title＆＃34;，标题=＆＃34; phineas finn＆＃34;）[]＆gt;＆gt; con.run（＆＃34;回滚＆＃34;）[]＆gt;＆gt;在Con.Run中的行（＆＃34;从书中选择*）：...打印（行）[1，＆＃34; Ender＆＃39; s游戏＆＃34;] [2，＆＃39 ; Magus＆＃39;] [3，＆＃39; phineas finn＆＃39;]

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;导入DateTime＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ts = datetime。日期（1980,4,27）＆gt;＆gt; ＆gt;骗子。跑（＆＃34;选择时间戳＆＃39; 2013-12-01 16：06＆＃39; - ：Ts＆＃34;，ts = ts）[[DateTime。 Timedelta（天= 12271，秒= 57960）]]

与服务器通信时，PG8000使用TheServer要求使用的字符集（客户端编码）。默认情况下，客户端编码是数据库的字符集（在创建数据库时选择），但是可以以多种方式更改，但是可以以多种方式更改（例如，postgreSQL.conf中的setcarlient_encoding）。改变ClientEncodinging的另一种方式是使用SQL命令。例如：

JSON始终从服务器释放出序列化。如果你要发送的json是一个dictthen，你可以刚才做：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; val = {＆＃39;：＆＃39; apollo 11洞穴＆＃39 ;,＆＃39; zebra＆＃39; true，＆＃39;年龄＆＃39 ;: 26.003}＆gt;＆gt; ＆gt;骗子。运行（＆＃34;选择：apollo＆＃34;，apollo = val）[[{＆＃39;年龄＆＃39;：26.003，＆＃39;名称＆＃39 ;:＆＃39; apollo 11洞穴＆＃39; ，＆＃39;斑马＆＃39;：true}]]

＆gt;＆gt; ＆gt;进口json＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; val = [＆＃39;阿波罗11洞穴＆＃39;，真实，26.003]＆gt;＆gt; ＆gt;骗子。 run（＆＃34;选择cast（：apolloasejsonb）＆＃34; apollo = json。转储（val））[[＆＃39; apollo 11 cave＆＃39;，26.003]]]

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。运行（＆＃34;创建临时表夸克（ID序列，名称文本）＆＃34;）[]＆gt;＆gt; ＆gt;在（＆＃39;＆＃39;＆＃39; down＆＃39;）的名称：...骗局。 run（＆＃34;插入zhark（名称）值（：name）＆＃34;，name = name）[] []＆gt;＆gt; ＆gt; ＃现在执行Query＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。运行（＆＃34;从Quark＆＃34选择*）[[1，＆＃39; Up＆＃39;]，[2，＃39;＆＃39;]]＆gt;＆gt;＆gt;＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃并重试元数据＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。列[{＆＃39; table_oid＆＃39 ;: ...，＆＃39; column_attrnum＆＃39 ;: 1，＆＃39; type_oid＆＃39 ;: 23，＆＃39; type_size＆＃39 ;: 4，＆ ＃39; type_modifier＆＃39 ;: - 1，＆＃39;格式＆＃39 ;: 0，＆＃39;姓名＆＃39 ;:＆＃39; id＆＃39; {＆＃39; table_oid＆＃39; ：...，＆＃39; column_attrnum＆＃39 ;: 2，＆＃39; type_oid＆＃39 ;: 25，＆＃39; type_size＆＃39 ;: - 1，＆＃39; type_modifier＆＃39 ;: - 1 ，＆＃39;格式＆＃39 ;: 0，＆＃39;姓名＆＃39 ;:＆＃39;名称＆＃39;}]＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃显示列名称＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; [C [＆＃39;符号名称＆＃39;] con。列[＆＃39; id＆＃39;＆＃39;名称＆＃39;]

PostgreSQL标记存储在称为Connection.Notices并使用Append（）方法添加的DEQUE。类似地，存在Connectification.notificationsand.parameter_statuses，用于更改服务器配置。的一个例子：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。跑（＆＃34;听aliens_landed＆＃34;）[]＆gt; ＆gt;骗子。跑（＆＃34;通知Aliens_landed＆＃34;）[]＆gt;＆gt; ＆gt; ＃通知是包含（后退_pid，频道，有效载荷）＆gt;＆gt的元组。 ＆gt; ＆gt;＆gt; ＆gt;骗子。通知[0]（...，＆＃39; aliens_landed＆＃39;＆＃39;＆＃39;）

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。跑（＆＃34; select＆＃39; silo 1＆＃39; lims：lim＆＃34 ;,5 lim =＆＃39;全部＆＃39;）回溯（最近呼叫最后）：pg8000。例外。数据库错误： ...

相反，Docs Saytht您可以将空闲作为所有工作的替代品，这是工作：

您可能会认为以下会有效，但实际上服务器没有：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。跑（＆＃34;选择＆＃39;孤岛1＆＃39;其中＆＃39; a＆＃39;＆＃39; v＆＃34;，v =（＆＃39; a＆＃39;和＃39; b＆＃39; b＆＃39; 39;））回溯（最近呼叫最后）：PG8000。例外。数据库错误： ...

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。跑（＆＃34; select＆＃39; silo 1＆＃39;其中＆＃39; a＆＃39;（选择UNNEST（：V））＆＃34;，v =（＆＃39; a＆＃39; ，＆＃39; b＆＃39;））[[＆＃39; silo 1＆＃39;]]

在PostgreSQL参数中只能用于数据值，而不是标识符。有时，这可能无法按预期工作，例如以下失败：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。运行（＆＃34;使用密码创建用户Juan：password＆＃34;，password =＆＃39; quail＆＃39;）回溯（最近调用最后）：pg8000。例外。数据库错误： ...

它失败，因为PostgreSQL服务器不允许此语句才能获得参数。有许多SQL陈述，人们可能认为将有很多分析器，但是没有。

SQL Copy DateplateCan可用于复制到文件或文件等对象。在这里＆＃39;一个emplyusing csv格式：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt;来自IO导入Bytesio＆Gt;＆gt; ＆gt;进口CSV＆gt;＆gt; ＆gt;导入编解码器＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃在内存中创建CSV文件。＆gt; ＆gt; ＆gt;＆gt; ＆gt; Stream_in = bytesio（）＆gt;＆gt; ＆gt; StreamWriter =编解码器。 getwriter（＆＃39; utf-8＆＃39;）＆gt;＆gt; ＆gt; CSV_WRITER = CSV。作者（StreamWriter（Stream_in））＆gt;＆gt; ＆gt; CSV_WRITER。作品（[1，＆＃34;电子＆＃34;]）＆gt;＆gt; ＆gt; CSV_WRITER。作品（[2，＆＃34; muon＆＃34;]）＆gt;＆gt; ＆gt; CSV_WRITER。作者（[3，＆＃34; tau＆＃34;]）＆gt;＆gt; ＆gt; Stream_in。寻求（0）0＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃创建一个表，然后将CSV复制到IT＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。跑（＆＃34;创建临时表Lepton（ID序列，名称文本）＆＃34;）[]＆gt;＆gt; ＆gt;骗子。跑（＆＃34;从stdin复制leptin与（格式csv）＆＃34; stream = stream_in）[]＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃从表中复制到流＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; Stream_out = bytesio（）＆gt;＆gt; ＆gt;骗子。运行（＆＃34;用（格式csv）＆＃34; stream = stream_out）[]＆gt;＆gt; ＆gt;流出来。寻求（0）0＆gt;＆gt; ＆gt; StreamReader =编解码器。 GetReader（＆＃39; UTF-8＆＃39;）＆gt;＆gt; ＆gt;用于CSV的行。读者（StreamReader（Stream_out））：...打印（行）[＆＃39; 1＆＃39;＆＃39;电子＆＃39;] [＆＃39; 2＆＃39;＆＃39; muon＆＃ 39;] [＆＃39; 3＆＃39;＆＃39; tau＆＃39;]

如果要执行一系列SQL语句（例如,.SQL文件），则YOUCAN按预期运行它们：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;陈述=＆＃34;选择5;选择＆＃39; eRich fromm＆＃39 ;;＆＃34; ＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。 run（陈述）[[5]，[＆＃39; eRich fromm＆＃39;]]

唯一的警告是，当执行多个陈述时，您就不能有任何parameters。

假设你有一个名为我的列的列。由于它的区分大小写，因此您必须通过双引号括起来。但你做不到：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。跑（＆＃34;选择＆＃39;你好＆＃39;作为＆＃34;我的列＆＃34;＆＃34;）回溯（最近呼叫最后一个电话）：syntaxError：语法无效

由于Python使用双引号来分隔字符串文字，因此一个解决方案是使用Python的三额额相级别界定字符串：

PG8000具有从Python类型到PostgreSQL类型的映射，因为它需要将SQL参数发送到服务器时。在大多数情况下，Cutp8000的默认映射旨在运行良好，但您可能希望添加Orreplace默认映射。

将Python DateTime.Timedelta对象作为PostgreSQL间隔类型发送到服务器，其中具有OID 1186.但是假设我们想创建自己的Python类作为间隔类型。然后我们已经托架了适配器：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; Class MyInterval（str）：...通过和gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; def my_interval_out（my_interval）：...返回my_interval＃必须返回str＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。 register_out_adapter（MyInterval，1186，my_interval_out）＆gt;＆gt; ＆gt;骗子。运行（＆＃34;选择：间隔＆＃34;，interval = myInterval（＆＃34; 2小时＆＃34;））[[DateTime。 Timedelta（秒= 7200）]]

请注意，它仍然是DateTime.Timedelta对象，因为我们唯一从Python到PostgreSQL的映射。有关HOWTO将PostgreSQL的映射更改为Python的示例，请参阅下文。

PG8000从PostgresQL类型映射到Python类型，何时收听来自服务器的QL结果。 PG8000附带的默认映射在大多数情况下，才能运行良好，但您可能希望添加或替换thedefault映射。

如果PG800收到PostgreSQL间隔类型，则具有OID 1186，它将其转换为Python DateTime.Timedelta对象。但是，让我们说我们希望创建自己的Python类来代替DateTime.Timedelta。然后我们必须注册一个适配器：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; Class MyInterval（str）：...通过和gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; def my_interval_in（my_interval_str）：＃参数是str的类型...返回myInterval（my_interval）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。 register_in_adapter（1186，my_interval_in）＆gt;＆gt; ＆gt;骗子。跑（＆＃34;选择\＆＃39; 2年＆＃39;＆＃34;）[[39; 2岁＆＃39;]]]

请注意，注册＆＃39;在＆＃39;适配器仅从Python类型从博斯特格QL类型从映射上。有关如何从PostgreSQL转换为Python的示例，请参阅上面。

有时你会得到＆＃39;无法确定参数的数据类型＆＃39;来自服务器的errormessage：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;骗子。运行（＆＃34;选择：v为null＆＃34;，v = none）回溯（最近呼叫最后一个呼叫）：pg8000。例外。 DatabaseError：{＆＃39; s＆＃39 ;:＆＃39;错误＆＃39;＆＃39; v＆＃39 ;:＆＃39;错误＆＃39 ;,＆＃39; c＆＃39 ;:＆＃39; c＆＃39 ;:＆＃39; c＆＃39 ;:＆＃39; 39; 42P18＆＃39 ;,＆＃39; m＆＃39 ;:＆＃39;无法确定参数1美元＆＃39 ;,＆＃39; f＆＃39 ;:＆＃39; postgres.c＆＃ 39 ;,＆＃39; l＆＃39 ;:＆＃39; ...＆＃39 ;,＆＃39; r＆＃39 ;:＆＃39; exec_parse_message＆＃39;}

准备好的报表可用于提高性能时，当您有一个反复声明时会提高性能。这是一个例子：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（＆＃34; postgres＆＃34;密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃创建准备好的声明＆gt;＆gt; ＆gt; ps = con。准备（＆＃34;选择cast（：v作为varchar）＆＃34;）＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃重复地兑换陈述＆gt;＆gt; ＆gt; PS。运行（v =＆＃34;速度＆＃34;）[[＆＃39;速度＆＃39;]]＆gt; ＆gt; PS。跑（v =＆＃34; rapt＆＃34; [＆＃39;＆＃39;]＆gt; ＆gt; PS。跑（v =＆＃34; swift＆＃34;）[[＆＃39; swift＆＃39;]]＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃关闭准备好的声明，释放服务器上的资源＆gt;＆gt; ＆gt; PS。关闭（）

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt;进口乐谱＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃使用当前用户名和gt连接到数据库;＆gt; ＆gt;用户名= getpass。 getUser（）＆gt;＆gt; ＆gt;连接= PG8000。本国的。连接（用户名，密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;联系。跑（＆＃34;选择＆＃39; pilau＆＃39;＆＃34;）[[＆＃39; pilau＆＃39;]]]

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt;来自OS进口环境和GT;＆GT; ＆gt; ＆gt;＆gt; ＆gt;用户名= Environ。得到（＆＃39; pguser＆＃39;＆＃39; postgres＆＃39;）＆gt;＆gt; ＆gt;密码=环境。得到（＆＃39; pgpassword＆＃39;＆＃39; cpsnow＆＃39;）＆gt;＆gt; ＆gt; Host = Environ。得到（＆＃39; pghost＆＃39;＆＃39; localhost＆＃39;）＆gt;＆gt; ＆gt;端口=环境。得到（＆＃39; pgport＆＃39 ;,＆＃39; 5432＆＃39;）＆gt;＆gt; ＆gt;数据库=环境。得到（＆＃39; pgdatabase＆＃39;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;连接= PG8000。本国的。连接（...用户名，password = password，host = host，port = port，database = database）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;联系。跑（＆＃34;选择＆＃39;开罗＆＃39先生;＆＃34;）[[＆＃39;开罗和＃39先生;]]

它可能被问到，为什么PG8000没有这种行为？思考遵循Python Zen的第二个憎恶：

所以我们只采用了能够设置PG8000的连接参数的方法.Connection（）构造函数。

可能是您的PostgreSQL服务器位于SSL代理服务器后面，可以在其中设置PG8000特定的属性SSL.SSLContext.Request_ssl = false，告诉pg8000使用anssl套接字连接，但不需要从PostgreSQL服务器请求SSL：

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（用户名，密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt;骗子。跑（＆＃34;开始交易＆＃34;）[]＆gt;＆gt; ＆gt;骗子。 run（＆＃34;声明c scrossolsor for select * from generate_series（1,100）＆＃34;）[]＆gt;＆gt; ＆gt;骗子。跑（＆＃34;从c＆＃34上获取5.）[[1]，[2]，[3]，[4]，[5]]＆gt; ＆gt;骗子。跑（＆＃34;从c＆＃34移动50;）[]＆gt;＆gt; ＆gt;骗子。运行（＆＃34; FETCH BACKWARD 10选自C＆＃34;）[[54]，[53]，[52]，[51]，[50]，[49]，[48]，[47]，[46 [45]]＆gt;＆gt; ＆gt;骗子。跑（＆＃34;关闭c＆＃34;）[]＆gt;＆gt; ＆gt;骗子。运行（＆＃34;回滚＆＃34;）[]

＆gt;＆gt; ＆gt;导入pg8000。天然＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。本国的。连接（用户名，密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃创建一个blob并获得其OID＆gt;＆gt; ＆gt;数据= B＆＃39;你好＆＃39; ＆gt;＆gt; ＆gt; res = con。运行（＆＃34;选择lo_from_bytea（0，：data）＆＃34;，data = data）＆gt;＆gt; ＆gt; oid = res [0] [0]＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃创建一个表并存储blob＆gt的oid;＆gt; ＆gt;骗子。运行（＆＃34;创建临时表图像（光栅OID）＆＃34;）[]＆gt;＆gt; ＆gt;骗子。运行（＆＃34;插入图像（栅格）值（：oid）＆＃34;，oid = oid）[]＆gt;＆gt; ＆gt; ＃使用OID＆gt检索数据。＆gt; ＆gt;骗子。运行（＆＃34;选择lo_get（：oid）＆＃34;，oid = oid）[[b＆＃39; hello＆＃39;]]＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃将一些数据添加到Blob＆gt的末尾;＆gt; ＆gt; more_data = B＆＃39;所有＆＃39; ＆gt;＆gt; ＆gt; offset = len（数据）＆gt;＆gt; ＆gt;骗子。运行（...＆＃34;选择lo_put（：oid，：offset，deam）＆＃34;，... oid = oid，offset = offset，data = more_data）[[＆＃39;＆＃39 ;]]]＆gt;＆gt; ＆gt;骗子。 run（＆＃34;选择lo_get（：oid）＆＃34;，oid = oid）[[b＆＃39;你好所有＆＃39;]＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; ＃下载数据的一部分＆gt;＆gt; ＆gt;骗子。运行（＆＃34;选择lo_get（：oid，6,3）＆＃34;，oid = oid）[[b＆＃39;全部＆＃39;]]]

导入pg8000，连接数据库，创建一个表，添加一些行，然后添加一个表：

＆gt;＆gt; ＆gt;导入pg8000。 dbapi＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; conn = pg8000。 dbapi。 Connect（User =＆＃34; Postgres＆＃34;，密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; Cursor = Conn。 Cursor（）＆gt;＆gt; ＆gt;光标。执行（＆＃34;创建临时表书（ID序列，标题文本）＆＃34;）＆gt;＆gt; ＆gt;光标。执行（...＆＃34;插入到书籍（标题）值（％s），（％s）返回id，title＆＃34;，...（＆＃34; enter＆＃39; s game＆＃34; ，＆＃34;死者的扬声器＆＃34;））> ＆gt;结果=光标。 fetchall（）＆gt;＆gt; ＆gt;在结果中为行：... ID，标题=行...打印（＆＃34; ID =％s，title =％s＆＃34;％（id，title））id = 1，标题= enter＆＃39 ; S游戏ID = 2，标题=死者的扬声器＆gt;＆gt; ＆gt;康涅狄格州。犯罪（）

＆gt;＆gt; ＆gt;导入pg8000。 dbapi＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。 dbapi。 Connect（User =＆＃34; Postgres＆＃34;，密码=＆＃34; cpsnow＆＃34;）＆gt;＆gt; ＆gt; Cursor = Con。 Cursor（）＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt;光标。执行（＆＃34;从现在（从现在（））＆＃34;）＆gt;＆gt; ＆gt;光标。 fetchone（）[3.0]

＆gt;＆gt; ＆gt;导入DateTime＆gt;＆gt; ＆gt;导入pg8000。 dbapi＆gt;＆gt; ＆gt; ＆gt;＆gt; ＆gt; con = pg8000。 dbapi。连接（用户=＆＃34; postgres＆＃34;

......