Problem z while w Pythonie

Question

Witam, mam programik, który łączy się z bazą danych, i ma wypisywać po kolei id wszystkich rekordów, ale po każdym go usuwać. Czyli pobiera id pierwszego i go usuwa, itd. Mam kod:

#......
cur = db.cursor();
cura = db.cursor();
cur.execute("SELECT * FROM a")
for row in cur.fetchall():
    a = row[0]
    print a
    cura.execute("DELETE FROM a WHERE id=%s", (a,))
    db.conmit()
   

Wszystko działa, ale chciałem, aby to działało tak  dynamicznie. Czyli wypisuje te co są, ale wciąż czuwa, i na bieżąco jak się doda to wypisze i usunie. Więc dodałem przed tym poprostu while 1==1, oczywiście pamiętając o kolejnych tabulacjach. Ale nie działa. Wypisuje te co jest, a jak się doda to ani nie wypisuje, ani nie usuwa.

Pozdrawiam i z góry dzięki za każde zaangażowanie.

 

 

Answer 1

Chyba tego poszukujesz: 

​​​​​​while True: 
   //kod tutaj 

 

Comments

Zmieniłem, i dorzucam cały kod, ale dalej nie działa:

#-*- coding: utf-8 -*-
import MySQLdb

db = MySQLdb.connect(user='cpp', passwd='cpp', db='cpp', host='127.0.0.1', port=3306)

cur = db.cursor();
cura = db.cursor();
while True:
	cur.execute("SELECT * FROM kolejka")
	for row in cur.fetchall():
		print row[0]
		a = row[0]
		delstatmt = "DELETE FROM `kolejka` WHERE id = %s"
		cura.execute(delstatmt, (a,))
		db.commit()

 

Answer 2

Proponuje dołożyć sleep-a i powinno być OK. No i ten drugi kursor (cura) jest zbędny.

Musisz tylko skorzystać z biblioteki time i funkcji time.sleep()

Nie miałem dostępu do MySql ale zamieszczam minimalnie przerobiony kod z użyciem bazy sqlite.

import sqlite3
import time

conn = sqlite3.connect('cpp.sqlite')
cur = conn.cursor()

cur.executescript('''
CREATE TABLE IF NOT EXISTS kolejka (
    id  INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT UNIQUE,
    name TEXT UNIQUE,
	info TEXT
);
''')

while True:
    cur.execute("SELECT * FROM kolejka")
    for row in cur.fetchall():
        print row[0]
        a = row[0]
        delstatmt = "DELETE FROM `kolejka` WHERE id = ?"
        cur.execute(delstatmt, (a,))	
        conn.commit()
	
    # czekaj 10 sekund
    time.sleep(10)

 

Comments

Pozmieniałem:

import MySQLdb
import time
db = MySQLdb.connect(user='cpp', passwd='cpp', db='cpp',
                             host='127.0.0.1', port=3306)
                   
cur = db.cursor()
while 1==1:
	cur.execute("SELECT * FROM kolejka")
	for row in cur.fetchall():
		a = row[0]
		print a
		cur.execute("DELETE FROM kolejka WHERE id=%s", (a,))
		db.commit()
	print 'a'
	time.sleep(10)
		

I masz filmik, gdzie pokazane, że nie działa: LINK

Dodałem wypisanie a aby wiedzieć, czy wogóle się ta pętla wykonuje.

---

Przenieś tworzenie kursora do wewnątrz pętli while (cur = db.cursor()).

Dla porządku na samym końcu (poza pętlą while) wypadało by się rozłączyć z bazą:

if db:
    db.close()

Tym razem powinno już działać.

---

Podmieniłem:

import MySQLdb
import time
db = MySQLdb.connect(user='cpp', passwd='cpp', db='cpp',
                             host='127.0.0.1', port=3306)
                    
while (cur = db.cursor()):
    cur.execute("SELECT * FROM kolejka")
    for row in cur.fetchall():
        a = row[0]
        print a
        cur.execute("DELETE FROM kolejka WHERE id=%s", (a,))
        db.commit()
    print 'a'
    time.sleep(10)
if db:
		db.close()
    

Wyskakuje błąd:

  File "z.py", line 6
    while (cur = db.cursor()):
               ^
SyntaxError: invalid syntax

 

 

---

Chodziło mi tylko o przeniesienie tej linii do wnętrza pętli:

import MySQLdb
import time

db = MySQLdb.connect(user='cpp', passwd='cpp', db='cpp',
                             host='127.0.0.1', port=3306)
                    
while 1==1:
    cur = db.cursor()
    cur.execute("SELECT * FROM kolejka")
    for row in cur.fetchall():
        a = row[0]
        print a
        cur.execute("DELETE FROM kolejka WHERE id=%s", (a,))
        db.commit()
    print 'a'
    time.sleep(10)

if db:
    db.close()