bq 命令行中出现无法识别的名称错误

Question

我想获取表的记录数。我已经写了以下程序。

Create or replace procedure 
procedurename(In tablename string)
Begin
Declare sql1 string
Set sql1= 'select count(*) from ' ||tablename;
Execute immediate sql1;
End;

问题：

1. 当我在 bq 控制台中使用调用 sp 执行它时，它给了我计数。 但是当我在 bq 命令行中使用 bq query --use_legacy_sql=false '调用过程名（表名）' 它给我的错误是“无法识别的名称：表名”。为什么会这样？

谢谢。

Answer 1

回答您的问题：

1. 您收到 Unrecognized name:'tablename' 错误，因为在您的查询中 tablename 未定义。

尝试使用下面的命令来执行你的存储过程

bq query \
--use_legacy_sql=false \
‘DECLARE tablename STRING DEFAULT NULL;
set tablename="your-table-name";
CALL `projectid.datasetid.procedurename`(tablename);’
    

1. 要将表名作为参数传递，您可以尝试使用 documentation 中提到的 bq 命令行或客户端库。

例如在 bq 命令行中：

    bq query \
    --use_legacy_sql=false \
    --parameter=tablename:string:your-table-name \
    'DECLARE tablename STRING ;
    CALL `projectid.datasetid.procedurename`(@tablename);'

评论#1的答案：

• 使用 bq 命令行无法在运行时传递用户输入，但您可以使用客户端库在运行时传递表名。

例如参考这个python脚本：

from google.cloud import bigquery

# Construct a BigQuery client object.
client = bigquery.Client(project="project_id")

mytable1=raw_input("Enter your table: ")

query = """
   DECLARE tablename STRING ;
   CALL `project_id.dataset.procFedurename`(@tablename);

"""
job_config = bigquery.QueryJobConfig(
   query_parameters=[
       bigquery.ScalarQueryParameter("tablename", "STRING", mytable1),
      
   ]
)

job = client.query(query, job_config=job_config)  # Make an API request.

for row in job.result():
   print("No of records:{}".format(row[0]))