Das deutsche Python-Forum

Code: Alles auswählen

import sqlite3

conn=sqlite3.connect('Messergebnisse.sqlite')
curs=conn.cursor()
for row in curs.execute("SELECT * FROM Messergebnisse WHERE Abgeholt='2'"):
    print row 
conn.close()

Code: Alles auswählen

#!/usr/bin/env python
import sqlite3

conn=sqlite3.connect('/var/www/Messergebnisse.sqlite')
curs=conn.cursor()
for row in curs.execute("SELECT * FROM Messergebnisse WHERE Abgeholt='2'"):

	conn=sqlite3.connect('/var/www/Messergebnisse2.sqlite')
	curs=conn.cursor()
	curs.execute("INSERT row INTO Messergebnisse")
	conn.close()
conn.close()

Code: Alles auswählen

#!/usr/bin/env python
import sqlite3
conn=sqlite3.connect('/var/www/Messergebnisse.sqlite')
curs=conn.cursor()
for row in curs.execute("SELECT * FROM Messergebnisse WHERE Abgeholt='0'"):
	conn=sqlite3.connect('/var/www/Messergebnisse2.sqlite')
	curs=conn.cursor()
	curs.execute("INSERT INTO Messergebnisse VALUES (?,?,?,?)", row)
	conn.close()
conn.close()

Code: Alles auswählen

#!/usr/bin/env python
import sqlite3
conn=sqlite3.connect('/var/www/Messergebnisse.sqlite')
curs=conn.cursor()

#Ergebnis aus dem select in ergebnis zwischenspeichern
ergebnis = conn.fetchall()   

#zur Sicherheit die Verbindung schließen, bevor unter dem gleichen Namen nochmals eine Verbindung zu einer anderen Datenbank geöffnet wird
conn.close() 

conn=sqlite3.connect('/var/www/Messergebnisse2.sqlite')
curs=conn.cursor()

#curs.execute() durch curs.executemany() ersetzen, damit man nicht selber über ergebnis iterieren muss
curs.executemany("INSERT INTO Messergebnisse VALUES (?,?,?,?)", ergebnis)

conn.commit()
conn.close()

Code: Alles auswählen

using GLib;

static const string SELECT_STRING =
    "SELECT * FROM Messergebnisse WHERE Abgeholt=:abgeholt;";
static const string INSERT_TEMPLATE =
    "INSERT INTO Messergebnisse (%s) VALUES (%s);";


static inline void print_db_error (string text, Sqlite.Database db)
{
    stderr.printf ("%s: %d: %s\n", text, db.errcode (), db.errmsg ());
}


static inline int create_insert_statement (
    Sqlite.Statement select_statement,
    Sqlite.Database target_db,
    out Sqlite.Statement insert_statement
) {
    var column_count = select_statement.column_count ();
    var column_names = new string[column_count];
    var placeholders = new string[column_count];
    for (int i = 0; i < column_count; i++) {
        column_names[i] = select_statement.column_name (i);
        placeholders[i] = "?";
    }
    var sql = INSERT_TEMPLATE.printf (
        string.joinv (",", column_names), string.joinv (",", placeholders)
    );
    return target_db.prepare_v2 (sql, sql.length, out insert_statement);
}


static inline int copy (
    string source_db_name, string target_db_name, int abgeholt_value
) {

    Sqlite.Database source_db;
    var rc = Sqlite.Database.open_v2 (
        source_db_name, out source_db, Sqlite.OPEN_READONLY
    );
    if (rc != Sqlite.OK) {
        print_db_error ("Can't open source database", source_db);
        return 1;
    }
    Sqlite.Statement select_statement;
    rc = source_db.prepare_v2 (
        SELECT_STRING, SELECT_STRING.length, out select_statement
    );
    if (rc != Sqlite.OK) {
        print_db_error ("Can't prepare select statement", source_db);
        return 1;
    }
    select_statement.bind_int (
        select_statement.bind_parameter_index (":abgeholt"), abgeholt_value
    );

    Sqlite.Database target_db;
    rc = Sqlite.Database.open (target_db_name, out target_db);
    if (rc != Sqlite.OK) {
        print_db_error ("Can't open target database", target_db);
        return 1;
    }

    Sqlite.Statement insert_statement;
    rc = create_insert_statement (
        select_statement, target_db, out insert_statement
    );
    if (rc != Sqlite.OK) {
        print_db_error ("Can't pepare insert statement", target_db);
        return 1;
    }
    var column_count = select_statement.column_count ();
    assert (column_count == insert_statement.bind_parameter_count ());
    while (select_statement.step () == Sqlite.ROW) {
        for (int i = 0; i < column_count; i++) {
            insert_statement.bind_value (
                i + 1, select_statement.column_value (i)
            );
        }
        rc = insert_statement.step ();
        if (rc != Sqlite.DONE) {
            print_db_error("Can't insert data", target_db);
            return 1;
        }
        insert_statement.reset ();
    }

    select_statement.reset ();

    return 0;
}


static int main (string[] args) {
    if (args.length != 4) {
        print ("Usage %s source_db target_db abgeholt_value\n", args[0]);
        return 1;
    } else {
        return copy(args[1], args[2], int.parse(args[3]));
    }
}

Code: Alles auswählen

#!/usr/bin/env python
import sqlite3

#Daten von Datenbank1 auslesen
conn=sqlite3.connect('/var/www/Messergebnisse.sqlite')
curs=conn.cursor()
curs.execute("SELECT * FROM Messergebnisse WHERE Abgeholt=0")
ergebnis = curs.fetchall()	#Ergebnis aus dem select in ergebnis zwischenspeichern
conn.commit()	#Aenderungen festschreiben
curs.execute("DELETE FROM Messergebnisse WHERE Abgeholt=2")
curs.execute("UPDATE Messergebnisse SET Abgeholt=2 WHERE Abgeholt=1")
curs.execute("UPDATE Messergebnisse SET Abgeholt=1 WHERE Abgeholt=0")
conn.commit()	#Aenderungen festschreiben
conn.close()	#Verbindung schliessen
 

#Daten in Datenbank2 eintragen
conn=sqlite3.connect('/var/www/Messergebnisse2.sqlite')
curs=conn.cursor()
curs.executemany("INSERT INTO Messergebnisse VALUES (?,?,?,?)", ergebnis)
conn.commit()
conn.close()