Method isColumnUnique

plugins/destination/duckdb/client/migrate.go:221–241

(ctx context.Context, tableName string, columName string)

}

func (c *Client) isColumnUnique(ctx context.Context, tableName string, columName string) (bool, error) {
	rows, err := c.db.QueryContext(ctx, isColumnUniqueSQL, tableName, columName)
	if err != nil {
		return false, err
	}
	defer rows.Close()
	for rows.Next() {
		var n int
		if err := rows.Scan(&n); err != nil {
			return false, err
		}
		if n == 1 {
			return true, nil
		}
	}
	if err := rows.Err(); err != nil {
		return false, err
	}

	return false, nil
}

func (c *Client) getTableInfo(ctx context.Context, tableName string) (*schema.Table, error) {
	info := tableInfo{}