QZkpuWme

1sql_create_titanic_table = """ CREATE TABLE IF NOT EXISTS titanic (
2                                        name text NOT NULL,
3                                        age smallint NOT NULL,
4                                        sex text NOT NULL,
5                                        survived text NOT NULL
6                                    ); """
7
8
9import pandas as pd
10import sqlite3
11
12# create table
13try:
14    conn = sqlite3.connect('pythonsql/kampus.db')
15    print("sukses masuk")
16    
17    cursor = conn.cursor()
18    
19#     create table
20    cursor.execute(sql_create_titanic_table)
21 
22    
23        
24    conn.commit()
25    conn.close()
26except:
27    print("error konek ke database")
28    
29# ingest data from dataframe to sql
30try:
31    conn = sqlite3.connect('pythonsql/kampus.db')
32    print("sukses masuk")
33    
34#     ingest
35    df.to_sql("titanic", conn, if_exists="replace")
36    
37    conn.close()
38    
39except:
40    print("error konek database")