使用Pyodbc连接SQL Server的Streamlit应用：非ID字段模糊查询无结果的问题排查

我开发了一个使用Pyodbc连接SQL Server数据库的Streamlit应用，尝试通过包含通配符的SELECT语句根据用户输入查询数据。但遇到的问题是：当用户查询ID以外的字段时，无法返回任何数据。

数据库表结构如下：

CREATE TABLE [dbo].[t1]( 
    [ID] [int] IDENTITY(1,1) NOT NULL, 
    [first] [nvarchar](50) NULL, 
    [last] [nchar](50) NULL, 
    [Rating] [int] NULL, 
    CONSTRAINT [PK_t1] PRIMARY KEY CLUSTERED ( [ID] ASC )
) ON [PRIMARY]

Python代码如下：

import pandas as pd
import streamlit as st
advanced_search_term_list = []
if len(advanced_search_term_list)>0:
    sql="select * from testDB.dbo.t1 where (ID = ? OR ID is null) and (first LIKE ? OR first is null) and (last LIKE ? or last is null) and (Rating = ? or Rating is null) "
    param0=advanced_search_term_list[0]
    param1=f'%{advanced_search_term_list[1]}%'
    param2=f'%{advanced_search_term_list[2]}%'
    param3=advanced_search_term_list[3]
    rows = cursor.execute(sql,param0,param1,param2,param3).fetchall()

目前仅param0（对应ID参数）能返回数据，请问我的代码中存在什么错误？

你的代码存在几个关键问题，导致非ID字段查询无结果： #

1. ID字段的条件逻辑错误
   从表结构可以看到，ID是IDENTITY(1,1) NOT NULL，意味着这个字段永远不会为null，所以OR ID is null部分完全是多余的。更严重的是：当用户没有输入ID时，param0是空值（比如空字符串），而ID是int类型，空字符串和int类型的ID匹配会直接失败，再加上WHERE条件是所有子句用AND连接，这就导致整个WHERE条件不成立，自然返回空结果。

2. 固定WHERE条件的逻辑缺陷
   你写死了所有字段的查询条件，并用AND连接——这意味着即使用户只输入了first的查询词，也必须同时满足ID、last、Rating的条件。比如用户没有输入ID，那ID的条件(ID = ? OR ID is null)会因为ID不可能为null，且ID = 空值不匹配任何数据，导致整个查询无结果。

3. nchar字段的潜在匹配问题
   last字段是nchar(50)，这是固定长度的字符串类型，存储时会用空格填充到50位。如果直接用last LIKE ?，当用户输入的查询词没有包含这些尾空格时，可能会出现匹配不上的情况（虽然SQL Server的LIKE会自动补空格比较，但用RTRIM处理会更稳妥）。

解决方案：动态构建SQL查询条件 #

正确的做法是只添加用户有输入的字段条件，而不是固定写死所有字段的条件。这样可以避免无输入字段的条件干扰查询结果，同时让逻辑更灵活。

修改后的代码示例：

import pandas as pd
import streamlit as st
import pyodbc

# 1. 建立数据库连接（你的代码里可能漏掉了这部分，需要补充）
conn = pyodbc.connect(
    "DRIVER={SQL Server};SERVER=你的服务器地址;DATABASE=testDB;UID=用户名;PWD=密码"
)
cursor = conn.cursor()

# 2. 获取用户输入（用Streamlit控件示例，你可以替换成你的输入逻辑）
id_input = st.text_input("请输入ID（整数）")
first_input = st.text_input("请输入first字段关键词")
last_input = st.text_input("请输入last字段关键词")
rating_input = st.text_input("请输入Rating（整数）")

# 3. 动态构建查询条件和参数
conditions = []
params = []

# 处理ID条件：仅当输入有效整数时添加
if id_input.strip():
    try:
        id_val = int(id_input)
        conditions.append("ID = ?")
        params.append(id_val)
    except ValueError:
        st.error("ID必须是整数类型，请重新输入")

# 处理first字段：有输入才添加LIKE条件
if first_input.strip():
    conditions.append("first LIKE ?")
    params.append(f'%{first_input.strip()}%')

# 处理last字段：用RTRIM去掉尾空格，避免nchar固定长度的匹配问题
if last_input.strip():
    conditions.append("RTRIM(last) LIKE ?")
    params.append(f'%{last_input.strip()}%')

# 处理Rating条件：仅当输入有效整数时添加
if rating_input.strip():
    try:
        rating_val = int(rating_input)
        conditions.append("Rating = ?")
        params.append(rating_val)
    except ValueError:
        st.error("Rating必须是整数类型，请重新输入")

# 4. 构建完整SQL语句
sql = "SELECT * FROM testDB.dbo.t1"
if conditions:
    sql += " WHERE " + " AND ".join(conditions)

# 5. 执行查询并显示结果
try:
    rows = cursor.execute(sql, params).fetchall()
    # 转换为DataFrame方便Streamlit显示
    if rows:
        df = pd.DataFrame.from_records(rows, columns=[col[0] for col in cursor.description])
        st.dataframe(df)
    else:
        st.info("没有匹配到数据")
except Exception as e:
    st.error(f"查询出错：{str(e)}")
finally:
    # 关闭游标和连接
    cursor.close()
    conn.close()

关键改进点说明： #

• 动态条件：只有用户输入了内容的字段才会被加入WHERE条件，避免无输入字段的无效条件干扰查询。
• 类型校验：对ID和Rating做了整数转换校验，避免因输入非数字导致的SQL错误。
• nchar字段处理：用RTRIM(last)去掉存储时的尾空格，确保用户输入的关键词能正确匹配。
• 健壮性：增加了异常捕获，方便排查查询过程中的错误。

内容的提问来源于stack exchange，提问作者DevLeb2022