def optimize_question(self, sql_ddl, sql_desc, question):logger.info(f"优化用户问题: {question}")system_prompt = f"""以下DDL为{sql_desc} 表, DDL：{sql_ddl} 。请你根据以上信息对用户的问题进行优化，使问题更加明确。请记住，你只需要输出优化后的问题，不要输出其它额外的内容。
EXAMPLES
INPUT:统计最常见的五个用户常用词OUTPUT:IOS输入法中，该用户最常用的五个常用词是什么？INPUT:统计搜索次数最多的前两个搜索内容OUTPUT:用户在Safari浏览器中搜索次数最多的前两个搜索内容是什么？"""user_prompt = f"INPUT:n{question}nOUTPUT:"message_log = [self.vn.system_message(system_prompt),self.vn.user_message(user_prompt)]llm_response = self.vn.submit_prompt(message_log)return llm_response

def json_correct(self, input_text):logger.info(f"纠正json: {input_text}")system_prompt = "你非常善于对一段格式有误的 JSON 进行修改。请你对用户提供的格式有误的JSON进行修正，你需要把它严格按照 JSON 标准进行改正为可以直接进行解析的代码，并重新输出。nn请记住：回答时不要做任何解释，只回答以 [ 开头的 JSON。"user_prompt = f"输入：{input_text}"message_log = [self.vn.system_message(system_prompt),self.vn.user_message(user_prompt)]llm_response = self.vn.submit_prompt(message_log)question_sqls = re.findall(r"```jsonn(.*)```", llm_response, re.DOTALL)if question_sqls:llm_response = question_sqls[-1]
return llm_response
def pre_generate_question_sql_pair(self):n_questions = 5files = get_dir_files_path(self.data_dir, '.csv')for file in files:table_name = self.file_table_map[file]ddl = self.vn.run_sql(f"SELECT sql FROM sqlite_master WHERE name = '{table_name}' AND sql IS NOT NULL;") sql_ddl = ddl["sql"].to_list()[0]match = re.search(r'--(.+)', sql_ddl, re.MULTILINE)sql_desc = match.group(1).strip()# print(sql_ddl)# print(sql_desc)df = pd.read_csv(file).head()# print(df.to_markdown())
message_log = [self.vn.system_message(f"你是一个SQLite专家。"),self.vn.user_message(f"根据用户提供的SQLite表信息和数据样例，生成 {n_questions} 个 Question-SQL 对。nn" +f"表描述：{sql_desc} 表，SQLite建表语句：{sql_ddl}nn 数据样例：{df.to_markdown()}nn" +"""必须以JSON格式回答。格式如下：	```json	[{"Question": "生成的第一个问题", "SQL": "第一个问题对应的SQL语句"}{"Question": "生成的第二个问题", "SQL": "第二个问题对应的SQL语句"}	]	```回答时不要做任何解释，只回答JSON。请记住，生成的问题必须明确，生成的SQL必须是SELECT语句，必须要符号SQLite的语法规范，尽量不要生成 `SELECT *`开头的SQL语句。不要试图生成错误的SQL和JSON，否则会造成严重的BUG。""")]llm_response = self.vn.submit_prompt(message_log)try:question_sqls = re.findall(r"```jsonn(.*)```", llm_response, re.DOTALL)if question_sqls:question_sql_json = json.loads(question_sqls[-1])except Exception as e:try:logger.warning(f"生成JSON 失败，即将纠正: {e}")correct_json = self.json_correct(llm_response)print(correct_json)print('----'*20)question_sql_json = json.loads(correct_json)logger.info("纠正JSON成功...")except Exception as e1:logger.warning(f"纠正JSON失败: {e}")continuefor question_sql in question_sql_json:question = question_sql["Question"]sql = question_sql["SQL"]sql_status = self.val_sql(sql)if sql_status:optimized_question = self.optimize_question(sql_ddl, sql_desc, question)logger.info(f"优化后的Question: {optimized_question}")else:logger.info(f"SQL：{sql} 无效...")continuemeta = {"Question": optimized_question,"SQL": sql}with jsonlines.open(self.pre_general_question_sql_path, 'a') as f:f.write(meta)

实验的目的是什么？论文的研究背景是什么？...

def pre_generate_question(self):n_questions = 5files = get_dir_files_path(self.data_dir, '.csv')for file in files:table_name = self.file_table_map[file]ddl = self.vn.run_sql(f"SELECT sql FROM sqlite_master WHERE name = '{table_name}' AND sql IS NOT NULL;") sql_ddl = ddl["sql"].to_list()[0]match = re.search(r'--(.+)', sql_ddl, re.MULTILINE)sql_desc = match.group(1).strip()df = pd.read_csv(file).head()
message_log = [self.vn.system_message(f"You are a helpful data assistant."),self.vn.user_message(f"""SQLite中：{sql_desc} 表的建表语句：nn{sql_ddl} nn以及该表的一部分数据：{df.to_markdown()}请你根据以上数据，生成 {n_questions} 个问题，每行一个，生成的问题必须能够通过以上数据找到答案，请记住，回答时不要做任何额外的解释，只回答问题。请记住，生成的问题必须能够通过SQL查询语句找到答案，生成的每个问题应该明确主谓宾，不要生成模糊不清的问题，因为模糊的问题对于检索有非常严重的问题。请记住，生成的问题里面，必须包含 {sql_desc} 中的内容，否则，当我有很多表时，我无法明确你的问题的目的。请记住，不要生成和序号相关的问题，因为这一列没有任何作用。""")]
llm_response = self.vn.submit_prompt(message_log)
numbers_removed = re.sub(r"^d+.s*", "", llm_response, flags=re.MULTILINE)generate_questions = numbers_removed.split("n")
logger.info(f"根据SQL数据示例生成的Question: n {generate_questions}")for question in generate_questions:message_log = [self.vn.system_message(f"你是一位资深的SQLite专家，非常擅长将自然语言转换成符合SQLite语法的SQL语句。"),self.vn.user_message(f"""SQLite中：{sql_desc} 表的建表语句：nn{sql_ddl} nn以及该表的一部分数据：{df.to_markdown()}请你根据以上数据，将问题：{question} 转换成对应的SQL语句，以便我后续执行SQL语句。请记住，你的回答只有SQL语句，无需回答额外的解释，否则会产生严重的BUG。""")]llm_response = self.vn.submit_prompt(message_log)sql_statement = self.vn.extract_sql(llm_response)sql_status = self.val_sql(sql_statement)if sql_status:logger.info(f"根据问题: {question} 生成的SQL: {sql_statement}")else:logger.info(f"SQL：{sql_statement} 无效...")continuemeta = {"Question": question,"SQL": sql_statement}with jsonlines.open(self.pre_general_question_sql_path, 'a') as f:f.write(meta)