sqlite.py 1.24 KB
Newer Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
#!/usr/bin/python3
import sqlite3
import yaml

#Einlesen der User aus der yaml-Datei users
with open('users.yaml') as yaml_file:
    users = yaml.load(yaml_file)

#Aufbauen einer Verbindung zur Datenbank test
connection = sqlite3.connect("test.db")
cursor = connection.cursor()

#Löscht Tabelle Benutzer, wenn sie exisitert
drop_benutzer = "DROP TABLE IF EXISTS benutzer; "
cursor.execute(drop_benutzer)

#Erstellt Tabelle Benutzer
create_benutzer = """
CREATE TABLE benutzer (
user_id INTEGER PRIMARY KEY,
vname VARCHAR(20),
nname VARCHAR(20),
username VARCHAR(20),
joining DATE,
aktiv VCHAR(4)
);"""
cursor.execute(create_benutzer)

#Methode, um User-Datensätze in die Tabelle einzutragen
def insert(user_id, vname, nname, username, joining, aktiv):               
    cursor.execute("INSERT INTO benutzer(user_id, vname, nname, username, joining, aktiv) VALUES (:user_id, :vname, :nname, :username, :joining, :aktiv)" , {'user_id' : user_id, 'vname' : vname, 'nname' : nname, 'username' : username, 'joining' :joining, 'aktiv' : aktiv})

#Eintragen der vorhandenen user (aus der Yaml-Datei) in die Tabelle
for p in users:
    insert(p['user_id'], p['vname'], p['nname'], p['username'], p['joining'], p['aktiv'])

connection.commit()
connection.close()