fix:test error

Author: whki

examples/persistence/main.go

@@ -27,7 +27,7 @@ import (
 )
 
 func main() {
-	fmt.Println("=== StreamSQL 持久化功能测试 ===\n")
+	fmt.Println("=== StreamSQL 持久化功能测试 ===")
 
 	// 清理之前的测试数据
 	cleanupTestData()
@@ -37,14 +37,14 @@ func main() {
 	testDataOverflowPersistence()
 
 	// 测试2: 模拟程序重启和数据恢复
-	fmt.Println("\n📌 测试2: 程序重启数据恢复")
+	fmt.Println("📌 测试2: 程序重启数据恢复")
 	testDataRecovery()
 
 	// 测试3: 查看持久化文件内容
-	fmt.Println("\n📌 测试3: 持久化文件分析")
+	fmt.Println("📌 测试3: 持久化文件分析")
 	analyzePersistenceFiles()
 
-	fmt.Println("\n✅ 真正持久化功能测试完成！")
+	fmt.Println("✅ 真正持久化功能测试完成！")
 }
 
 func testDataOverflowPersistence() {

functions/expr_bridge_test.go

@@ -117,9 +117,9 @@ func TestGetAllAvailableFunctions(t *testing.T) {
 	// 验证函数数量合理
 	streamSQLFuncs := info["streamsql"].(map[string]interface{})
 	t.Logf("StreamSQL functions count: %d", len(streamSQLFuncs))
-	for name := range streamSQLFuncs {
-		t.Logf("StreamSQL function: %s", name)
-	}
+	// for name := range streamSQLFuncs {
+	// 	t.Logf("StreamSQL function: %s", name)
+	// }
 	assert.GreaterOrEqual(t, len(streamSQLFuncs), 1) // 至少应该有一个函数
 
 	exprLangFuncs := info["expr-lang"].(map[string]interface{})

streamsql_benchmark_test.go

@@ -264,13 +264,15 @@ func BenchmarkPureInputPerformance(b *testing.B) {
 	}
 
 	b.ResetTimer()
+	start := time.Now()
 
 	// 测量纯输入吞吐量
 	for i := 0; i < b.N; i++ {
 		ssql.AddData(data)
 	}
 
-	duration := b.Elapsed()
+	b.StopTimer()
+	duration := time.Since(start)
 	throughput := float64(b.N) / duration.Seconds()
 	b.ReportMetric(throughput, "pure_input_ops/sec")
 }
@@ -1391,15 +1393,15 @@ func BenchmarkOptimizedPerformance(b *testing.B) {
 		}
 
 		b.ResetTimer()
+		start := time.Now()
 
 		for i := 0; i < b.N; i++ {
 			ssql.AddData(data)
 		}
 
-		duration := b.Elapsed()
-		throughput := float64(b.N) / duration.Seconds()
-
 		b.StopTimer()
+		duration := time.Since(start)
+		throughput := float64(b.N) / duration.Seconds()
 
 		// 获取统计
 		detailedStats := ssql.Stream().GetDetailedStats()
@@ -2460,16 +2462,16 @@ func BenchmarkPurePerformance(b *testing.B) {
 	}
 
 	b.ResetTimer()
+	start := time.Now()
 
 	// 纯输入性能测试
 	for i := 0; i < b.N; i++ {
 		ssql.AddData(data)
 	}
 
-	duration := b.Elapsed()
-	throughput := float64(b.N) / duration.Seconds()
-
 	b.StopTimer()
+	duration := time.Since(start)
+	throughput := float64(b.N) / duration.Seconds()
 	cancel()
 
 	b.ReportMetric(throughput, "pure_ops/sec")