declare @max_fsrq datetime
  declare @currJJDM varchar(10)
  declare @temp table (jjdm2 varchar(10))
  declare @useTime datetime
  set @useTime =GETDATE ();
  
  insert into @temp(jjdm2)
   select jjdm from [FundYield] group by jjdm order by jjdm asc
   
  while EXISTS (select jjdm2 from @temp)
  begin
    set @currJJDM=(select top 1 jjdm2 from @temp)
    select @max_fsrq = MAX(fsrq) from [FundYield] where jjdm=@currJJDM
    delete from @temp where jjdm2 =@currJJDM 
    print @max_fsrq
  end

print 'T-SQL Execute Times(ms):'  
 print datediff(ms,@useTime,getdate())

 public static void Test2(string connName1,string connName2)
        {
            System.Diagnostics.Stopwatch watch = new System.Diagnostics.Stopwatch();
            watch.Start();
            string allJjdmList = "";
            string connString = getConnectionString();
            //SqlConnection conn = new SqlConnection(connString);
            //conn.Open();

string sql = "select jjdm from [FundYield] group by jjdm order by jjdm asc";
            DataSet ds = getData(connString, sql);
            int allCount = ds.Tables[0].Rows.Count;
            int p = (int)(allCount * 0.5);

System.Threading.Thread t1=new System.Threading.Thread (new System.Threading.ParameterizedThreadStart (tp1=>
                {
                    for (int i = 0; i < p; i++)
                    {
                        string jjdm = ds.Tables[0].Rows[i][0].ToString();

object result = getSclar(ConfigurationManager.ConnectionStrings[connName1].ConnectionString,
                       string.Format("select MAX(fsrq) from [FundYield] where jjdm='{0}'", jjdm));
                        if (result != DBNull.Value)
                        {
                            DateTime dt = Convert.ToDateTime(result);
                            //Console.WriteLine("Thread 2 No {0} ,jjdm[{1}] last FSRQ is:{2}", i, jjdm, dt);
                        }

allJjdmList = allJjdmList + "," + jjdm;
                    }

Console.WriteLine("Tread 1 used all time is(ms):{0}", watch.ElapsedMilliseconds);
                }
            ));

System.Threading.Thread t2 = new System.Threading.Thread(new System.Threading.ParameterizedThreadStart(tp2 =>
            {
                for (int i = p; i < allCount; i++)
                {
                    string jjdm = ds.Tables[0].Rows[i][0].ToString();
                    //这里不论使用default还是express，区别不大
                    object result = getSclar(ConfigurationManager.ConnectionStrings[connName2].ConnectionString,
                        string.Format("select MAX(fsrq) from [FundYield] where jjdm='{0}'", jjdm));
                    if (result != DBNull.Value)
                    {
                        DateTime dt = Convert.ToDateTime(result);
                        //Console.WriteLine("Thread 2 No {0} ,jjdm[{1}] last FSRQ is:{2}", i, jjdm, dt);
                    }
                    
                    allJjdmList = allJjdmList + "," + jjdm;
                }

Console.WriteLine("Tread 2 used all time is(ms):{0}", watch.ElapsedMilliseconds);
            }
            ));

t1.Start();
            t2.Start();
            t1.Join();
            t2.Join();

Console.WriteLine("====All thread completed!========");

}