SrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSK J r SSK r Sr S r S rS rS rS rSrSrSrSrg)zAFunctions for parsing SQL query parameters from the command line.)absolute_import)division)unicode_literalsN) exceptions)filesc @[R"U5n[R"U5nUVs/sH0n[R "[ UR555PM2 nn[R"U5sSSS5 $s snf!,(df  g=f)zIReads a JSON file specified by path and returns its contents as a string.N) r FileReaderjsonload collections OrderedDictsorteditemsdumps)pathparameters_file parametersparamresultss ;lib/googlecloudsdk/api_lib/dataflow/sql_query_parameters.pyParseParametersFilersz ?+JEODN5 u{{} 56J  ::g  sB7B )B B Bcx/nUHnUR[U55 M [R"U5$)zParses a list of parameters. Arguments: parameters: A list of parameter strings with the format name:type:value, for example min_word_count:INT64:250. Returns: A JSON string containing the parameters. )append_ParseParameterr r)rr parameters rParseParametersListr's3 'i NN?9-. G ctURSS5n[U5S:wa[R"S5eU$)N:zQuery parameters must be of the form: "name:type:value", ":type:value", or "name::value". An empty name produces a positional parameter. An empty type produces a STRING parameter.)splitlenrError) param_stringr"s r _SplitParamr&7s>   S! $%Z1_    5 66 ,rc[U5up[U5up#[R"5nU(aXS'X$S'X4S'U$)Nname parameterTypeparameterValue)r&_ParseParameterTypeAndValuer r )r%r( type_dict value_dictresults rrrBsJ"<0$5lC)  " " $& 6N%'  -rc^[U5upU(dSn[U5nU[X254$)zCParse a string of the form : into each part.STRING)r&_ParseParameterType_ParseParameterValue)r% type_string value_stringr,s rr+r+Ms2),7+ K!+.) (A AArcSUR50nUR5RS5(a<URS5(a&[R"S[ USS54S/5nURS5(a<URS5(a&[R"S [ US S54S /5nU(d[R"S 5eU$) zGParse a parameter type string into a JSON dict for the DF SQL launcher.typezARRAY<> arrayType)r6ARRAYzSTRUCT< structTypes)r6STRUCTzQuery parameter missing type) upper startswithendswithr r r1_ParseStructTyperr$)r3r,s rr1r1Vs{((*+)##H--+2F2Fs2K2K'' )+a*;<=?P)II&&;+?+?+D+D''-*:;q;L*M*O);)=>I    9 :: rc/n[U5H;up#[R"SU4S[U54/5nUR U5 M= U$)z9Parse a Struct QueryParameter type into a JSON dict form.r(r6)_StructTypeSplitr r r1r)r3subtypesr(sub_typeentrys rrBrBfsV ((5nd  # #fd^&,.A(.K%L%N OE OOE6 /rc## U(aURSS5SnSU;auSnSn[URS5[U55H%nXS:XaUS- nXS:XaUS-nUS:XdM% O US:wa[R "S5eUSUS-nU[U5S-SnURSS5n[U5S:wa[R "S 5eUv U(aMgg7f) zCYields single field-name, sub-types tuple from a StructType string.,r rS  + >S  + !   <  9::fq1u%ic)nq012K __T1 %F 6{a   F GG L'  sA,C12A;C1/C1cd[U[5$![a [U[5s$f=f)N) isinstanceunicode NameErrorstr)vals r _IsStringrWs0 c7 ##  c3  s //cSU;a[U5(a US:XaSS0$[R"U5n[R"[ UR 555n[R"USVs/sH o"SUS4PM sn5n[R"5n[R"U5HupV[X5U5XE'M SU0$SU;aS[U5(a US:XaSS0$[R"U5nUVs/sHn[USU5PM nnSU0$S US:waU0$S0$s snfs snf) aWParse a parameter value of type `type_dict` from value_input. Arguments: type_dict: The JSON-dict type as which to parse `value_input`. value_input: Either a string representing the value, or a JSON dict for array and value types. Returns: A dict with one of value, arrayValues, or structValues populated depending on the type. r<NULL structValuesNr(r6r8 arrayValuesvalue) rWr loadsr r rrsix iteritemsr2)r, value_inputxtype_mapvalues field_namer\s rr2r2s_i  %%JJ{+k))&1B1B1D*EFK&&(1-(@((@16AfI(@(H $ $ &F"}}[9/0DeLf : F ##I  t$$JJ{+kALALAY{3Q7  6 "" +"7; BBT BB!(s ;EE)__doc__ __future__rrrr r googlecloudsdk.api_lib.dataflowrgooglecloudsdk.core.utilrr^rrr&rr+r1rBrDrWr2rrrjsWH&' 6*   B  0 #Cr