GaussDB不支持的特性

Author: szlele

.env.example

@@ -5,6 +5,7 @@ use gaussdb_test_helpers::*;
 use std::error::Error;
 
 #[test]
+#[ignore] // GaussDB doesn't support DOMAIN
 fn defaults() {
     #[derive(FromSql, ToSql, Debug, PartialEq)]
     struct SessionId(Vec<u8>);
@@ -31,6 +32,7 @@ fn defaults() {
 }
 
 #[test]
+#[ignore] // GaussDB doesn't support DOMAIN
 fn name_overrides() {
     #[derive(FromSql, ToSql, Debug, PartialEq)]
     #[gaussdb(name = "session_id")]
@@ -58,6 +60,7 @@ fn name_overrides() {
 }
 
 #[test]
+#[ignore] // GaussDB doesn't support DOMAIN
 fn wrong_name() {
     #[derive(FromSql, ToSql, Debug, PartialEq)]
     struct SessionId(Vec<u8>);
@@ -80,6 +83,7 @@ fn wrong_name() {
 }
 
 #[test]
+#[ignore] // GaussDB doesn't support DOMAIN
 fn wrong_type() {
     #[derive(FromSql, ToSql, Debug, PartialEq)]
     #[gaussdb(name = "session_id")]
@@ -103,6 +107,7 @@ fn wrong_type() {
 }
 
 #[test]
+#[ignore] // GaussDB doesn't support DOMAIN
 fn domain_in_composite() {
     #[derive(FromSql, ToSql, Debug, PartialEq)]
     #[gaussdb(name = "domain")]

gaussdb-derive-test/src/domains.rs

@@ -240,7 +240,7 @@ async fn custom_enum() {
 }
 
 #[tokio::test]
-#[cfg(feature = "opengauss")]
+#[ignore] // GaussDB doesn't support DOMAIN
 async fn custom_domain() {
     let client = connect("user=postgres").await;
 
@@ -327,19 +327,13 @@ async fn custom_range() {
 }
 
 #[tokio::test]
-#[ignore] // GaussDB simple query message format differences
 #[allow(clippy::get_first)]
 async fn simple_query() {
-    // TODO: GaussDB简单查询消息格式差异
-    // 原因：GaussDB的简单查询响应消息格式与PostgreSQL略有不同，消息数量或顺序存在差异
-    // 错误：thread 'simple_query' panicked at: unexpected message
-    // 影响：仅影响对消息格式严格验证的测试，实际查询功能完全正常
-    // 解决方案：开发更灵活的消息验证逻辑，适应GaussDB的消息格式
-    let client = connect("user=postgres").await;
+    let client = connect("").await;
 
     let messages = client
         .simple_query(
-            "CREATE TABLE IF NOT EXISTS simple_query_test (
+            "CREATE TEMPORARY TABLE simple_query_test (
                 id INTEGER,
                 name TEXT
             );
@@ -393,36 +387,44 @@ async fn simple_query() {
         command_completes >= 3,
         "Should have at least 3 command completes"
     );
-    match &messages[3] {
-        SimpleQueryMessage::Row(row) => {
-            assert_eq!(row.columns().get(0).map(|c| c.name()), Some("id"));
-            assert_eq!(row.columns().get(1).map(|c| c.name()), Some("name"));
-            assert_eq!(row.get(0), Some("1"));
-            assert_eq!(row.get(1), Some("steven"));
+    
+    // 不再硬编码索引检查，而是遍历消息查找特定类型
+    let mut row_messages = Vec::new();
+    
+    for message in &messages {
+        match message {
+            SimpleQueryMessage::Row(_) => {
+                row_messages.push(message);
+            }
+            _ => {}
         }
-        _ => panic!("unexpected message"),
     }
-    match &messages[4] {
-        SimpleQueryMessage::Row(row) => {
-            assert_eq!(row.columns().get(0).map(|c| c.name()), Some("id"));
-            assert_eq!(row.columns().get(1).map(|c| c.name()), Some("name"));
-            assert_eq!(row.get(0), Some("2"));
-            assert_eq!(row.get(1), Some("joe"));
-        }
-        _ => panic!("unexpected message"),
+    
+    // 确保我们至少有2行数据
+    assert!(row_messages.len() >= 2, "Should have at least 2 Row messages");
+    
+    // 检查第一行数据
+    if let SimpleQueryMessage::Row(row) = &row_messages[0] {
+        assert_eq!(row.columns().get(0).map(|c| c.name()), Some("id"));
+        assert_eq!(row.columns().get(1).map(|c| c.name()), Some("name"));
+        assert_eq!(row.get(0), Some("1"));
+        assert_eq!(row.get(1), Some("steven"));
     }
-    match messages[5] {
-        SimpleQueryMessage::CommandComplete(2) => {}
-        _ => panic!("unexpected message"),
+    
+    // 检查第二行数据
+    if let SimpleQueryMessage::Row(row) = &row_messages[1] {
+        assert_eq!(row.columns().get(0).map(|c| c.name()), Some("id"));
+        assert_eq!(row.columns().get(1).map(|c| c.name()), Some("name"));
+        assert_eq!(row.get(0), Some("2"));
+        assert_eq!(row.get(1), Some("joe"));
     }
-    assert_eq!(messages.len(), 6);
 }
 
 #[tokio::test]
 async fn cancel_query_raw() {
-    let client = connect("user=postgres").await;
+    let client = connect("user=gaussdb_tests password=gaussdb_tests123").await;
 
-    let socket = TcpStream::connect("127.0.0.1:5433").await.unwrap();
+    let socket = TcpStream::connect("113.44.80.136:8000").await.unwrap();
     let cancel_token = client.cancel_token();
     let cancel = cancel_token.cancel_query_raw(socket, NoTls);
     let cancel = time::sleep(Duration::from_millis(100)).then(|()| cancel);
@@ -798,7 +800,7 @@ async fn copy_out() {
 async fn notices() {
     let long_name = "x".repeat(65);
     let (client, mut connection) = connect_raw(&format!(
-        "user=gaussdb password=Gaussdb@123 dbname=postgres application_name={}",
+        "host=113.44.80.136 port=8000 user=gaussdb_tests password=gaussdb_tests123 dbname=gaussdb_tests application_name={}",
         long_name,
     ))
     .await

tokio-gaussdb/tests/test/main.rs

@@ -496,7 +496,7 @@ async fn test_slice_range() {
 }
 
 #[tokio::test]
-#[cfg(feature = "opengauss")]
+#[ignore] // GaussDB doesn't support Domain
 async fn domain() {
     #[derive(Debug, PartialEq)]
     struct SessionId(Vec<u8>);