24 lines
609 B
Plaintext
24 lines
609 B
Plaintext
debug(params_kw)
|
|
ns = params_kw.copy()
|
|
orgid = await get_userorgid()
|
|
debug(f'orgid={orgid}')
|
|
|
|
db = DBPools()
|
|
sql = f"""select {params_kw.tblvalue} as {params_kw.valueField},
|
|
{params_kw.tbltext} as {params_kw.textField}
|
|
from {params_kw.table} where 1=1 """
|
|
|
|
if orgid:
|
|
sql += " and orgid = ${orgid}$ "
|
|
ns['orgid'] = orgid
|
|
|
|
if params_kw.get('cond'):
|
|
sql += f" and {params_kw.cond} "
|
|
|
|
sql += f"order by {params_kw.textField}"
|
|
|
|
debug(f'/rag/kdb/get_user_kdb.dspy: {sql=}, ns={ns}')
|
|
|
|
async with db.sqlorContext(params_kw.dbname) as sor:
|
|
rs = await sor.sqlExe(sql, ns)
|
|
return rs if rs else [] |