主页 / 问题 / 1431759
Accepted
Nommad
Asked:2022-07-21 19:14:08 +0800 CST2022-07-21 19:14:08 +0800 CST

功能、选项和 psycopg2

  • 772

函数和参数我搞不清楚（请告诉我，不要扔拖鞋

def get_connect_to_database():
    try:
        connect = psycopg2.connect(dbname = name_of_database, user = user, password = password, host= host)
        print('\n', Fore.GREEN+'================= CONNECTION OK =================')
        print(Fore.RESET)
        cur = connect.cursor()
        time_start = time.time()
    except Exception as _ex:
        print(Fore.RED + '[-Error-]CONNECTION NOT OK', _ex)


def get_query_from_database():
    try:
        get_data_from_first_table = """
            SELECT id,pas_id, date_add, status_id
            FROM status_history 
            where status_id !=7
            and date_add>= now()- interval '10 day'
            order by date_add desc limit 50"""
        cur.execute(get_data_from_first_table)
        data_frame_from_first_table = cur.fetchall()
        print(get_data_from_first_table)
    except Exception as _ex:
        print(Fore.RED + "[-Error-] ERROR WITH QUERY")

如何将cur正确的功能添加到def get_query_from_database(). 他不活跃

python функции

1 个回答

  1. Best Answer

    有几种选择：

    1. 传入参数：
    def get_connect_to_database():
    try:
        connect = psycopg2.connect(dbname = name_of_database, user = user, password = password, host= host)
        print('\n', Fore.GREEN+'================= CONNECTION OK =================')
        print(Fore.RESET)
        cur = connect.cursor()
        time_start = time.time()
        return cur # <---
    except Exception as _ex:
        print(Fore.RED + '[-Error-]CONNECTION NOT OK', _ex)

def get_query_from_database(cur): # <---
    try:
        get_data_from_first_table = """
            SELECT id,pas_id, date_add, status_id
            FROM status_history 
            where status_id !=7
            and date_add>= now()- interval '10 day'
            order by date_add desc limit 50"""
        cur.execute(get_data_from_first_table)
        data_frame_from_first_table = cur.fetchall()
        print(get_data_from_first_table)
    except Exception as _ex:
        print(Fore.RED + "[-Error-] ERROR WITH QUERY")

cur = get_connect_to_database() # <---
if cur: # <---
    get_query_from_database(cur) # <---
    1. 使变量全局：
    cur = None # <---

def get_connect_to_database():
    global cur # <---
    try:
        connect = psycopg2.connect(dbname = name_of_database, user = user, password = password, host= host)
        print('\n', Fore.GREEN+'================= CONNECTION OK =================')
        print(Fore.RESET)
        cur = connect.cursor()
        time_start = time.time()
    except Exception as _ex:
        print(Fore.RED + '[-Error-]CONNECTION NOT OK', _ex)


def get_query_from_database():
    global cur # <---
    try:
        get_data_from_first_table = """
            SELECT id,pas_id, date_add, status_id
            FROM status_history 
            where status_id !=7
            and date_add>= now()- interval '10 day'
            order by date_add desc limit 50"""
        cur.execute(get_data_from_first_table)
        data_frame_from_first_table = cur.fetchall()
        print(get_data_from_first_table)
    except Exception as _ex:
        print(Fore.RED + "[-Error-] ERROR WITH QUERY")
    • 2

相关问题