SrSSKJr SSKJr SSKJr SSKrSSKrSSKrSSKJ r SSK J r SSK J r SS KJr "S S 5rS rg) zBProvides split file preprocessing for adding splits to a database.)absolute_import)division)unicode_literalsN) extra_types)apis) exceptions)filesc6\rSrSrSrSrSrSrSrSr Sr g ) SplitFileParsera+Parses a split file into a list of split points. The split file is expected to be in the format of: [space][space]() [space][space]() ... where ObjectType can be TABLE or INDEX. Each split point must be in a new line. Split value is expected to be a comma separated list of key parts. Split values should be surrounded by parenthesis like () String values should be supplied in single quotes:'splitKeyPart' Boolean values should be one of: true/false INT64 and NUMERIC spanner datatype values should be supplied within single quotes values like string format: '123', '999999999999999999999999999.99' Other number values should be supplied without quotes: 1.287 Timestamp values should be provided in the following format in single quote values: '2020-06-18T17:24:53Z' If the split value needs to have a comma, then that should be escaped by backslash. Examples: TABLE Singers ('c32ca57a-786c-2268-09d4-95182a9930be') INDEX Order (4.2) TABLE TableD (0,'7ef9db22-d0e5-6041-8937-4bc6a7ef9db2') INDEX IndexXYZ ('8762203435012030000',NULL,NULL) INDEX IndexABC (0, '2020-06-18T17:24:53Z') TableKey (123,'ab\,c') -- note that the above split value has a delimieter (comma) in it, hence escaped by a backslash. c*XlX l[R"S5Ul[R"S5Ul[R"S5Ul[R"S5Ul[R"S5Ulg)Nz(\S+)\s+(\S+)\s+(.+)z"\((.*?)\) TABLE (\S+)\s+\((.*?)\)$z"\((.*?)\) INDEX (\S+)\s+\((.*?)\)$z\((.*?)\) TableKey \((.*?)\)$z \((.*?)\)$) splits_filesplit_expiration_daterecompilesplit_line_pattern&incorrect_split_with_table_key_pattern&incorrect_split_with_index_key_patternindex_full_key_patternsingle_key_pattern)selfrrs ;lib/googlecloudsdk/command_lib/spanner/split_file_parser.py__init__SplitFileParser.__init__?so"!6 jj)@AD24**-3D/35**-3D/#%**-M"ND jj7Dc4[R"SS5n/n[R"UR5nUR 5R 5GH nURU5nU(a5US(a+US(a!US(aUSR5S;a&[R"SSRU55eUR5nUSR5S :Xa USUl O!USR5S :Xa USUlUS(aURUS5UlUR"(aUR"UlUR'U5 GM# S S S 5 U$!,(df  U$=f) *Gets the split points from the input file.spannerv1 SplitValue ObjectName ObjectType)TABLEINDEX --splits-fileInvalid split point string: {}. Each split point must be in the format of () where ObjectType can be TABLE or INDEXr#r$N)rGetMessagesModuler FileReaderrread splitlinesParseSplitPointStringupper c_exceptionsInvalidArgumentExceptionformat SplitPointstableindexParseSplitValuekeysr expireTimeappend)rmsgssplit_points_listfilesingle_split_string single_splitsplits rProcessSplitFileParser.ProcessLsi  ! !)T 2D   $** +t!%!7!7!9 112EF  - - -L)//19KK55228&9L2M     "  % + + - 8$\2%+ , ' - - /7 :$\2%+  %++L,FG%*  % %!77%   '5": ,8 9 , +8 s EF FcURRU5nU(a3URS5URS5URS5S.$[R"SSR U55e)a?Parses a string in the format " ()". and returns a dictionary with the extracted information. Args: input_string: The string to parse. Returns: A dictionary with keys "ObjectType", "ObjectName", and "SplitValue", or None if the input string is not in the expected format. )r"r!r r%r&)rmatchgroupr-r.r/)r input_stringrCs rr+%SplitFileParser.ParseSplitPointStringnso  # # ) ), 7E  A A A  1 1  ..4f\.B  rc[R"SS5n/nUR5nURR U5(d UR R U5(a&[ R"SSRU55e/nURR U5nU(aAURURS55 URURS55 OZURR U5nU(a!URURS55 O[ R"SS5eUGHnUR5nURS5nUR5nURU5Hn[R "5n US :XaS U lOsUS :XdUS :Xd US :XdUS:Xa[%UR'55U lO&?I #%+',['9i$'2'8'8'>i$""9-#D$ooj!-!1. Orc[R"[R"U5SS[RSS9n[ U5$)zTokenizes text using commas as delimiters, ignoring commas within single quotes. Args: text: The text to tokenize. Returns: A list of tokens. rMT\) quotecharskipinitialspacequoting escapechar)csvreaderioStringIO QUOTE_NONEnext)rtextrjs rrQSplitFileParser.TokenizeWithCsvs9ZZ Ds~~ F <r)rrrrrrrN) __name__ __module__ __qualname____firstlineno____doc__rr=r+r3rQ__static_attributes__rrr r s"> 8 D8>@rr c^[URUR5R5$)r)r rrr=)argss rParseSplitPointsrzs$ ))4+E+E F N N PPr)ru __future__rrrrirkrapitools.base.pyrgooglecloudsdk.api_lib.utilrgooglecloudsdk.callioperr-googlecloudsdk.core.utilr r rzrwrrrs<I&' (,>*zzzQr