1 files changed, 16 insertions, 0 deletions
diff --git a/functions/sql_functions.py b/functions/sql_functions.py
new file mode 100644
index 0000000..5cc2ae9
--- /dev/null
+++ b/functions/sql_functions.py
@@ -0,0 +1,16 @@
+import sqlite3 as sql
+import pandas as pd
+
+
+def execute_sql_statement(sql_statement):
+    conn = sql.connect("database.db")
+    cur = conn.cursor()
+    cur.execute(sql_statement)
+    rows = cur.fetchall()
+    return rows
+
+
+def run_sql_pandas(sql_statement):
+    conn = sql.connect("database.db")
+    df = pd.read_sql_query(sql_statement, conn).to_records(index=False)
+    return df