Psycopg数据库基本使用

Posted 2021-02-15 yunwangjun-python-520

一、Psycopg简介

Psycopg是Python编程语言中最流行的PostgreSQL数据库适配器。它的主要功能是完整实现Python DB API 2.0规范和线程安全（多个线程可以共享相同的连接）。它专为大量多线程应用程序而设计，可以创建和销毁大量游标并创建大量并发“INSERT”或“UPDATE”。

Psycopg 2主要在C中作为libpq包装器实现，从而既高效又安全。它具有客户端和服务器端游标，异步通信和通知，“复制到/复制”支持。许多Python类型都支持开箱即用，适用于匹配PostgreSQL数据类型; 通过灵活的物体适应系统，可以扩展和定制适应性。
Psycopg 2兼容Unicode和Python 3。

 

二、安装Psycopg

pip install psycopg2

 

 

 

三、PsyCopg的使用

 

使用Python3连接postgresql数据库

 

 

import psycopg2
 
#创建连接对象
conn=psycopg2.connect(database="postgres",user="postgres",password="123456",host="localhost",port="5432")
cur=conn.cursor() #创建指针对象
 
# 创建表
cur.execute("CREATE TABLE student(id integer,name varchar,sex varchar);")
 
#插入数据
cur.execute("INSERT INTO student(id,name,sex)VALUES(%s,%s,%s)",(1,‘Aspirin‘,‘M‘))
cur.execute("INSERT INTO student(id,name,sex)VALUES(%s,%s,%s)",(2,‘Taxol‘,‘F‘))
cur.execute("INSERT INTO student(id,name,sex)VALUES(%s,%s,%s)",(3,‘Dixheral‘,‘M‘))
 
# 获取结果
cur.execute(‘SELECT * FROM student‘)
results=cur.fetchall()
print (results)
 
# 关闭连接
conn.commit()
cur.close()
conn.close()

 

 

 

 

 

Pgsql常用命令：

 连接数据库, 默认的用户和数据库是postgres
psql -U user -d dbname

切换数据库,相当于mysql的use dbname
c dbname
列举数据库，相当于mysql的show databases
l
列举表，相当于mysql的show tables
dt
查看表结构，相当于desc tblname,show columns from tbname
d tblname

di 查看索引 

创建数据库： 
create database [数据库名]; 
删除数据库： 
drop database [数据库名];  
*重命名一个表： 
alter table [表名A] rename to [表名B]; 
*删除一个表： 
drop table [表名]; 

*在已有的表里添加字段： 
alter table [表名] add column [字段名] [类型]; 
*删除表中的字段： 
alter table [表名] drop column [字段名]; 
*重命名一个字段：  
alter table [表名] rename column [字段名A] to [字段名B]; 
*给一个字段设置缺省值：  
alter table [表名] alter column [字段名] set default [新的默认值];
*去除缺省值：  
alter table [表名] alter column [字段名] drop default; 
在表中插入数据： 
insert into 表名 ([字段名m],[字段名n],......) values ([列m的值],[列n的值],......); 
修改表中的某行某列的数据： 
update [表名] set [目标字段名]=[目标值] where [该行特征]; 
删除表中某行数据： 
delete from [表名] where [该行特征]; 
delete from [表名];--删空整个表 
创建表： 
create table ([字段名1] [类型1] <references 关联表名(关联的字段名)>;,[字段名2] [类型2],......<,primary key (字段名m,字段名n,...)>;); 

copyright     显示 PostgreSQL 的使用和发行条款
encoding [字元编码名称]
                 显示或设定用户端字元编码
h [名称]      SQL 命令语法上的说明，用 * 显示全部命令
prompt [文本] 名称
                 提示用户设定内部变数
password [USERNAME]
                 securely change the password for a user
q             退出 psql


可以使用pg_dump和pg_dumpall来完成。比如备份sales数据库： 
pg_dump drupal>/opt/Postgresql/backup/1.bak

 

 

pgsql操作数据库命令

 

  关于postgresql——常用操作指令 
创建数据库
CREATE DATABASE test WITH OWNER = postgres ENCODING = ‘UTF8‘;

进入控制台方法，在postgreSQL的安装目的bin下执行命令： psql 数据库名，
 例： /usr/local/pgsql/bin/psql mydb

指定host、用户名和数据库的话，如：
/usr/local/pgsql/bin/psql -h localhost -U postgres -d test

查看版本： psql --version 或 SELECT version();

查看所有数据库：l

查看所有数据库（包括详细参数）：select * from pg_database;

选择数据库：c databasename

查看所有表：dt schema_name.* 

查看某个表的结构：d schema_name.tablename

退出psql控制台：q

查看表的索引：
select * from pg_indexes where tablename=‘log‘;

导出备份数据库：
pg_dump -h localhost -U postgres databasename > /tmp/databasename.bak.yyyymmdd.sql
(或者用如下命令：
#su postgres

#psql 

说明：

1.(psql -U immuser -h 127.0.0.1 -d newpro 表示使用newpro数据库的immuser用户登录本地服务器的newpro数据库

2.（psql -U postgres -h 127.0.0.1 表示使用postgres 用户登录本地数据库）)
#l
#q
#cd   (这里cd后面直接按回车键，表示进入到postgres用户的home目录，linux是多用户的，cd后面不加任何参数表示，进入当前用户的家目录中)
#pg_dump databasename > databasename.sql
)

 

下面是数据库备份与恢复详细过程：

导入恢复数据库(sql文件是pg_dump导出的文件就行，可以是整个数据库，也可以只是单个表，也可以只是结构等)：
 mkdir -p /var/lib/pgsql/9.4/data/newpro_space #创建存放表空间的目录
chown -R postgres:postgres /var/lib/pgsql/9.4/data/newpro_space #修改其所属组
(1).创建表空间
CREATE TABLESPACE newpro_sp
  OWNER immuser
  LOCATION ‘/var/lib/pgsql/9.4/data/newpro_space‘;
-- Database: usercenter
-- DROP DATABASE usercenter;

(2).创建数据库，因为备份数据库时只能备份表的结构和内容，所以在回复数据库的时候要先创建数据库，用于恢复数据；
CREATE DATABASE newpro
  WITH OWNER = immuser
       ENCODING = ‘UTF8‘
       TABLESPACE = newpro_sp
       LC_COLLATE = ‘en_US.UTF-8‘
       LC_CTYPE = ‘en_US.UTF-8‘
       CONNECTION LIMIT = -1;
psql -h localhost -U postgres -d databasename < /tmp/databasename.bak.yyyymmdd.sql
(或者用如下命令：
#su postgres
#cd   (这里cd后面直接按回车键，表示进入到postgres用户的home目录，linux是多用户的，cd后面不加任何参数表示，进入当前用户的家目录中)
psql databasename < databasename.sql
)

导出数据结构，主要是加上参数-s：
pg_dump -U username -W dbname -f /tmp/filename.sql

导出某个表：
pg_dump -h localhost -U postgres -t tablename dbname > test.sql

导出某个表的结构，同样是加参数"-s"：
pg_dump -h localhost -U postgres -t tablename -s dbname > test_construct.sql

导出某个表的数据，加参数"-a"：
pg_dump -h localhost -U postgres -t tablename -a dbname > test_data.sql

查看序列：select * from information_schema.sequences where sequence_schema = ‘public‘;

查看数据库大小：select pg_size_pretty(pg_database_size(‘test‘));

查看表的大小：select pg_size_pretty(pg_relation_size(‘test‘));

 

####为了便于数据库的统一管理与减少pgsql的安装将三台服务器数据库全部搭建在87服务器上####
###10.0.1.87###
首先要先将101和70服务器上的数据库备份.sql文件上传到87服务器上；
然后按照如下步骤操作：

a).恢复newpro数据库：
 mkdir -p /var/lib/pgsql/9.4/data/newpro_space #创建存放表空间的目录
chown -R postgres:postgres /var/lib/pgsql/9.4/data/newpro_space #修改其所属组
#su postgres
#psql
(1).创建表空间
CREATE TABLESPACE newpro_sp
  OWNER immuser
  LOCATION ‘/var/lib/pgsql/9.4/data/newpro_space‘;
-- Database: newpro;
-- DROP DATABASE newpro;

(2).创建数据库，因为备份数据库时只能备份表的结构和内容，所以在回复数据库的时候要先创建数据库，用于恢复数据；
CREATE DATABASE newpro
  WITH OWNER = immuser
       ENCODING = ‘UTF8‘
       TABLESPACE = newpro_sp
       LC_COLLATE = ‘en_US.UTF-8‘
       LC_CTYPE = ‘en_US.UTF-8‘
       CONNECTION LIMIT = -1;
#q
psql -h localhost -U postgres -d newpro< newpro.sql
(或者用如下命令：
#su postgres
#cd   (这里cd后面直接按回车键，表示进入到postgres用户的home目录，linux是多用户的，cd后面不加任何参数表示，进入当前用户的家目录中)
psql newpro< newpro.sql
)

b).恢复usercenter数据库：
 mkdir -p /var/lib/pgsql/9.4/data/usercenter_space #创建存放表空间的目录
chown -R postgres:postgres /var/lib/pgsql/9.4/data/usercenter_space #修改其所属组
#su postgres
#psql
(1).创建表空间
CREATE TABLESPACE usercenter_sp
  OWNER immuser
  LOCATION ‘/var/lib/pgsql/9.4/data/usercenter_space‘;
-- Database: usercenter;
-- DROP DATABASE usercenter;

(2).创建数据库，因为备份数据库时只能备份表的结构和内容，所以在回复数据库的时候要先创建数据库，用于恢复数据；
CREATE DATABASE usercenter
  WITH OWNER = immuser
       ENCODING = ‘UTF8‘
       TABLESPACE = usercenter_sp
       LC_COLLATE = ‘en_US.UTF-8‘
       LC_CTYPE = ‘en_US.UTF-8‘
       CONNECTION LIMIT = -1;
#q

psql -h localhost -U postgres -d usercenter< usercenter.sql
(或者用如下命令：
#su postgres
#cd   (这里cd后面直接按回车键，表示进入到postgres用户的home目录，linux是多用户的，cd后面不加任何参数表示，进入当前用户的家目录中)
psql usercenter< usercenter.sql
)

c).恢复teamtalk数据库
mkdir -p /var/lib/pgsql/9.4/data/teamtalk_space #创建存放表空间的目录
chown -R postgres:postgres /var/lib/pgsql/9.4/data/teamtalk_space #修改其所属组
#su postgres
#psql
SET statement_timeout = 0;
SET client_encoding = ‘UTF8‘;
SET standard_conforming_strings = on;
SET check_function_bodies = false;
SET client_min_messages = warning;
CREATE SCHEMA teamtalk;
ALTER SCHEMA teamtalk OWNER TO immuser;

(1).创建表空间
CREATE TABLESPACE teamtalk_sp
  OWNER immuser
  LOCATION ‘/var/lib/pgsql/9.4/data/teamtalk_space‘;
-- Database: teamtalk;
-- DROP DATABASE teamtalk;

(2).创建数据库，因为备份数据库时只能备份表的结构和内容，所以在回复数据库的时候要先创建数据库，用于恢复数据；
CREATE DATABASE teamtalk
  WITH OWNER = immuser
       ENCODING = ‘UTF8‘
       TABLESPACE = teamtalk_sp
       LC_COLLATE = ‘en_US.UTF-8‘
       LC_CTYPE = ‘en_US.UTF-8‘
       CONNECTION LIMIT = -1;
#q


psql -h localhost -U postgres -d teamtalk< teamtalk.sql
(或者用如下命令：
#su postgres
#cd   (这里cd后面直接按回车键，表示进入到postgres用户的home目录，linux是多用户的，cd后面不加任何参数表示，进入当前用户的家目录中)
psql teamtalk< teamtalk_new.sql
)

View Code