当前文件： BnVideo/com.bn388.DBHelper/OdbcHelper.cs[3K，2009-6-12 11:34:38]，打开代码结构图

		            
  1using System;
  2using System.Data;
  3using System.Data.Odbc;
  4using System.Collections;
  5using System.Collections.Generic;
  6using System.Text;
  7
  8namespace com.bn388.DBHelper
  9...{
 10    public class OdbcHelper
 11    ...{
 12        private static OdbcConnection conn;
 13        private static OdbcCommand cmd;
 14        private static OdbcDataReader reader;
 15        private static OdbcDataAdapter da;
 16        private static DataSet dataset;
 17
 18        public static int ExecuteScalar(string sql)
 19        ...{
 20            PrepareCommand(sql);
 21            return Convert.ToInt32(cmd.ExecuteScalar());
 22        }
 23
 24        public static int ExecuteNonQuery(string sql)
 25        ...{
 26            int i;
 27            PrepareCommand(sql);
 28            try
 29            ...{
 30                i = cmd.ExecuteNonQuery();
 31            }
 32            catch
 33            ...{
 34                i = 0;
 35            }
 36            return i;
 37        }
 38
 39        public static bool ExecuteNonQueryTransaction(ArrayList sqls)
 40        ...{
 41            conn = new OdbcConnection();
 42            conn.ConnectionString = Connect.connstring;
 43            if (conn.State == ConnectionState.Closed)
 44            ...{
 45                conn.Open();
 46            }
 47            OdbcTransaction ot = conn.BeginTransaction();
 48
 49            int sql_count = sqls.Count;
 50
 51            List<OdbcCommand> cmds = new List<OdbcCommand>();
 52            for (int i = 0; i < sql_count; i++)
 53            ...{
 54                cmd = new OdbcCommand(sqls[i].ToString(), conn);
 55                cmd.Transaction = ot;
 56                cmds.Add(cmd);
 57            }
 58
 59            bool isOK;
 60            try
 61            ...{
 62                for (int i = 0; i < sql_count; i++)
 63                ...{
 64                    cmds[i].ExecuteNonQuery();
 65                }
 66                ot.Commit();
 67                isOK = true;
 68            }
 69            catch
 70            ...{
 71                ot.Rollback();
 72                isOK = false;
 73            }
 74            return isOK;         
 75        }
 76
 77        public static OdbcDataReader SingleRow(string sql)
 78        ...{
 79            PrepareCommand(sql);
 80            reader = cmd.ExecuteReader(CommandBehavior.SingleRow);
 81            return reader;
 82        }
 83
 84        public static OdbcDataReader ExecuteReader(string sql)
 85        ...{
 86            PrepareCommand(sql);
 87            reader = cmd.ExecuteReader();
 88            return reader;
 89        }
 90
 91        public static DataSet Data_Set(string sql, string table)
 92        ...{
 93            PrepareCommand(sql);
 94            da = new OdbcDataAdapter();
 95            da.SelectCommand = cmd;
 96            dataset = new DataSet();
 97            da.Fill(dataset, table);
 98            return dataset;
 99        }
100
101        public static DataSet Data_Set(string sql, string table, int startindex, int pagesize)
102        ...{
103            PrepareCommand(sql);
104            da = new OdbcDataAdapter();
105            da.SelectCommand = cmd;
106            dataset = new DataSet();
107            da.Fill(dataset, startindex, pagesize, table);
108            return dataset;
109        }
110
111        public static DataSet AspNetPager(Wuqi.Webdiyer.AspNetPager pager, string sql, string table)
112        ...{
113            PrepareCommand(sql);
114            da = new OdbcDataAdapter();
115            da.SelectCommand = cmd;
116            dataset = new DataSet();
117            da.Fill(dataset, pager.PageSize * (pager.CurrentPageIndex - 1), pager.PageSize, table);
118            return dataset;
119        }
120
121        public static void PrepareCommand(string sql)
122        ...{
123            conn = new OdbcConnection();
124            conn.ConnectionString = Connect.connstring;
125            if (conn.State != ConnectionState.Open)
126            ...{
127                conn.Open();
128            }
129            cmd = new OdbcCommand(sql, conn);
130            
131        }
132
133        public static void Close()
134        ...{
135            if (conn.State != ConnectionState.Closed)
136            ...{
137                conn.Close();
138                conn.Dispose();
139            }
140        }
141
142
143    }
144}
145