LpEH1mC2

1def create_database():
2    query = """ATTACH DATABASE database AS database"""
3
4    conn = sqlite3.connect('database.db')
5    c = conn.cursor()
6
7    connectionObject = sqlite3.connect("primedb.db")
8
9    # Obtain a cursor object
10
11    cursorObject = connectionObject.cursor()
12
13    attach = "ATTACH DATABASE ? AS database"
14
15    db = ('database.db',)
16
17    c.execute(attach, db)
18
19
20def create_table():
21
22    query = """CREATE TABLE IF NOT EXISTS preprocessed_file(idfile INTEGER PRIMARY KEY ASC, 
23                      name_file VARCHAR(255) NOT NULL, tw INT(6) NOT NULL)"""
24
25    conn = sqlite3.connect('database.db')
26    c = conn.cursor()
27
28    try:
29        c.execute(query)
30
31    except Error as e:
32        print("""Error occur: %s""" % e)
33
34    finally:
35        if conn:
36            conn.close()
37
38        return True
39
40
41"""INSERT INTO my_table (id, name) values(1, 'test');"""
42
43
44def execute_insert_tuple(nome_file, tw):
45
46    t = (nome_file, tw,)
47    query = """INSERT INTO preprocessed_file ('name_file', 'tw') VALUES (?, ?)"""
48
49    conn = sqlite3.connect('database.db')
50    c = conn.cursor()
51
52    try:
53
54        c.execute(query, t)
55
56        # Save (commit) the changes
57        conn.commit()
58
59    except sqlite3.IntegrityError as e:
60        print("""Error occured: %s""" % e)
61    except Exception as e:
62        print("""Exception: %s, Error: %s""" % (query, str(e)))
63
64    finally:
65        if conn:
66            conn.close()
67
68        return True
69
70
71def execute_select_tuple(nome_file, tw):
72
73    t = (nome_file, tw,)
74    query = """SELECT * FROM preprocessed_file WHERE name_file=? AND tw=?"""
75
76    conn = sqlite3.connect('database.db')
77    c = conn.cursor()
78
79    try:
80
81        c.execute(query, t)
82
83        # Save (commit) the changes
84        conn.commit()
85
86        entry = c.fetchone()
87
88        if entry is not None:
89            return True
90        else:
91            return False
92
93    except sqlite3.Error as e:
94        print("""Database error on query: '%s', Error: %s""" % (query, e))
95    except Exception as e:
96        print("""Exception Query Failed: %s, Error: %s""" % (query, str(e)))
97
98    finally:
99        if conn:
100            conn.close()
101
102
103def execute_delete_tuple(nome_file, tw):
104
105    t = (nome_file, tw,)
106    query = """DELETE FROM preprocessed_file WHERE name_file=? AND tw=?"""
107
108    conn = sqlite3.connect('database.db')
109    c = conn.cursor()
110
111    try:
112
113        c.execute(query, t)
114
115        # Save (commit) the changes
116        conn.commit()
117
118    except sqlite3.Error as e:
119        print("""Error occur: %s""" % e)
120        return False
121    except Exception as e:
122        print("""Exception: %s, Error: %s""" % (query, str(e)))
123        return False
124
125    finally:
126        if conn:
127            conn.close()
128
129        return True