Python3练习项目13：简单的BBS功能（上）

这个练习项目来自《Python基础教程（第2版）》，案例原名为“自定义电子公告板”。

练习包括两个阶段：

第一阶段：实现与PostgreSQL的连接与数据操作，并将数据呈现为网页。

第二阶段：实现消息列表、查看消息、编辑消息、回复消息和保存信息等功能。

本篇教程我们完成第一阶段。

一、创建数据库与数据表

大家可以参考《PostgreSQL数据库简易安装教程》完成数据库以及表的创建。

除了《PostgreSQL数据库简易安装教程》中创建数据库与数据表的SQL语句，这里再给大家列出一些当前项目准备过程中可能需要用到的语句。

此处以数据库“myproject_db”和数据表“messages”以及用户“opython”简单举例。

注意：红色部分加粗部分均为可变内容，并且，SQL Shell中命令结束加分号“;”才能够执行。

drop databasemyproject_db;

create useropythonwith superuser password ‘123456‘;

alter useropythonwith password ‘654321‘;

drop useropython;

drop tablemessages;

insert intomessages(列名1,列名2,…) values (值1,值2,…);

select * frommessages;

selectsubject,textfrommessageswhereid=1;

在进行下一步之前，如果还没有创建数据表“messages”的话，可以通过如下语句进行创建。

示例代码：

create table messages(id serial primary key,subject text not null,sender text not null,reply_to integer references messages,text text not null);

这里，我对每一列的名称做一下解释：

id：消息序号，serial表示自动增长的数字，primary key表示这一列是不可重复的主键。

subject：消息标题，text表示文本类型，not null表示不可为空值。

sender：消息发送人。

reply_to：被回复消息序号，integer表示整数类型，references messages表示引用messages表的主键，也就是说被回复消息的序号必须是messages表中主键序号之一，即只有已存在表中的消息才能被回复。

text：消息内容。

二、尝试与数据库进行连接

与数据库进行连接，我们需要使用到psycopg2模块。

通过psycopg2模块中的connect()方法与数据库进行连接。

注意，connect()方法中参数的提供有两种不同的写法。

示例代码：

import psycopg2conn = psycopg2.connect(database='myproject_db', user='opython', password='opython') # 连接数据库# 另一种写法：conn=psycopg2.connect('user=opython password=opython dbname=myproject_db ')curs = conn.cursor() # 获取游标对象sql = 'select * from messages'curs.execute(sql) # 执行SQL语句print(curs.fetchall()) # 显示输出所有查询结果

当我们运行代码，我们能够看到由数据库中所有数据行元组所组成的列表。

当然，如果数据库中没有任何数据，只会显示一个空列表。

到这里，我们已经能够成功的进行数据库的访问。

三、尝试向数据库中添加数据

我们可以通过input()函数模拟获取用户输入，然后根据输入中是否有被回复消息的序号来决定如何插入新的数据。

这个功能实现起来很简单，请大家参考示例代码进行理解。

示例代码：

import psycopg2subject = input('标题：')sender = input('发送人：')reply_to = input('回复给：')text = input('内容：')if reply_to: # 如果是回复已有消息 sql = "insert into messages(subject,sender,reply_to,text) values('%s','%s',%s,'%s')" % ( subject, sender, reply_to, text)else: # 否则是发布新的消息 sql = "insert into messages(subject,sender,text) values('%s','%s','%s')" % (subject, sender, text)conn = psycopg2.connect(database='myproject_db', user='postgres', password='opython')curs = conn.cursor()curs.execute(sql)conn.commit() # 提交数据操作sql = 'select * from messages'curs.execute(sql)print(curs.fetchall())

运行上方代码之后，我们就能够向数据库中添加新的内容了。

四、查询数据并输出到HTML

输出的网页内容如下图：

我们可以在PyCharm中先新建一个HTML文件，编写页面代码。

示例代码：（HTML）

我的论坛小楼帅哥的第一个BBSid.发送人：消息标题

消息内容 id.回复人：回复标题

回复内容

接下来，我们可以新建一个CGI或py脚本，将这些HTML代码复制到脚本代码中使用。

示例代码：

import psycopg2.extrasconn = psycopg2.connect(database='myproject_db', user='opython', password='opython')curs = conn.cursor(cursor_factory=psycopg2.extras.DictCursor) # 参数是以字典形式获取查询结果print(''' 我的论坛 小楼帅哥的第一个BBS''')sql = 'select * from messages'curs.execute(sql)messages = curs.fetchall()top_level = [] # 保存父级消息的列表children = {} # 保存子级消息的字典for message in messages: # 遍历返回的消息列表 parrent_id = message['reply_to'] # 获取消息元组中的reply_to列 if parrent_id is None: # 如果不是回复的消息 top_level.append(message) # 添加到父级消息列表 else: children.setdefault(parrent_id, []).append(message) # 否则以被回复消息的序号为键添加回复消息到值的列表def format_show(message): print('{}.{}：{}'.format(message['id'], message['sender'], message['subject'])) # 输出父级消息内容 print('{}'.format(message['text'])) try: kids = children[message['id']] # 根据父级消息id从子级消息字典中查找所有子级消息 except KeyError: pass else: print('') for kid in kids: # 遍历找到的消息列表 format_show(kid) # 递归进行下一级消息的处理 print('')print('

')for message in top_level: # 遍历父级消息 format_show(message) # 调用递归函数进行多级遍历print('''

''')

在上方代码中，重点内容是所有消息的输出使用到了递归函数。

基本原理是：读取一条顶级消息时，调用递归函数，将顶级消息输出到页面，然后以顶级消息的id为键，获取到子级消息字典中对应的值的列表。然后，再对子级消息进行遍历，将子级消息作为父级消息再次调用递归函数。

到这里，我们就完成了第一阶段的练习。