mikhailnazarov / ydb-rs-sqlx Goto Github PK

CREATE TABLE IF NOT EXISTS test_opt(
      id Int32 NOT NULL,
      title Utf8,
      PRIMARY KEY (id)
  );
  insert into test_opt(id, title) values
        (1, 'title1'),
        (2, 'title2'),
        (3, 'title3')
;

let rows = sqlx::query_as::<_,(i32, Option<String>)>(r#"
        select * from test_opt
    "#).fetch_all(&mut *conn).await.unwrap();

ColumnDecode { index: "1", source: Convert("failed to convert from Optional to alloc::string::String")

2024-07-04T05:20:54.029986Z ERROR ydb::client_table: error=YdbStatusError(YdbStatusError { message: "Operation { id: \"\", ready: true, status: SchemeError, issues: [IssueMessage { position: None, message: \"Type annotation\", end_position: None, issue_code: 1030, severity: 1, issues: [IssueMessage { position: Some(Position { row: 4, column: 1, file: \"\" }), message: \"At function: KiReadTable!\", end_position: Some(Position { row: 4, column: 1, file: \"\" }), issue_code: 0, severity: 1, issues: [IssueMessage { position: Some(Position { row: 4, column: 1, file: \"\" }), message: \"Cannot find table 'db.[/local/test2]' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions.\", end_position: Some(Position { row: 4, column: 1, file: \"\" }), issue_code: 2003, severity: 1, issues: [] }] }] }], result: Some(Any { type_url: \"type.googleapis.com/Ydb.Table.ExecuteQueryResult\", value: [18, 0] }), metadata: None, cost_info: None }", operation_status: 400070, issues: [YdbIssue { issue_code: 1030, message: "Type annotation", issues: [YdbIssue { issue_code: 0, message: "At function: KiReadTable!", issues: [YdbIssue { issue_code: 2003, message: "Cannot find table 'db.[/local/test2]' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions.", issues: [], severity: Error }], severity: Error }], severity: Error }] })
Error: Database(InternalError { message: "Operation { id: \"\", ready: true, status: SchemeError, issues: [IssueMessage { position: None, message: \"Type annotation\", end_position: None, issue_code: 1030, severity: 1, issues: [IssueMessage { position: Some(Position { row: 4, column: 1, file: \"\" }), message: \"At function: KiReadTable!\", end_position: Some(Position { row: 4, column: 1, file: \"\" }), issue_code: 0, severity: 1, issues: [IssueMessage { position: Some(Position { row: 4, column: 1, file: \"\" }), message: \"Cannot find table 'db.[/local/test2]' because it does not exist or you do not have access permissions. Please check correctness of table path and user permissions.\", end_position: Some(Position { row: 4, column: 1, file: \"\" }), issue_code: 2003, severity: 1, issues: [] }] }] }], result: Some(Any { type_url: \"type.googleapis.com/Ydb.Table.ExecuteQueryResult\", value: [18, 0] }), metadata: None, cost_info: None }" })

[YdbIssue { issue_code: 0, message: "Failed to convert type: Struct<.....................,'token_expires_at':Timestamp,...............> to Struct<....................,'token_expires_at':Datetime?,.............................>