百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 热门文章 > 正文

一日一技:Python | PostgreSQL中的数据库管理

bigegpt 2025-02-03 11:28 12 浏览

有几个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() 

输出:

相关推荐

或者这些Joplin插件也可以帮助你的笔记应用再一次强大

写在前面距离上次分享《搭建私有全平台多端同步笔记,群晖NAS自建JoplinServer服务》已过去一段时间,大家是否开始使用起来了呢?如果你和我一样已经使用过Joplin有一段时间了,那或许你也会...

Three.JS教程4 threejs中的辅助类

一、辅助类简介Three.js提供了一些辅助类(Helpers)以帮助我们更容易地调试、可视化场景中的元素。ArrowHelepr:创建箭头辅助器;AxisHelper:创建坐标轴辅助器;BoxH...

第2章 还记得点、线、面吗(二)(第二章还能敲钟吗)

glbgltf模型(webvrmodel)-gltf模型下载定制,glb模型下载定制,三维项目电商网站在线三维展示,usdz格式,vr模型网,网页VR模型下载,三维模型下载,webgl网页模型下载我...

如何检查Linux系统硬件信息?从CPU到显卡,一网打尽!

你可能会问:“我为什么要关心硬件信息?”答案很简单:硬件是Linux系统的根基,了解它可以帮你解决很多实际问题。比如:性能调优:知道CPU核心数和内存大小,才能更好地调整程序运行参数。故障排查:系统卡...

SpriteJS:图形库造轮子的那些事儿

从2017年到2020年,我花了大约4年的时间,从零到一,实现了一个可切换WebGL和Canvas2D渲染的,跨平台支持浏览器、SSR、小程序,基于DOM结构和支持响应式的,高...

平时积累的FPGA知识点(6)(fpga经典应用100例)

平时在FPGA群聊等积累的FPGA知识点,第六期:1万兆网接口,发三十万包,会出现掉几包的情况,为什么?原因:没做时钟约束,万兆网接口的实现,本质上都是高速serdes,用IP的话,IP会自带约束。...

芯片逻辑调度框架设计 都需要那些那些软件工具

设计芯片逻辑调度框架通常需要使用以下软件工具:1.逻辑设计工具:例如Vivado、Quartus、SynopsysDesignCompiler等,用于设计和实现逻辑电路。2.仿真工具:例如Mo...

ZYNQ与DSP之间EMIF16通信(正点原子领航者zynq之fpga开发指南v3)

本文主要介绍说明XQ6657Z35-EVM高速数据处理评估板ZYNQ与DSP之间EMIF16通信的功能、使用步骤以及各个例程的运行效果。[基于TIKeyStone架构C6000系列TMS320C6...

好课推荐:从零开始大战FPGA(从零开始的冒险4399)

从零开始大战FPGA引子:本课程为“从零开始大战FPGA”系列课程的基础篇。课程通俗易懂、逻辑性强、示例丰富,课程中尤其强调在设计过程中对“时序”和“逻辑”的把控,以及硬件描述语言与硬件电路相对应的“...

业界第一个真正意义上开源100 Gbps NIC Corundum介绍

来源:内容由「网络交换FPGA」编译自「FCCM2020」,谢谢。FCCM2020在5月4日开始线上举行,对外免费。我们有幸聆听了其中一个有关100G开源NIC的介绍,我们对该文章进行了翻译,并对其中...

高层次综合:解锁FPGA广阔应用的最后一块拼图

我们为什么需要高层次综合高层次综合(High-levelSynthesis)简称HLS,指的是将高层次语言描述的逻辑结构,自动转换成低抽象级语言描述的电路模型的过程。所谓的高层次语言,包括C、C++...

Xilinx文档编号及其内容索引(部分)

Xilinx文档的数量非常多。即使全职从事FPGA相关工作,没有几年时间不可能对器件特性、应用、注意事项等等有较为全面的了解。本文记录了我自使用Xilinx系列FPGA以来或精读、或翻阅、或查询过的文...

Xilinx Vivado联合Modelsim软件仿真

引言:Xilinx公司Vivado开发软件自带仿真工具,可以实现一般性能的FPGA软件仿真测试,其测试执行效率以及性能都不如第三方专用仿真软件Modelsim强。本文我们介绍下如何进行Vivado20...

体育动画直播是怎么做出来的?从数据到虚拟赛场的科技魔法!

你是否见过这样的比赛直播?没有真实球员,却能看梅西带球突破?足球比赛变成动画版,但数据100%真实?电竞比赛用虚拟形象直播,选手操作实时同步?这就是体育动画直播——一种融合实时数据、游戏引擎和AI的...

Dialogue between CPC and political parties of neighboring countries held in Beijing

BEIJING,May26(Xinhua)--TheCommunistPartyofChina(CPC)inDialoguewithPoliticalPartiesof...