Source Code : C # implementation Apriori algorithm (source code)

C # implementation Apriori algorithm (source code)

1. /*Program.cs*/
2. using System; 
3. using System.Collections.Generic; 
4. using System.Text; 
5. using System.Data; 
6. using System.Data.SqlClient; 
7. using System.Text.RegularExpressions; 
8. using System.Collections; 
9. namespace testApriori1 
10. { 
11.  publicclass TestApriori 
12.  { 
13.  staticvoid Main(string[] args) 
14.  { 
15.  Console.WriteLine(DateTime.Now); 
16.  ArrayList D = GetEventsFromDB();//
17.  ArrayList I = GetItems1FromDB();//
18.  float s = 0.01f;//
19.  List L = new List();//
20.  L = Apriori(D, I, s); 
21.  for (int i = 0; i < L.Count; i++) 
22.  { 
23.  Console.WriteLine(L[i].Items); 
24.  Console.WriteLine(L[i].Sup); 
25.  } 
26.  Console.WriteLine(DateTime.Now); 
27.  Console.Read(); 
28.  } 
30.  #region-----Apriori-----
31.  /// 
32.  /// Apriori
33.  /// 
34.  /// 
35.  /// 
36.  /// 
37.  /// 
38.  static List Apriori(ArrayList D,ArrayList I,float sup) 
39.  { 
40.  List L = new List();//
41.  if (I.Count == 0) return L; 
42.  else
43.  { 
44.  int[] Icount = newint[I.Count];//,0
45.  ArrayList Ifrequent = new ArrayList();//
46.  //?
47.  Regex r=new Regex(","); 
48.  for (int i = 0; i < D.Count; i++) 
49.  { 
50.  string[] subD=r.Split(D[i].ToString()); 
51.  for (int j = 0; j < I.Count;j++ ) 
52.  { 
53.  string[] subI = r.Split(I[j].ToString()); 
54.  bool subIInsubD=true; 
55.  for(int m=0;m
56.  { 
57.  bool subImInsubD=false; 
58.  for(int n=0;n
59.  if (subI[m] == subD[n]) 
60.  { 
61.  subImInsubD = true; 
62.  continue; 
63.  } 
64.  if(subImInsubD==false) subIInsubD=false; 
65.  } 
66.  if(subIInsubD==true) Icount[j]++; 
67.  } 
68.  } 
69.  //L
70.  for (int i = 0; i < Icount.Length;i++ ) 
71.  { 
72.  if (Icount[i] >= sup * D.Count) 
73.  { 
74.  Ifrequent.Add(I[i]); 
75.  ItemSet iSet = new ItemSet(); 
76.  iSet.Items=I[i].ToString(); 
77.  iSet.Sup = Icount[i]; 
78.  L.Add(iSet); 
79.  } 
80.  } 
81.  I.Clear(); 
82.  I = AprioriGen(Ifrequent); 
83.  L.AddRange(Apriori(D, I, sup)); 
84.  return L; 
85.  } 
86.  } 
87.  #endregion-----Apriori-----
89.  #region-------Apriori-gen---------
90.  /// 
91.  /// Apriori-gen
92.  /// 
93.  /// 
94.  /// 
95.  static ArrayList AprioriGen(ArrayList L) 
96.  { 
97.  ArrayList Lk=new ArrayList(); 
98.  Regex r=new Regex(","); 
99.  for(int i=0;i
100.  { 
101.  string[] subL1 = r.Split(L[i].ToString()); 
102.  for(int j=i+1;j
103.  { 
104.  string[] subL2 = r.Split(L[j].ToString()); 
105.  //Ltemp
106.  string temp = L[j].ToString();//
107.  for(int m=0;m
108.  { 
109.  bool subL1mInsubL2=false; 
110.  for(int n=0;n
111.  { 
112.  if (subL1[m] == subL2[n]) subL1mInsubL2 = true; 
113.  } 
114.  if (subL1mInsubL2 == false) temp = temp + "," + subL1[m]; 
115.  } 
116.  //temp?L?+1temp
117.  string[] subTemp = r.Split(temp); 
118.  if (subTemp.Length == subL1.Length + 1) 
119.  { 
120.  bool isExists = false; 
121.  for (int m = 0; m < Lk.Count; m++) 
122.  { 
123.  bool isContained = true; 
124.  for (int n = 0; n < subTemp.Length; n++) 
125.  { 
126.  if (!Lk[m].ToString().Contains(subTemp[n])) isContained=false; 
127.  } 
128.  if (isContained == true) isExists = true; 
129.  } 
130.  if(isExists==false) Lk.Add(temp); 
131.  } 
132.  } 
133.  } 
134.  return Lk; 
135.  } 
136.  #endregion-------Apriori-gen---------
138.  #region----------------
139.  /// 
140.  /// 
141.  /// 
142.  /// 
143.  static ArrayList GetItems1FromDB() 
144.  { 
145.  string commandString = "select distinct Model from dbo.vAssocSeqLineItems"; 
146.  DataSet ds = ExcuteDataSetByCommandString(commandString); 
147.  int countItems1 = 0; 
148.  countItems1 = ds.Tables[0].Rows.Count; 
149.  ArrayList Items1 = new ArrayList(); 
150.  for (int i = 0; i < countItems1; i++) 
151.  Items1.Add(ds.Tables[0].Rows[i]["Model"].ToString()); 
152.  return Items1; 
153.  } 
154.  #endregion----------------
156.  #region----------------
157.  /// 
158.  /// 
159.  /// 
160.  /// 
161.  static ArrayList GetEventsFromDB() 
162.  { 
163.  string commandString="select count(OrderNumber) from vAssocSeqOrders"; 
164.  DataSet ds=ExcuteDataSetByCommandString(commandString); 
165.  int countEvent = Convert.ToInt32(ds.Tables[0].Rows[0][0]);//
166.  ArrayList events=new ArrayList(); 
167.  string temp=null; 
168.  string orderNumber=null;//OrderNumber,Order
169.  //
170.  commandString = "select OrderNumber,Model from vAssocSeqLineItems"; 
171.  ds = ExcuteDataSetByCommandString(commandString); 
172.  for (int i = 0; i < ds.Tables[0].Rows.Count; i++) 
173.  { 
174.  if (orderNumber == null)//
175.  { 
176.  orderNumber = ds.Tables[0].Rows[i]["OrderNumber"].ToString(); 
177.  temp = ds.Tables[0].Rows[i]["Model"].ToString(); 
178.  } 
179.  elseif (orderNumber == ds.Tables[0].Rows[i]["OrderNumber"].ToString())//Order
180.  { 
181.  temp = temp +","+ ds.Tables[0].Rows[i]["Model"]; 
182.  } 
183.  else//Order
184.  { 
185.  events.Add(temp); 
186.  orderNumber = ds.Tables[0].Rows[i]["OrderNumber"].ToString(); 
187.  temp=ds.Tables[0].Rows[i]["Model"].ToString(); 
188.  } 
189.  if (i == ds.Tables[0].Rows.Count - 1) events.Add(temp); 
190.  } 
191.  return events; 
192.  } 
193.  #endregion----------------
195.  #region-----commandString------
196.  /// 
197.  /// commandString
198.  /// 
199.  /// 
200.  /// 
201.  static DataSet ExcuteDataSetByCommandString(string commandString) 
202.  { 
203.  string connectionString = "server=.;database=AdventureWorksDW;trusted_connection=true"; 
204.  SqlConnection sqlCon = new SqlConnection(connectionString); 
205.  sqlCon.Open(); 
206.  SqlCommand sqlCmd = new SqlCommand(); 
207.  sqlCmd.Connection = sqlCon; 
208.  sqlCmd.CommandText = commandString; 
209.  DataSet ds = new DataSet(); 
210.  SqlDataAdapter sqlAdapter = new SqlDataAdapter(sqlCmd); 
211.  sqlAdapter.Fill(ds); 
212.  sqlCon.Close(); 
213.  return ds; 
214.  } 
215.  #endregion-----commandString------
216.  } 
217. }