| 235 | } |
| 236 | |
| 237 | arrow::Result<StatementIngest> ParseCommandStatementIngest( |
| 238 | const google::protobuf::Any& any) { |
| 239 | pb::sql::CommandStatementIngest command; |
| 240 | if (!any.UnpackTo(&command)) { |
| 241 | return Status::Invalid("Unable to unpack CommandStatementIngest."); |
| 242 | } |
| 243 | |
| 244 | StatementIngest result; |
| 245 | TableDefinitionOptions table_definition_options; |
| 246 | switch (command.table_definition_options().if_not_exist()) { |
| 247 | case pb::sql::CommandStatementIngest::TableDefinitionOptions:: |
| 248 | TABLE_NOT_EXIST_OPTION_UNSPECIFIED: |
| 249 | table_definition_options.if_not_exist = |
| 250 | TableDefinitionOptionsTableNotExistOption::kUnspecified; |
| 251 | break; |
| 252 | case pb::sql::CommandStatementIngest::TableDefinitionOptions:: |
| 253 | TABLE_NOT_EXIST_OPTION_CREATE: |
| 254 | table_definition_options.if_not_exist = |
| 255 | TableDefinitionOptionsTableNotExistOption::kCreate; |
| 256 | break; |
| 257 | case pb::sql::CommandStatementIngest::TableDefinitionOptions:: |
| 258 | TABLE_NOT_EXIST_OPTION_FAIL: |
| 259 | table_definition_options.if_not_exist = |
| 260 | TableDefinitionOptionsTableNotExistOption::kFail; |
| 261 | break; |
| 262 | |
| 263 | default: |
| 264 | return Status::Invalid( |
| 265 | "Unrecognized TableNotExistOption for " |
| 266 | "CommandStatementIngest::TableDefinitionOptions."); |
| 267 | } |
| 268 | |
| 269 | switch (command.table_definition_options().if_exists()) { |
| 270 | case pb::sql::CommandStatementIngest::TableDefinitionOptions:: |
| 271 | TABLE_EXISTS_OPTION_UNSPECIFIED: |
| 272 | table_definition_options.if_exists = |
| 273 | TableDefinitionOptionsTableExistsOption::kUnspecified; |
| 274 | break; |
| 275 | case pb::sql::CommandStatementIngest::TableDefinitionOptions:: |
| 276 | TABLE_EXISTS_OPTION_FAIL: |
| 277 | table_definition_options.if_exists = TableDefinitionOptionsTableExistsOption::kFail; |
| 278 | break; |
| 279 | case pb::sql::CommandStatementIngest::TableDefinitionOptions:: |
| 280 | TABLE_EXISTS_OPTION_APPEND: |
| 281 | table_definition_options.if_exists = |
| 282 | TableDefinitionOptionsTableExistsOption::kAppend; |
| 283 | break; |
| 284 | case pb::sql::CommandStatementIngest::TableDefinitionOptions:: |
| 285 | TABLE_EXISTS_OPTION_REPLACE: |
| 286 | table_definition_options.if_exists = |
| 287 | TableDefinitionOptionsTableExistsOption::kReplace; |
| 288 | break; |
| 289 | |
| 290 | default: |
| 291 | return Status::Invalid( |
| 292 | "Unrecognized TableExistsOption for " |
| 293 | "CommandStatementIngest::TableDefinitionOptions."); |
| 294 | } |