-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathsql.py
More file actions
66 lines (54 loc) · 1.9 KB
/
sql.py
File metadata and controls
66 lines (54 loc) · 1.9 KB
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
from dotenv import load_dotenv
load_dotenv()
import streamlit as st
import os
import sqlite3
from google import genai
# Configure the new Client
client = genai.Client(api_key=os.getenv("GEMINI_API_KEY"))
## Function to load gemini model
def get_gemini_response(question, prompt):
response = client.models.generate_content(
model='gemini-2.5-flash',
contents=[prompt[0], question]
)
return response.text
## Function to retrieve query from the database
def read_sql_query(sql, db):
conn = sqlite3.connect(db)
cur = conn.cursor()
try:
cur.execute(sql)
rows = cur.fetchall()
conn.close()
return rows
except sqlite3.Error as e:
st.error(f"An error occurred with the SQL query: {e}")
return []
## Define your prompt
prompt = [
"""
You are an expert in converting English text into SQL queries!
The SQL database has the name STUDENT and has the following columns: NAME, CLASS, SECTION.
For example:
Example 1: How many students are studying in Data Science class?
The SQL command will be: SELECT COUNT(*) FROM STUDENT WHERE CLASS="Data Science";
Example 2: Tell me all the students studying in Data Science class?
The SQL command will be: SELECT * FROM STUDENT WHERE CLASS="Data Science";
also the sql code should not have ``` in the beginning or end of the output and no word 'sql' in the output.
"""
]
## Streamlit app
st.set_page_config(page_title="I can retrieve any SQL query")
st.header("Gemini App to Retrieve SQL Data")
question = st.text_input("Input:", key="input")
submit = st.button("Ask the question")
if submit:
response = get_gemini_response(question, prompt)
print("first" ,response)
response = read_sql_query(response, "student.db")
print("second", response)
st.subheader("The response is")
for row in response:
print(row)
st.dataframe(row)