Function NewPostgreSQLStore

pkg/memory/logic/store_postgres.go:35–62

NewPostgreSQLStore 创建 PostgreSQL 存储

(config *PostgreSQLStoreConfig)

// NewPostgreSQLStore 创建 PostgreSQL 存储
func NewPostgreSQLStore(config *PostgreSQLStoreConfig) (*PostgreSQLStore, error) {
	if config == nil {
		return nil, errors.New("config is required")
	}

	if config.DB == nil {
		return nil, errors.New("database connection is required")
	}

	tableName := config.TableName
	if tableName == "" {
		tableName = "logic_memories"
	}

	store := &PostgreSQLStore{
		db:        config.DB,
		tableName: tableName,
	}

	// 自动创建表
	if config.AutoMigrate {
		if err := store.migrate(); err != nil {
			return nil, fmt.Errorf("failed to migrate: %w", err)
		}
	}

	return store, nil
}

// migrate 创建表结构
func (s *PostgreSQLStore) migrate() error {