使用C#訪問數據庫入門

寫在前面：

這里的代碼只是為了同學們學習的時候入門，很多該優化、簡寫的東西都沒有處理。

這種訪問數據庫的方法還存在嚴重的安全漏洞（sql注入漏洞），實際開發中禁止使用。

工作中可以使用改良后的類，安全，結構復雜，使用方法類似。不利於此處學習，故不在此列出。

---

數據庫操作類代碼：

#define WIN
//#define NET
//********ACCESS要開類型和版本兩個******
//#define ACCESS
//#define ACCESS_2003
//#define ACCESS_2010
//********EXCEL開一個具體版本就行了******
//(#define EXCEL)
//#define EXCEL_2010
//********************************
#define SQLSERVER
//(sql2000測試通過)
//*******************************
//#define MYSQL

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using System.Data.OleDb;
using System.Data.SqlClient;
//using MySql.Data.MySqlClient;
#if NET
    using System.Web;
#endif

namespace HC
{
    //操作access等數據庫的類
    class Hc_db
    {
        public Hc_db()
        {
        }
#if SQLSERVER
        static SqlConnection createConn()
#elif MYSQL
            static MySqlConnection createConn()
#else
            static OleDbConnection createConn()
#endif
        {
#if SQLSERVER
            string s1 = "server=(localdb)\\mssqllocaldb;initial catalog=d1;user ID=sa;password=123456;";
#endif
#if ACCESS_2003
                string s1 = "Provider=Microsoft.Jet.OLEDB.4.0;Data Source=";
#endif
#if ACCESS_2010
                string s1 = "Provider=Microsoft.ACE.OLEDB.12.0;Data Source=";
#endif
#if ACCESS
#if NET
                    string s2 =@HttpContext.Current.Server.MapPath(@"~/data/d1.accdb"); 
#endif
#if WIN
                    string s2 = System.IO.Path.GetDirectoryName(System.Reflection.Assembly.GetExecutingAssembly().Location)+@"\data\yangbiao.mdb"; 
#endif
#endif

#if EXCEL_2010
                string s1 = "Provider=Microsoft.ACE.OLEDB.12.0;Data Source=";
#if NET
                    string s2 =@HttpContext.Current.Server.MapPath(@"~/data/e1.xlsx")+";Extended Properties='Excel 12.0;HDR=YES'";//HDR=YES表示有標題
#endif
#if WIN
                    string s2 =System.IO.Path.GetDirectoryName(System.Reflection.Assembly.GetExecutingAssembly().Location)+@"\data\e1.xlsx"+";Extended Properties='Excel 12.0;HDR=YES'";//HDR=YES表示有標題
#endif
            //說明：
                //若要引用完全使用的工作表的范圍，請指定后面跟有美元符號的工作表名稱。例如： 
                //select * from [Sheet1$] 
                //若要引用工作表上的特定地址范圍，請指定后面跟有美元符號和該范圍的工作表名稱。例如： 
                //select * from [Sheet1$A1:B10]
                //關於IMEX:
                //若為 0，則為輸出模式，此情況下只能用作寫入 Excel； 
                //若為 1，則為輸入模式，此情況下只能用作讀取 Excel，並且始終將 Excel 數據作為文本類型讀取； 
                //若為 2，則為連接模式，此情況下既可用作寫入、也可用作讀取。
                //所以若要讀取混合數據類型，應該將 IMEX 設置為 1；若誤設置為 0，則讀取不到任何行；若誤設置為 2 或省略，則有些數據讀取出來是空白。
                //注意：輸出模式對應寫入、輸入模式對應讀取。
#endif
#if MYSQL
            string s1 = "Database=ipt_authd;Data Source=10.10.XXX.XXX;User Id=XXXX;allow zero datetime=true";
            //標准寫法：myConnectionString = "Database=Test;Data Source=localhost;User Id=username;Password=pass";
#endif
#if SQLSERVER
            SqlConnection conn = new SqlConnection(s1);
#elif MYSQL
                MySqlConnection conn = new MySqlConnection(s1);
#else
                OleDbConnection conn = new OleDbConnection(s1+s2);
#endif
            return conn;
        }

        public static DataTable get_datatable(string s1)
        {
#if SQLSERVER
            SqlConnection myconn = Hc_db.createConn();
            SqlDataAdapter myda = new SqlDataAdapter(s1, myconn);
#elif MYSQL
                    MySqlConnection myconn = Hc_db.createConn();                
                    MySqlDataAdapter myda = new MySqlDataAdapter(s1, myconn);
#else
                OleDbConnection myconn = Hc_db.createConn();
                OleDbDataAdapter myda = new OleDbDataAdapter(s1, myconn);
#endif
            DataSet myds = new DataSet();
            try
            {
                myconn.Open();
                myda.Fill(myds, "No1");
                myconn.Close();
                //myconn.Dispose();
                return myds.Tables["No1"];
            }
            catch (Exception e1)
            {
                throw (e1);
            }
        }
        public static int do_nonquery(string s1)
        {
#if SQLSERVER
            SqlConnection myconn = Hc_db.createConn();
            SqlCommand mycomm = new SqlCommand(s1, myconn);
#elif MYSQL
                MySqlConnection myconn = Hc_db.createConn();
                MySqlCommand mycomm = new MySqlCommand(s1, myconn);
#else
            OleDbConnection myconn = Hc_db.createConn();
            OleDbCommand mycomm = new OleDbCommand(s1, myconn);
#endif
            try
            {
                int c;
                myconn.Open();
                c = mycomm.ExecuteNonQuery();
                myconn.Close();
                //myconn.Dispose();
                return c;
            }
            catch (Exception e1)
            {
                //HttpContext.Current.Response.Write("<script language='javascript' defer>alert('" + e1.ToString() + "');</script>");
                throw (e1);
                //return false;
            }
        }
    }
}
//INSERT INTO 表 [(字段1[,字段2[, ...]])]
////VALUES (值1[,值2[, ...])
//            string str_sql = "insert into myt1(姓名,性別,年齡) values('"+textBox2.Text+"','"+textBox3.Text+"',"+textBox4.Text+")";

 

以上代碼可用作控制台下操作localdb數據庫。對於其他的sqlserver，修改第45行信息。

在mvc等web環境下使用，修改前兩行即可。

數據庫內容如下：

 

 控制台程序如下：

 static void Main(string[] args)
        {
            DataTable dt;
            string sql;
            sql = "select * from t1";
            dt = Hc_db.get_datatable(sql);
            for (int i = 0; i < dt.Rows.Count; i++)
            {
                for (int j = 0; j < dt.Columns.Count; j++)
                {
                    Console.Write(dt.Rows[i][j].ToString()+"\t");
                }
                Console.WriteLine(); ;
            }
            Hc_db.do_nonquery("delete from t1 where xm='ls'");
            dt = Hc_db.get_datatable(sql);
            Console.WriteLine(dt.Rows.Count);
            Console.ReadKey();
        }

運行結果：