How to take PostgreSQL table's data constantly using Python?

Question

How to take PostgreSQL table's data constantly using Python? (For example, every 1 minute, it needs to take the next row's data) Could you please help me with that?

import psycopg2

#establishing the connection
conn = psycopg2.connect(
   database="mydb", user='postgres', password='password', host='127.0.0.1', port= '5432'
)

#Setting auto commit false
conn.autocommit = True

#Creating a cursor object using the cursor() method
cursor = conn.cursor()

#Retrieving data
cursor.execute('''SELECT * from EMPLOYEE''')

#Fetching 1st row from the table
result = cursor.fetchone();
print(result)

#Fetching 1st row from the table
result = cursor.fetchall();
print(result)

#Commit your changes in the database
conn.commit()

#Closing the connection
conn.close()

Yes, I found a way. It's now taking data constantly from database. I have another issue now. Could you please help me with it ? — Shakh
– Shakh, Commented Nov 4, 2022 at 5:54
In database table, Second and third columns have numbers. *Suppose 105 is selected from the second column and 115 is selected from the third column: *When the new row's number received in the .sql table drops below 105, the python should print a Notification message. "Warning! The number has dropped below 105.". On the other hand, whenever the number reveived from the third column is higher than 115, it needs to print "The number is higher than 115". Otherwise, python doesn't needs to give a message. I hope you got it. — Shakh
– Shakh, Commented Nov 4, 2022 at 5:54
Each time, whenever new rows added in database table, python needs to check them constantly. — Shakh
– Shakh, Commented Nov 4, 2022 at 5:54

Shakh · Accepted Answer · 2022-11-04 06:05:44Z

1

You can use while loop and timer to execute your code as shown below.

import psycopg2
import time


#establishing the connection
conn = psycopg2.connect(
   database="mydb", user='postgres', password='password', host='127.0.0.1', port= '5432'
)

#Setting auto commit false
conn.autocommit = True

#Creating a cursor object using the cursor() method
cursor = conn.cursor()


def fetch_data(): 

    
    #Retrieving data
    cursor.execute('''SELECT * from EMPLOYEE''')
    
    #Fetching 1st row from the table
    result = cursor.fetchone();
    print(result)
    
    #Fetching 1st row from the table
    result = cursor.fetchall();
    print(result)
    
    #Commit your changes in the database
    conn.commit()
    

while True:
    fetch_data()
    print("Fetching data every one minute")
    time.sleep(1*60) # every sixty sec

edited Nov 4, 2022 at 6:05

Shakh

316 bronze badges

answered Nov 4, 2022 at 5:11

shining

1,06916 silver badges31 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Shakh Over a year ago

Bro, could you please add on your code this stuffs. Second and third columns have numbers. *Suppose 105 is selected from the second column and 115 is selected from the third column: *When the new row's number received in the .sql table drops below 105, the python should print a Notification message. "Warning! The number has dropped below 105.". On the other hand, whenever the number reveived from the third column is higher than 115, it needs to print "The number is higher than 115". Otherwise, python doesn't needs to give a message. I hope you got it.

Collectives™ on Stack Overflow

How to take PostgreSQL table's data constantly using Python?

1 Answer 1

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related