Hướng dẫn postgresql python stored procedure example - Ví dụ về thủ tục được lưu trữ trong python postgresql

Tóm tắt: Trong hướng dẫn này, bạn sẽ tìm hiểu cách gọi các thủ tục được lưu trữ của PostgreSQL từ chương trình Python.: in this tutorial, you will learn how to call PostgreSQL stored procedures from a Python program.

Các bước để gọi một thủ tục được lưu trữ sau PostgreSQL trong Python

Để gọi một thủ tục được lưu trữ sau PostgreSQL trong chương trình Python, bạn làm theo các bước đó:

Đầu tiên, hãy tạo kết nối cơ sở dữ liệu mới đến máy chủ cơ sở dữ liệu PostgreSQL bằng cách gọi hàm ____1010:

conn = psycopg2.connect(dsn)
Code language: Python (python)

Phương thức

cur = conn.cursor()
Code language: Python (python)

cur = conn.cursor()
Code language: Python (python)

Tiếp theo, tạo một con trỏ mới bằng cách gọi phương thức

cur = conn.cursor()
Code language: Python (python)

cur = conn.cursor()
Code language: Python (python)

Sau đó, chuyển tên của quy trình được lưu trữ và các giá trị đầu vào tùy chọn cho phương thức

cur = conn.cursor()



Code language: Python (python)

cur = conn.cursor()
Code language: Python (python)

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

Nếu bạn đã lưu trữ thủ tục không chấp nhận bất kỳ tham số nào, bạn có thể bỏ qua đối số thứ hai như sau:

cur.execute("CALL sp_name);")
Code language: Python (python)

Sau đó, hãy gọi phương thức

cur = conn.cursor()
Code language: Python (python)

conn.commit();
Code language: Python (python)

Cuối cùng, hãy gọi phương thức

cur = conn.cursor()
Code language: Python (python)

cur = conn.cursor()
Code language: Python (python)

cur = conn.cursor()



Code language: Python (python)

cur.close()
conn.close()
Code language: Python (python)

Gọi một ví dụ về thủ tục được lưu trữ

Đầu tiên, hãy tạo quy trình được lưu trữ

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

CREATE OR REPLACE PROCEDURE add_new_part(
	new_part_name varchar,
	new_vendor_name varchar
) 
AS $$
DECLARE
	v_part_id INT;
	v_vendor_id INT;
BEGIN
	-- insert into the parts table
	INSERT INTO parts(part_name) 
	VALUES(new_part_name) 
	RETURNING part_id INTO v_part_id;
	
	-- insert a new vendor
	INSERT INTO vendors(vendor_name)
	VALUES(new_vendor_name)
	RETURNING vendor_id INTO v_vendor_id;
	
	-- insert into vendor_parts
	INSERT INTO vendor_parts(part_id, vendor_id)
	VALUEs(v_part_id,v_vendor_id);
	
END;
$$
LANGUAGE PLPGSQL;
Code language: SQL (Structured Query Language) (sql)

Thứ hai, tạo một tệp mới có tên

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

cur.execute("CALL sp_name(%s, %s);", (val1, val2))



Code language: Python (python)

#!/usr/bin/python
import psycopg2
from config import config


def add_part(part_name, vendor_name):

    conn = None
    try:
        # read database configuration
        params = config()
        # connect to the PostgreSQL database
        conn = psycopg2.connect(**params)
        # create a cursor object for execution
        cur = conn.cursor()

        # call a stored procedure
        cur.execute('CALL add_new_part(%s,%s)', (part_name, vendor_name))

        # commit the transaction
        conn.commit()

        # close the cursor
        cur.close()
    except (Exception, psycopg2.DatabaseError) as error:
        print(error)
    finally:
        if conn is not None:
            conn.close()

if __name__ == '__main__':
    add_part('OLED', 'LG')
Code language: Python (python)

Thực hiện tệp Python

Để thực hiện tệp Python, bạn sử dụng câu lệnh sau:

python stored_proc.py
Code language: CSS (css)

Để xác minh chèn, bạn có thể truy vấn dữ liệu từ bảng

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

cur.execute("CALL sp_name(%s, %s);", (val1, val2))
Code language: Python (python)

SELECT * FROM parts;
SELECT * FROM vendors;
SELECT * FROM vendor_parts;

Trong hướng dẫn này, bạn đã học từng bước làm thế nào để gọi một thủ tục được lưu trữ của PostgreSQL trong Python.

Hướng dẫn này có hữu ích không?