Python psycopg2 create database

Введение в PostgreSQL с Python +Psycopg2

Это руководство по PostgreSQL в Python описывает, как использовать модуль Psycopg2 для подключения к PostgreSQL, выполнения SQL-запросов и других операций с базой данных.

Здесь не инструкции по установки локального сервера, так как это не касается python. Скачайте и установите PostgreSQL с официального сайта https://www.postgresql.org/download/. Подойдут версии 10+, 11+, 12+.

Вот список разных модулей Python для работы с сервером базы данных PostgreSQL:

• Psycopg2,
• pg8000,
• py-postgreql,
• PyGreSQL,
• ocpgdb,
• bpsql,
• SQLAlchemy. Для работы SQLAlchemy нужно, чтобы хотя бы одно из перечисленных выше решений было установлено.

Примечание: все модули придерживаются спецификации Python Database API Specification v2.0 (PEP 249). Этот API разработан с целью обеспечить сходство разных модулей для доступа к базам данных из Python. Другими словами, синтаксис, методы и прочее очень похожи во всех этих модулях.

В этом руководстве будем использовать Psycopg2, потому что это один из самых популярных и стабильных модулей для работы с PostgreSQL:

• Он используется в большинстве фреймворков Python и Postgres;
• Он активно поддерживается и работает как с Python 3, так и с Python 2;
• Он потокобезопасен и спроектирован для работы в многопоточных приложениях. Несколько потоков могут работать с одним подключением.

В этом руководстве пройдемся по следующим пунктам:

• Установка Psycopg2 и использование его API для доступа к базе данных PostgreSQL;
• Вставка, получение, обновление и удаление данных в базе данных из приложения Python;
• Дальше рассмотрим управление транзакциями PostgreSQL, пул соединений и методы обработки исключений, что понадобится для разработки сложных программ на Python с помощью PostgreSQL.

Установка Psycopg2 с помощью pip

Для начала нужно установить текущую версию Psycopg2 для использования PostgreSQL в Python. С помощью команды pip можно установить модуль в любую операцию систему: Windows, macOS, Linux:

Также можно установить конкретную версию программы с помощью такой команды:

Если возникает ошибка установки, например «connection error: [SSL: CERTIFICATE_VERIFY_FAILED] certificate verify failed (_ssl.c:598)», то ее можно решить, сделав files.pythonhosted.org доверенным хостом:

python -m pip install --trusted-host pypi.org --trusted-host files.pythonhosted.org --trusted-host pypi.python.org psycopg2 

Модуль psycopg2 поддерживает:

• Python 2.7 и Python 3, начиная с версии 3.4.
• Сервер PostgreSQL от 7.4 до 12.
• Клиентскую библиотеку PostgreSQL от 9.1.

Проверка установки Psycopg2

После запуска команды должны появиться следующие сообщения:

• Collecting psycopg2
• Downloading psycopg2-2.8.6
• Installing collected packages: psycopg2
• Successfully installed psycopg2-2.8.6

При использовании anaconda подойдет следующая команда.

conda install -c anaconda psycopg2

Подключение к базе данных PostgreSQL из Python

В этом разделе рассмотрим, как подключиться к PostgreSQL из Python с помощью модуля Psycopg2.

Вот какие аргументы потребуются для подключения:

• Имя пользователя: значение по умолчанию для базы данных PostgreSQL – postgres.
• Пароль: пользователь получает пароль при установке PostgreSQL.
• Имя хоста: имя сервера или IP-адрес, на котором работает база данных. Если она запущена локально, то нужно использовать localhost или 127.0.0.0.
• Имя базы данных: в этом руководстве будем использовать базу postgres_db .

• Использовать метод connect() с обязательными параметрами для подключения базы данных.
• Создать объект cursor с помощью объекта соединения, который возвращает метод connect . Он нужен для выполнения запросов.
• Закрыть объект cursor и соединение с базой данных после завершения работы.
• Перехватить исключения, которые могут возникнуть в процессе.

Создание базы данных PostgreSQL с Psycopg2

Для начала создадим базу данных на сервере. Во время установки PostgreSQL вы указывали пароль, его нужно использовать при подключении.

 
import psycopg2 
from psycopg2 import Error 
from psycopg2.extensions import ISOLATION_LEVEL_AUTOCOMMIT try: 
# Подключение к существующей базе данных 
connection = psycopg2.connect(user="postgres", 
# пароль, который указали при установке PostgreSQL 
password="1111", 
host="127.0.0.1", 
port="5432") 
connection.set_isolation_level(ISOLATION_LEVEL_AUTOCOMMIT) 
# Курсор для выполнения операций с базой данных 
cursor = connection.cursor() 
sql_create_database = 'create database postgres_db' 
cursor.execute(sql_create_database) except (Exception, Error) as error: 
print("Ошибка при работе с PostgreSQL", error) 
finally: 
if connection: 
cursor.close() 
connection.close() 
print("Соединение с PostgreSQL закрыто") 
 
Пример кода для подключения к базе данных PostgreSQL из Python
 
Для подключения к базе данных PostgreSQL и выполнения SQL-запросов нужно знать название базы данных. Ее нужно создать прежде чем пытаться выполнить подключение.
 
 
import psycopg2 
from psycopg2 import Error 
 
try: 
# Подключение к существующей базе данных 
connection = psycopg2.connect(user="postgres", 
# пароль, который указали при установке PostgreSQL 
password="1111", 
host="127.0.0.1", 
port="5432", 
database="postgres_db") 
 
# Курсор для выполнения операций с базой данных 
cursor = connection.cursor() 
# Распечатать сведения о PostgreSQL 
print("Информация о сервере PostgreSQL") 
print(connection.get_dsn_parameters(), "\n") 
# Выполнение SQL-запроса 
cursor.execute("SELECT version();") 
# Получить результат 
record = cursor.fetchone() 
print("Вы подключены к - ", record, "\n") 
 
except (Exception, Error) as error: 
print("Ошибка при работе с PostgreSQL", error) 
finally: 
if connection: 
cursor.close() 
connection.close() 
print("Соединение с PostgreSQL закрыто") 
 
После подключения появится следующий вывод:
 
Информация о сервере PostgreSQL Вы подключены к - ('PostgreSQL 10.13, compiled by Visual C++ build 1800, 64-bit',) Соединение с PostgreSQL закрыто
 
Разбор процесса подключения в деталях
 
import psycopg2 — Эта строка импортирует модуль Psycopg2 в программу. С помощью классов и методов модуля можно взаимодействовать с базой.
 
from psycopg2 import Error — С помощью класса Error можно обрабатывать любые ошибки и исключения базы данных. Это сделает приложение более отказоустойчивым. Этот класс также поможет понять ошибку в подробностях. Он возвращает сообщение об ошибке и ее код.
 
psycopg2.connect() — С помощью метода connect() создается подключение к экземпляру базы данных PostgreSQL. Он возвращает объект подключения. Этот объект является потокобезопасным и может быть использован на разных потоках.
 
Метод connect() принимает разные аргументы, рассмотренные выше. В этом примере в метод были переданы следующие аргументы: user = "postgres", password = "1111", host = "127.0.0.1", port = "5432", database = "postgres_db" .
 
cursor = connection.cursor() — С базой данных можно взаимодействовать с помощью класса cursor . Его можно получить из метода cursor() , который есть у объекта соединения. Он поможет выполнять SQL-команды из Python.
 
Из одного объекта соединения можно создавать неограниченное количество объектов cursor . Они не изолированы, поэтому любые изменения, сделанные в базе данных с помощью одного объекта, будут видны остальным. Объекты cursor не являются потокобезопасными.
 
После этого выведем свойства соединения с помощью connection.get_dsn_parameters() .
 
cursor.execute() — С помощью метода execute объекта cursor можно выполнить любую операцию или запрос к базе данных. В качестве параметра этот метод принимает SQL-запрос. Результаты запроса можно получить с помощью fetchone() , fetchmany() , fetchall() .
 
В этом примере выполняем SELECT version(); для получения сведений о версии PosgreSQL.
 
Блок try-except-finally — Разместим код в блоке try-except для перехвата исключений и ошибок базы данных.
 
cursor.close() и connection.close() — Правильно всегда закрывать объекты cursor и connection после завершения работы, чтобы избежать проблем с базой данных.
 
Создание таблицы PostgreSQL из Python
 
В этом разделе разберем, как создавать таблицу в PostgreSQL из Python. В качестве примера создадим таблицу Mobile.
 
 
Подготовим запрос для базы данных
 
Подключимся к PosgreSQL с помощью psycopg2.connect() .
 
Выполним запрос с помощью cursor.execute() .
 
Закроем соединение с базой данных и объект cursor .
 
 
Источник
 
Python psycopg2 create database
 
Для создания базы данных применяется SQL-команда CREATE DATABASE , которой передается имя базы данных. Например, создадим базу данных с именем "metanit":
 
import psycopg2 conn = psycopg2.connect(dbname="postgres", user="postgres", password="123456", host="127.0.0.1") cursor = conn.cursor() conn.autocommit = True # команда для создания базы данных metanit sql = "CREATE DATABASE metanit" # выполняем код sql cursor.execute(sql) print("База данных успешно создана") cursor.close() conn.close()
 
Обратите внимание, что для выражения "CREATE DATABASE" необходимо установиить автокоммит:
 
Благодаря этому команда SQL, во-первых, выполняется немедленно. А во-вторых, выполняется вне транзакции (выражение "CREATE DATABASE" должно выполняться именно вне транзакции)
 
После этого на сервере мы сможем найти базу данных "metanit"
 
 
 
Создание таблицы
 
Для создания таблицы в PostgreSQL применяется инструкция CREATE TABLE . Например, в вышесозданной базе данных "metanit" создадим таблицу people:
 
import psycopg2 conn = psycopg2.connect(dbname="metanit", user="postgres", password="123456", host="127.0.0.1") cursor = conn.cursor() # создаем таблицу people cursor.execute("CREATE TABLE people (id SERIAL PRIMARY KEY, name VARCHAR(50), age INTEGER)") # поддверждаем транзакцию conn.commit() print("Таблица people успешно создана") cursor.close() conn.close()
 
В метод cursor.execute() передается инструкция CREATE TABLE , которая создает таблицу people с тремя столбцами. Столбец id представляет идентификатор пользователя, хранит данные типа Serial, то есть число, которое будет автоматически генерироваться и инкрементироваться с каждой новой строкой и которое представляет первичный ключ. Второй столбец - name представляет строку - имя пользователя. И третий столбец - age представляет возраст пользователя.
 
После выполнения скрипта мы можем открыть базу данных и увидеть созданную таблицу
 
Источник
 
Create A Database In PostgreSQL Using Psycopg And Python
 
Creating a PostgreSQL database using Python and Psycopg2:
 
 
Import the Psycopg2 module inside a Python program. If the import fails use the pip command to install Psycopg2.
 
To install Psycopg2 use the command: pip install psycopg2
 
Create a connection object to the PostgreSQL server by providing the logon credentials and calling the function psycopg2.connect().
 
Through the connection object obtain a cursor object by calling the cursor() method on the connection object.
 
Define a Python string, which contains the SQL command CREATE DATABASE.
 
Pass the Python string containing the SQL statement while calling the execute() method of the database cursor.
 
Calling execute() function with CREATE DATABASE creates a database on the PostgreSQL server.
 
To get the list of databases, enter into the interactive terminal of PostgreSQL, by typing psql from command line. From psql type \list or \l to list all the databases.
 
 
Example:
 
# ----- Example Python program to create a database in PostgreSQL using Psycopg2 -----
 
# import the PostgreSQL client for Python
 
from psycopg2.extensions import ISOLATION_LEVEL_AUTOCOMMIT
 
# Connect to PostgreSQL DBMS
 
con = psycopg2.connect("user=test password='test'");
 
sqlCreateDatabase = "create database "+name_Database+";"
 
# Create a table in PostgreSQL database
 
Output:
 
Name | Owner | Encoding | Collate | Ctype | Access privileges
 
postgres | postgres | UTF8 | en_US.UTF-8 | en_US.UTF-8 |
 
ims | test | UTF8 | en_US.UTF-8 | en_US.UTF-8 |
 
socialmedia | test | UTF8 | en_US.UTF-8 | en_US.UTF-8 |
 
template0 | postgres | UTF8 | en_US.UTF-8 | en_US.UTF-8 | =c/postgres +
 
template1 | postgres | UTF8 | en_US.UTF-8 | en_US.UTF-8 | =c/postgres +
 
test | test | UTF8 | en_US.UTF-8 | en_US.UTF-8 | =Tc/test +
 
Источник