Function queryExample

examples/session-postgres/main.go:228–268

queryExample 查询和过滤示例

(ctx context.Context, service *postgres.Service, userID string)

// queryExample 查询和过滤示例
func queryExample(ctx context.Context, service *postgres.Service, userID string) {
	// 1. 列出用户的所有 Session
	sessions, err := service.List(ctx, userID, &session.ListOptions{
		Limit: 10,
	})
	if err != nil {
		log.Fatalf("Failed to list sessions: %v", err)
	}

	fmt.Printf("✅ Found %d sessions for user %s\n", len(sessions), userID)

	// 2. 获取 Session 的事件
	if len(sessions) > 0 {
		sessionID := sessions[0].ID
		events, err := service.GetEvents(ctx, sessionID, &session.EventOptions{
			Limit: 10,
		})
		if err != nil {
			log.Fatalf("Failed to get events: %v", err)
		}

		fmt.Printf("✅ Session %s has %d events\n", sessionID[:8], len(events))
		for i, evt := range events {
			fmt.Printf("   [%d] %s: %s\n", i+1, evt.Author, truncate(evt.Content.Content, 30))
		}
	}

	// 3. 按分支过滤事件
	if len(sessions) > 0 {
		sessionID := sessions[0].ID
		events, err := service.GetEvents(ctx, sessionID, &session.EventOptions{
			Branch: "root",
			Limit:  5,
		})
		if err != nil {
			log.Fatalf("Failed to filter events by branch: %v", err)
		}

		fmt.Printf("✅ Found %d events in branch 'root'\n", len(events))
	}
}

// 辅助函数