有几个python模块可以让我们使用PostgreSQL连接和操作数据库：

1. Psycopg2
2. pg8000
3. py-postgresql
4. PyGreSQL

Psycopg2是PostgreSQL最受欢迎的python驱动程序之一。 它被积极维护并为不同版本的python提供支持。 它还提供对线程的支持，并且可以在多线程应用程序中使用。 由于这些原因，它是开发人员的流行选择。

在这一小节中，我们将通过在python中构建一个简单的数据库管理系统来探索使用psycopg2使用PostgreSQl的功能。

安装模块：

sudo pip3 install psycopg2   #使用的是 Ubuntu系统

注意：如果您使用的是Python2，请使用pip install代替pip3，不过python2.7版本已经不再维护，不推荐使用。

在您的系统中安装了psycopg之后，我们可以连接到数据库并在Python中执行查询。

创建数据库

在我们可以使用python访问数据库之前，我们需要在postgresql中创建数据库。 要创建数据库，请遵循以下步骤：

1.登录PostgreSQL.

sudo -u postgres psql

2.配置密码.

\password

然后将提示您输入密码。 记住这一点，因为我们将使用它来连接到Python中的数据库。

3.创建一个名为“ test”的数据库。 我们将连接到该数据库.

CREATE DATABASE test;   #分号；别忘记带上

配置数据库和密码后，退出psql服务器。

连接到数据库

connect（）方法用于建立与数据库的连接。 它包含5个参数：

1.database：您要连接的数据库的名称

2.user：您本地系统的用户名

3.password：登录psql的密码

4.host：主机，默认情况下设置为localhost

5.port：端口号，默认为5432

conn = psycopg2.connect(            database="test",             user = "adith",             password = "password",             host = "localhost",             port = "5432")

建立连接后，我们可以使用python操作数据库。

Cursor对象用于执行sql查询。 我们可以使用连接对象（conn）创建一个游标对象

cur = conn.cursor()  

使用此对象，我们可以更改连接到的数据库。

执行完所有查询后，我们需要断开连接。 不断开连接不会导致任何错误，但是通常认为断开连接是一种好习惯。

 conn.close() 

执行查询

execute（）方法采用一个参数，即要执行的SQL查询。 SQL查询采用包含SQL语句的字符串形式。

cur.execute("SELECT * FROM emp") 

获得数据

一旦执行了查询，就可以使用fetchall（）方法获取查询的结果。 此方法不带参数，并返回选择查询的结果。

 res = cur.fetchall() 

查询结果存储在res变量中.

全部放在一起

在PostgreSQL中创建数据库后，就可以使用python访问该数据库。 我们首先使用以下模式在数据库中创建一个名为test的emp表：（id INTEGER PRIMARY KEY，名称VARCHAR（10），salary INT，dept INT）。 创建表后，没有任何错误，我们将值插入表中。

插入值后，我们可以查询表以选择所有行，并使用fetchall（）函数将其显示给用户。

# importing libraries import psycopg2 # a function to connect to # the database. def connect(): 	# connecting to the database called test 	# using the connect function 	try: 		conn = psycopg2.connect(database ="test", 							user = "adith", 							password = "password", 							host = "localhost", 							port = "5432") 		# creating the cursor object 		cur = conn.cursor() 		except (Exception, psycopg2.DatabaseError) as error: 				print ("Error while creating PostgreSQL table", error) 		# returing the conn and cur 	# objects to be used later 	return conn, cur # a function to create the # emp table. def create_table(): 	# connect to the database. 	conn, cur = connect() 	try: 		# the test database contains a table called emp 		# the schema : (id INTEGER PRIMARY KEY, 		# name VARCHAR(10), salary INT, dept INT) 		# create the emp table 		cur.execute('CREATE TABLE emp (id INT PRIMARY KEY, name VARCHAR(10), 									salary INT, dept INT)') 		# the commit function permanently 		# saves the changes made to the database 		# the rollback() function can be used if 		# there are any undesirable changes and 		# it simply undoes the changes of the 		# previous query 		except: 		print('error') 	conn.commit() # a function to insert data # into the emp table def insert_data(id = 1, name = '', salary = 1000, dept = 1): 	conn, cur = connect() 	try: 		# inserting values into the emp table 		cur.execute('INSERT INTO emp VALUES(%s, %s, %s, %s)', 									(id, name, salary, dept)) 		except Exception as e: 		print('error', e) 	# commiting the transaction. 	conn.commit() # a function to fetch the data # from the table def fetch_data(): 	conn, cur = connect() 	# select all the rows from emp 	try: 		cur.execute('SELECT * FROM emp') 		except: 		print('error !') 	# store the result in data 	data = cur.fetchall() 	# return the result 	return data # a function to print the data def print_data(data): 	print('Query result: ') 	print() 	# iterating over all the 	# rows in the table 	for row in data: 		# printing the columns 		print('id: ', row[0]) 		print('name: ', row[1]) 		print('salary: ', row[2]) 		print('dept: ', row[3]) 		print('----------------------------------') # function to delete the table def delete_table(): 	conn, cur = connect() 	# delete the table 	try: 		cur.execute('DROP TABLE emp') 	except Exception as e: 		print('error', e) 	conn.commit() # driver function if __name__ == '__main__': 	# create the table 	create_table() 	# inserting some values 	insert_data(1, 'adith', 1000, 2) 	insert_data(2, 'tyrion', 100000, 2) 	insert_data(3, 'jon', 100, 3) 	insert_data(4, 'daenerys', 10000, 4) 	# getting all the rows 	data = fetch_data() 	# printing the rows 	print_data(data) 	# deleting the table 	# once we are done with 	# the program 	delete_table() 

输出：