Apakah mungkin untuk Pivot data menggunakan LINQ?

171

Saya bertanya-tanya apakah mungkin menggunakan LINQ untuk menggerakkan data dari tata letak berikut:

CustID | OrderDate | Qty
1      | 1/1/2008  | 100
2      | 1/2/2008  | 200
1      | 2/2/2008  | 350
2      | 2/28/2008 | 221
1      | 3/12/2008 | 250
2      | 3/15/2008 | 2150

menjadi sesuatu seperti ini:

CustID  | Jan- 2008 | Feb- 2008 | Mar - 2008 |
1       | 100       | 350       |  250
2       | 200       | 221       | 2150
Tim Lentine
sumber

Jawaban:

190

Sesuatu seperti ini?

List<CustData> myList = GetCustData();

var query = myList
    .GroupBy(c => c.CustId)
    .Select(g => new {
        CustId = g.Key,
        Jan = g.Where(c => c.OrderDate.Month == 1).Sum(c => c.Qty),
        Feb = g.Where(c => c.OrderDate.Month == 2).Sum(c => c.Qty),
        March = g.Where(c => c.OrderDate.Month == 3).Sum(c => c.Qty)
    });

GroupBydi Linq tidak bekerja sama dengan SQL. Di SQL, Anda mendapatkan kunci dan agregat (bentuk baris / kolom). Di Linq, Anda mendapatkan kunci dan elemen apa pun sebagai anak-anak dari kunci (bentuk hierarkis). Untuk berputar, Anda harus memproyeksikan hierarki kembali ke bentuk baris / kolom yang Anda pilih.

Amy B
sumber
Apakah daftar harus menjadi IEnumerable sebelum Anda dapat menerapkan pivot? Atau dapatkah ini juga dilakukan pada IQueryable dari EF (tanpa harus mematerialisasikan daftar dalam memori)?
Rob Vermeulen
@RobVermeulen Saya bisa menerjemahkan kueri itu ke dalam sql, jadi saya berharap EF bisa menerjemahkannya juga. Cobalah, kurasa?
Amy B
Saya mengujinya, dan itu berfungsi. Meskipun SQL Profiler menunjukkan bahwa EF tidak akan menerjemahkannya menjadi kueri pivot (cepat) tetapi beberapa sub-kueri yang lebih lambat.
Rob Vermeulen
12

Saya menjawab pertanyaan serupa menggunakan metode ekstensi LINQ:

// order s(ource) by OrderDate to have proper column ordering
var r = s.Pivot3(e => e.custID, e => e.OrderDate.ToString("MMM-yyyy")
    , lst => lst.Sum(e => e.Qty));
// order r(esult) by CustID

(+) implementasi generik
(-) jelas lebih lambat dari Amy B.

Adakah yang bisa meningkatkan implementasi saya (yaitu metode melakukan pemesanan kolom & baris)?

Sanjaya.Tio
sumber
7

Pendekatan rapi untuk ini, saya pikir, adalah menggunakan pencarian:

var query =
    from c in myList
    group c by c.CustId into gcs
    let lookup = gcs.ToLookup(y => y.OrderDate.Month, y => y.Qty)
    select new
    {
        CustId = gcs.Key,
        Jan = lookup[1].Sum(),
        Feb = lookup[2].Sum(),
        Mar = lookup[3].Sum(),
    };
Enigmativitas
sumber
2

Berikut ini cara yang lebih umum tentang cara memutar data menggunakan LINQ:

IEnumerable<CustData> s;
var groupedData = s.ToLookup( 
        k => new ValueKey(
            k.CustID, // 1st dimension
            String.Format("{0}-{1}", k.OrderDate.Month, k.OrderDate.Year // 2nd dimension
        ) ) );
var rowKeys = groupedData.Select(g => (int)g.Key.DimKeys[0]).Distinct().OrderBy(k=>k);
var columnKeys = groupedData.Select(g => (string)g.Key.DimKeys[1]).Distinct().OrderBy(k=>k);
foreach (var row in rowKeys) {
    Console.Write("CustID {0}: ", row);
    foreach (var column in columnKeys) {
        Console.Write("{0:####} ", groupedData[new ValueKey(row,column)].Sum(r=>r.Qty) );
    }
    Console.WriteLine();
}

di mana ValueKey adalah kelas khusus yang mewakili kunci multidimensi:

public sealed class ValueKey {
    public readonly object[] DimKeys;
    public ValueKey(params object[] dimKeys) {
        DimKeys = dimKeys;
    }
    public override int GetHashCode() {
        if (DimKeys==null) return 0;
        int hashCode = DimKeys.Length;
        for (int i = 0; i < DimKeys.Length; i++) { 
            hashCode ^= DimKeys[i].GetHashCode();
        }
        return hashCode;
    }
    public override bool Equals(object obj) {
        if ( obj==null || !(obj is ValueKey))
            return false;
        var x = DimKeys;
        var y = ((ValueKey)obj).DimKeys;
        if (ReferenceEquals(x,y))
            return true;
        if (x.Length!=y.Length)
            return false;
        for (int i = 0; i < x.Length; i++) {
            if (!x[i].Equals(y[i]))
                return false;
        }
        return true;            
    }
}

Pendekatan ini dapat digunakan untuk pengelompokan berdasarkan N-dimensi (n> 2) dan akan berfungsi dengan baik untuk dataset yang agak kecil. Untuk dataset besar (hingga 1 juta catatan dan lebih banyak lagi) atau untuk kasus-kasus ketika konfigurasi pivot tidak dapat di-hardcode, saya telah menulis pustaka PivotData khusus (gratis):

var pvtData = new PivotData(new []{"CustID","OrderDate"}, new SumAggregatorFactory("Qty"));
pvtData.ProcessData(s, (o, f) => {
    var custData = (TT)o;
    switch (f) {
        case "CustID": return custData.CustID;
        case "OrderDate": 
        return String.Format("{0}-{1}", custData.OrderDate.Month, custData.OrderDate.Year);
        case "Qty": return custData.Qty;
    }
    return null;
} );
Console.WriteLine( pvtData[1, "1-2008"].Value );  
Vitaliy Fedorchenko
sumber
2

Ini cara yang paling efisien:

Periksa pendekatan berikut. Alih-alih mengulangi melalui kelompok pelanggan setiap waktu untuk setiap bulan.

var query = myList
    .GroupBy(c => c.CustId)
    .Select(g => {
        var results = new CustomerStatistics();
        foreach (var customer in g)
        {
            switch (customer.OrderDate.Month)
            {
                case 1:
                    results.Jan += customer.Qty;
                    break;
                case 2:
                    results.Feb += customer.Qty;
                    break;
                case 3:
                    results.March += customer.Qty;
                    break;
                default:
                    break;
            }
        }
        return  new
        {
            CustId = g.Key,
            results.Jan,
            results.Feb,
            results.March
        };
    });

Atau yang ini:

var query = myList
    .GroupBy(c => c.CustId)
    .Select(g => {
        var results = g.Aggregate(new CustomerStatistics(), (result, customer) => result.Accumulate(customer), customerStatistics => customerStatistics.Compute());
        return  new
        {
            CustId = g.Key,
            results.Jan,
            results.Feb,
            results.March
        };
    });

Solusi lengkap:

using System;
using System.Collections.Generic;
using System.Linq;

namespace ConsoleApp
{
    internal class Program
    {
        private static void Main(string[] args)
        {
            IEnumerable<CustData> myList = GetCustData().Take(100);

            var query = myList
                .GroupBy(c => c.CustId)
                .Select(g =>
                {
                    CustomerStatistics results = g.Aggregate(new CustomerStatistics(), (result, customer) => result.Accumulate(customer), customerStatistics => customerStatistics.Compute());
                    return new
                    {
                        CustId = g.Key,
                        results.Jan,
                        results.Feb,
                        results.March
                    };
                });
            Console.ReadKey();
        }

        private static IEnumerable<CustData> GetCustData()
        {
            Random random = new Random();
            int custId = 0;
            while (true)
            {
                custId++;
                yield return new CustData { CustId = custId, OrderDate = new DateTime(2018, random.Next(1, 4), 1), Qty = random.Next(1, 50) };
            }
        }

    }
    public class CustData
    {
        public int CustId { get; set; }
        public DateTime OrderDate { get; set; }
        public int Qty { get; set; }
    }
    public class CustomerStatistics
    {
        public int Jan { get; set; }
        public int Feb { get; set; }
        public int March { get; set; }
        internal CustomerStatistics Accumulate(CustData customer)
        {
            switch (customer.OrderDate.Month)
            {
                case 1:
                    Jan += customer.Qty;
                    break;
                case 2:
                    Feb += customer.Qty;
                    break;
                case 3:
                    March += customer.Qty;
                    break;
                default:
                    break;
            }
            return this;
        }
        public CustomerStatistics Compute()
        {
            return this;
        }
    }
}
Ali Bayat
sumber
-4

Kelompokkan data Anda pada bulan, dan kemudian proyeksikan ke data baru dengan kolom untuk setiap bulan. Tabel baru akan menjadi tabel pivot Anda.

mattlant
sumber
Saya tidak dapat membayangkan bagaimana ini akan bekerja, tapi saya cukup penasaran untuk meminta Anda memasukkan beberapa contoh kode.
Josh Gallagher