Hướng dẫn call postgresql function from python - gọi hàm postgresql từ python

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

Gọi chức năng PostgreSQL trong các bước Python

Để gọi chức năng PostgreSQL từ chương trình Python, bạn sử dụng các bước sau:

Đầ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 connect() của mô -đun ____10.

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

Phương thức connect() trả về một thể hiện mới của lớp

cur = conn.cursor()
Code language: SQL (Structured Query Language) (sql)

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: SQL (Structured Query Language) (sql)

cur = conn.cursor()
Code language: SQL (Structured Query Language) (sql)

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

cur = conn.cursor()



Code language: SQL (Structured Query Language) (sql)

cur.callproc('function_name', (value1,value2))
Code language: SQL (Structured Query Language) (sql)

Trong nội bộ, phương thức & nbsp; ________ 14 dịch các giá trị gọi và đầu vào chức năng thành câu lệnh sau:

SELECT * FROM function_name(value1,value2);
Code language: Python (python)

Do đó, bạn có thể sử dụng phương thức

cur = conn.cursor()
Code language: SQL (Structured Query Language) (sql)

cur.execute("SELECT * FROM function_name( %s,%s); ",(value1,value2))
Code language: Python (python)

Cả hai tuyên bố đều có cùng một hiệu ứng.

Sau đó, xử lý bộ kết quả được trả về bởi hàm bằng phương pháp

cur = conn.cursor()
Code language: SQL (Structured Query Language) (sql)

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

cur.callproc('function_name', (value1,value2))
Code language: SQL (Structured Query Language) (sql)

cur.callproc('function_name', (value1,value2))
Code language: SQL (Structured Query Language) (sql)

cur = conn.cursor()
Code language: SQL (Structured Query Language) (sql)

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

Gọi một ví dụ về chức năng

Hàm

cur.callproc('function_name', (value1,value2))
Code language: SQL (Structured Query Language) (sql)

CREATE OR REPLACE FUNCTION get_parts_by_vendor(id integer)
  RETURNS TABLE(part_id INTEGER, part_name VARCHAR) AS
$$
BEGIN
 RETURN QUERY

 SELECT parts.part_id, parts.part_name
 FROM parts
 INNER JOIN vendor_parts on vendor_parts.part_id = parts.part_id
 WHERE vendor_id = id;

END; $$

LANGUAGE plpgsql;
Code language: SQL (Structured Query Language) (sql)

Hàm

cur.callproc('function_name', (value1,value2))
Code language: SQL (Structured Query Language) (sql)

cur.callproc('function_name', (value1,value2))



Code language: SQL (Structured Query Language) (sql)

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


def get_parts(vendor_id):
    """ get parts provided by a vendor specified by the vendor_id """
    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()
        # another way to call a function
        # cur.execute("SELECT * FROM get_parts_by_vendor( %s); ",(vendor_id,))
        cur.callproc('get_parts_by_vendor', (vendor_id,))
        # process the result set
        row = cur.fetchone()
        while row is not None:
            print(row)
            row = cur.fetchone()
        # close the communication with the PostgreSQL database server
        cur.close()
    except (Exception, psycopg2.DatabaseError) as error:
        print(error)
    finally:
        if conn is not None:
            conn.close()
Code language: Python (python)

Các cuộc gọi sau đây gọi chức năng

cur.callproc('function_name', (value1,value2))
Code language: SQL (Structured Query Language) (sql)

if __name__ == '__main__':
    get_parts(1)
Code language: Python (python)

Trong hướng dẫn này, bạn đã học từng bước cách gọi chức năng PostgreSQL trong Python.

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