c#學習筆記-----oracle數據庫操作、ADO.NET

1.1 概述

　　c#程序開發中，數據庫操作無疑是舉足輕重的，數據庫部分的技術點可能占整個c#技術點的1/4。這幾天我一直在研究System.Data.OracleClient.dll反編譯之后的.CS，放棄c#的心都有了，底層代碼不僅全是英文注釋，而且有很多東西看都看不懂，讓我深刻體會封裝的重要性！此外在做sql語句參數化拼接時，我想在c#中效仿java中的PreparedStatement，但是實現起來困難重重，花了很多時間，最后效果也不理想！放棄繼續深入！這就說明用語言開發和開發語言是兩個不同層次的!

　　fhbds!

1.2 操作oracle數據庫

　　任何操作都是建立在先連接上數據庫，連接數據庫需要第三方類庫System.Data.OracleClient.dll，（我已經上傳至文件），添加引用即可使用其中的類和方法。可惜沒有找到關於這個類庫的API，要不然學習這個類庫的阻力就會小很多，雖然微軟官網有一個c#的幫助文檔，但是我看后感覺幫助不大，就像我之前說的不要糾結別人提供給我們的類庫底層到底如何實現的，只要會用就ok了！java中連接數據庫也要導包，連接數據庫的語句在java中叫注冊數據庫驅動！

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using System.Configuration;
using Oracle.ManagedDataAccess.Client;
using System.Collections;


 public static bool ConnectOracle()
        {
            bool linkFlag = false;
            try
            {
                //注冊驅動
                string dataSource = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=2013-20130829TH)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=oracle)));";
                string persistSecurityInfo = "Persist Security Info=True;";
                string userID = "User ID=SYSTEM;";
                string password = "Password=admin;";
                OracleConnection con = new OracleConnection(dataSource + persistSecurityInfo + userID + password);
                con.Open();
                linkFlag = true;
                return linkFlag;
            }
            catch (Exception ex)
            {
                 ex.ToString();
                return linkFlag;

            }
        }

　　dataSource中一般只需要根據oracle安裝目錄下的tnsnames.ora文件修改HOST名和SERVICE_NAME就可以了，這個因人而異。第二個連接字符串不需要修改，usrid和password也是根據實際要
連接哪個數據庫來寫，以后可以寫到配置文檔中。
　　c#中操作數據庫主要用到以下三個類及其其中的方法，分別是：OracleConnection、 OracleDataAdapter、OracleCommand。此外還有一個OracleDataReader，基本上這四個對象就能完成我們
最基本的數據庫操作。
　　OracleConnection是用來連接數據庫的對象，最重要的2個方法就是open（）和close（）了。 OracleDataAdapter主要使用是用來執行select查詢語句的，返回時一個查詢的結果集。
下面這個方法就是通過返回結果集，來獲取數據庫中的數據，c#中獲取數據的方式有點特殊，它是使用了二維數組的方式來存取的，很有一種坐標的感覺！

public static string dataSource = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=2013-20130829TH)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=oracle)));";
        public static string persistSecurityInfo = "Persist Security Info=True;";
        public static string userID = "User ID=SYSTEM;";
        public static string password = "Password=admin;";
        public  static string connectionString = dataSource + persistSecurityInfo + userID + password;
        public static DataSet Query(string connectionString, string SQLString)
        {
            using (OracleConnection connection = new OracleConnection(connectionString))
            {
                DataSet ds = new DataSet();
                try
                {
                    connection.Open();
                    OracleDataAdapter command = new OracleDataAdapter(SQLString, connection);
                    command.Fill(ds, "ds");
                }
                catch (OracleException ex)
                {
                    throw new Exception(ex.Message);
                }
                finally
                {
                    if (connection.State != ConnectionState.Closed)
                    {
                        connection.Close();
                    }
                }
                return ds;
            }
        }

測試腳本：

SET DEFINE OFF;
Insert into STUDENT
   (SID, SNAME, SAGE, SPASS)
 Values
   ('100', '李四', '18', '123456');
Insert into STUDENT
   (SID, SNAME, SAGE, SPASS)
 Values
   ('003', '王五', '18', '123456');
Insert into STUDENT
   (SID, SNAME, SAGE, SPASS)
 Values
   ('004', '趙六', '18', '123456');
Insert into STUDENT
   (SID, SNAME, SAGE, SPASS)
 Values
   ('005', '張光烈', '18', '123456');
Insert into STUDENT
   (SID, SNAME, SAGE, SPASS)
 Values
   ('006', '魏大勇', '18', '123456');
Insert into STUDENT
   (SID, SNAME, SAGE, SPASS)
 Values
   ('007', '朱永博', '18', '123456');
Insert into STUDENT
   (SID, SNAME, SAGE, SPASS)
 Values
   ('001', '張三', '18', '123456');
Insert into STUDENT
   (SID, SNAME, SAGE, SPASS)
 Values
   ('520', '李雲龍', '100', '1314');
COMMIT;

測試代碼：

private void button2_Click(object sender, EventArgs e)
        {
            string sql1 = "select * from student where sid='520'";
            DataSet ds1 = new DataSet();
            ds1 = Query(connectionString, sql1);
            textBox1.Text += "此查詢語句一共查到["+ds1.Tables[0].Rows.Count.ToString()+"]條記錄！";
            textBox1.Text += "此查詢語句一共查到[" + ds1.Tables[0].Columns.Count.ToString() + "]個欄位！";
            textBox1.Text += "此查詢語句查到第一張表，第一條記錄的欄位“SNAME”的值是[" + ds1.Tables[0].Rows[0]["SNAME"].ToString().Trim()+"]！";
            textBox1.Text += "此查詢語句查到的第二個欄位是[" + ds1.Tables[0].Columns[1].ToString() + "]！";
          

        }

輸出：

         其中ds1.Tables[0].Rows.Count就能實現查詢語句返回的記錄數，不需要另外想什么方式！

　　OracleCommand是用來執行insert 、update、delete語句的，返回值是影響的行數！主要發揮作用的是OracleCommand的ExecuteNonQuery()方法。

//執行update insert delete語句，失敗了返回-1，成功了返回影響的行數,注意：自動commit
        public static int ExecuteNonQuery(string connectionString, string SQLString)
        {
            
            using (OracleConnection connection = new OracleConnection(connectionString))
            {
                    int val = -1;
                    try
                    {
                          connection.Open();
                          OracleCommand cmd = new OracleCommand(SQLString, connection);
                         val = cmd.ExecuteNonQuery();
                         cmd.Parameters.Clear();
                    }
                    catch (OracleException ex) {
                        throw new Exception(ex.Message);
                    }
                    finally
                    {
                        if (connection.State != ConnectionState.Closed)
                        {
                            connection.Close();
                        }
                    }
                    return val;
                }
        }

測試代碼：

private void button3_Click(object sender, EventArgs e)
        {

            string sid = "520";
            string sname = "李雲龍";
            int age = 100;
            string password = "1314";

            try
            {
                 string sql = @"Insert into STUDENT(SID, SNAME, SAGE, SPASS)Values('001', '張三', '18', '123456')";
                //string sql = @"update student set sname='韓信' where sid='001'";
               //string sql = @"delete student  where sid='001'";
               // string sql = "insert into student(SID,SNAME,SAGE,SPASS) values('" + sid + "','" + sname + "','" + age + "','" +password+ "')";
                int count = ExecuteNonQuery(connectionString, sql);
                textBox1.Text = count.ToString();
            } catch(Exception ex){
               textBox1.Text= ex.Message;
            }    
        }

 

　　此外OracleCommand還有一個ExecuteScalar()方法，返回的是object對象，返回的是查詢到的第一條記錄的第一個欄位的值，這個作用主要是用來精確查找的，也就是不會出現select *，

否則意義何在？

//返回查詢到第一個對象
        public static object GetCount(string connectionString, string SQLString)
        {
            using (OracleConnection connection = new OracleConnection(connectionString))
            {
                using (OracleCommand cmd = new OracleCommand(SQLString, connection))
                {
                    try
                    {
                        connection.Open();
                        object obj = cmd.ExecuteScalar();
                        if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
                        {
                            return null;
                        }
                        else
                        {
                            return obj;
                        }
                    }
                    catch (OracleException ex)
                    {
                        throw new Exception(ex.Message);
                    }
                    finally
                    {
                        if (connection.State != ConnectionState.Closed)
                        {
                            connection.Close();
                        }
                    }
                }
            }
        }

測試代碼：

            string sql1 = "select spass from student";
            object count = GetCount(connectionString,sql1);
            textBox1.Text = count.ToString();

　　有時候我們並不在意查到的值是什么，在意查不查的到只要稍微修改就可以了！

//判斷某個對象是否存在
        public static bool Exists(string connectionString, string strSql)
        {
            object obj =GetCount(connectionString, strSql);
            int cmdresult;
            if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
            {
                cmdresult = 0;
            }
            else
            {
                cmdresult = int.Parse(obj.ToString());
            }
            if (cmdresult == 0)
            {
                return false;
            }
            else
            {
                return true;
            }
        }

測試代碼：

            string sql1 =@"select spass from student where sname='劉邦'";
            bool flag = Exists(connectionString, sql1);
            textBox1.Text = flag.ToString();

1.3 參數化拼接SQL語句

　　由於實際的開發中很少有sql語句是固定寫死的，比如select * from person where name='某個對象的名字'，實際中對象的名字很多，不可能為每個對象寫一條sql語句，這樣就需要sql語句的拼接，但是實際操作中拼接的sql語句中單引號和雙引號我往往有時候看着這些點時間長了，就感覺他們在亂動，不說錯覺，這樣拼接在執行中很容易發生sql異常!

　java中為此引入  ?  占位符來取代拼接。但是c#中沒有，想要實現也是困難重重！

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

Connection conn = DBTool.getConnection();
PreparedStatement ps = null;
ResultSet rs = null;

public int savaEmployee(Employee e) {
    Connection conn =DBTool.getConnection();
    PreparedStatement ps=null;
    int count=0;
    String sql="insert into employee (empNum,empName,sex,salary,intoTime,outTime,statu,depNum)values(?,?,?,?,SYSDATE(),null,0,?)";
    try {
        ps=conn.prepareStatement(sql);
        ps.setString(1,e.getEmpNum());
        ps.setString(2, e.getEmpName());
        ps.setString(3, e.getSex());
        ps.setDouble(4, e.getSalary());
        ps.setString(5, e.getDepNum());
        count=ps.executeUpdate();
    } catch (SQLException e1) {
        // TODO Auto-generated catch block
        e1.printStackTrace();
    }    finally{
        DBTool.closeAll(conn, ps, null);
    }
    
        return count;
    }

　　java中是這樣實現的，上面代碼只是部分。我看了一些資料，發現c#中很多人是用@去是實現參數化拼接，但是我嘗試了很久，也沒調試成功！而用：可以實現參數化拼接！

　　因為OracleDataAdapter（）所含的四個構造方法都不能傳入數組，只能利用傳入Oraclecommand對象的屬性間接實現！這樣的話，首先需要一個傳輸參數的方法。這個方法作用就是把一些參數硬塞給Oraclecommand一個對象！

//傳入參數
        private static void PrepareCommand(OracleCommand cmd, OracleConnection conn, OracleTransaction trans, string cmdText, OracleParameter[] cmdParms)
        {
            if (conn.State != ConnectionState.Open)
                conn.Open();
            cmd.Connection = conn;
            cmd.CommandText = cmdText;
            if (trans != null)
                cmd.Transaction = trans;
            cmd.CommandType = CommandType.Text;
            if (cmdParms != null)
            {
                foreach (OracleParameter parameter in cmdParms)
                {
                    if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
                        (parameter.Value == null))
                    {
                        parameter.Value = DBNull.Value;
                    }
                    cmd.Parameters.Add(parameter);
                }
            }
        }

 　　 把之前的返回結果集的方法稍作修改！

//執行帶參數的sql查詢語句返回DataSet結果集
        public static DataSet QueryWithP(string connectionString, string SQLString, params OracleParameter[] cmdParms)
        {
            using (OracleConnection connection = new OracleConnection(connectionString))
            {
                OracleCommand cmd = new OracleCommand();
                PrepareCommand(cmd, connection, null, SQLString, cmdParms);
                using (OracleDataAdapter da = new OracleDataAdapter(cmd))
                {
                    DataSet ds = new DataSet();
                    try
                    {
                        da.Fill(ds, "ds");
                        cmd.Parameters.Clear();
                    }
                    catch (OracleException ex)
                    {
                        throw new Exception(ex.Message);
                    }
                    finally
                    {
                        if (connection.State != ConnectionState.Closed)
                        {
                            connection.Close();
                        }
                    }
                    return ds;
                }
            }
        }

測試代碼：

 private void button8_Click(object sender, EventArgs e)
        {
            string t_sid = "520";
            string t_sname = "李雲龍";
            string t_age = "100";
            string t_password = "1314";
          
            string sql = "select * from student where sid=:t_sid and sname=:t_sname and sage=:t_age and spass=:t_password";
            OracleParameter[] parameters = {
                new OracleParameter("t_sid ",OracleDbType.Varchar2),
                new OracleParameter("t_sname",OracleDbType.Varchar2),
                new OracleParameter("t_age",OracleDbType.Varchar2),
                new OracleParameter("t_password",OracleDbType.Varchar2)
        };
            parameters[0].Value = t_sid;
            parameters[1].Value = t_sname;
            parameters[2].Value = t_age;
           parameters[3].Value = t_password;
            DataSet ds1 = new DataSet();
            try
            {
                ds1 = QueryWithP(connectionString, sql, parameters);
            }catch(Exception ex){
                textBox1.Text = ex.Message;
            }
            textBox1.Text += "此查詢語句一共查到[" + ds1.Tables[0].Rows.Count.ToString() + "]條記錄！";
            textBox1.Text += "此查詢語句查到[" + ds1.Tables[0].Rows[0]["SNAME"].ToString().Trim() + "]！";
        }

輸出：

 　　把之前的執行變更數據庫內部數據的方法稍作修改！

   public static int ExecuteNonQueryWithP(string connectionString, string SQLString, OracleParameter[] cmdParms)
        {
            using (OracleConnection connection = new OracleConnection(connectionString))
            {
                OracleCommand cmd = new OracleCommand();

                PrepareCommand(cmd, connection, null, SQLString, cmdParms);
                int val = cmd.ExecuteNonQuery();
                cmd.Parameters.Clear();
                return val;
            }
        }

測試代碼:

  private void button9_Click(object sender, EventArgs e)
        {

            string t_sid = "20171116";
            string t_sname = "測試";
            string t_age = "100";
            string t_password = "1314520ln";
            // string sql = "insert into student(SID,SNAME,SAGE,SPASS) values('" + sid + "','" + sname + "','" + age + "','" +password+ "')";
            string sql = "insert into student(SID,SNAME,SAGE,SPASS) values(:t_sid,:t_sname, :t_age,:t_password)";
            OracleParameter[] parameters = {
                new OracleParameter("t_sid ",OracleDbType.Varchar2),
                new OracleParameter("t_sname",OracleDbType.Varchar2),
                new OracleParameter("t_age",OracleDbType.Varchar2),
                new OracleParameter("t_password",OracleDbType.Varchar2)
        };
            parameters[0].Value = t_sid;
            parameters[1].Value = t_sname;
            parameters[2].Value = t_age;
            parameters[3].Value = t_password;
            int i=-1;
            string flag = string.Empty;
            try
            {
                i= ExecuteNonQueryWithP(connectionString, sql, parameters);
            }
            catch (Exception ex)
            {
                textBox1.Text = ex.Message;
            }
            if (i == -1)
            {
                flag = "插入失敗！";
            }
            else {
                flag = "插入成功！";
            }
            textBox1.Text += "插入結果是：[" + flag + "]！";

        }

輸出：

　　之前的方法也都可稍作修改，相必也看到了，本來一句拼接語句，為了躲避拼接的麻煩，但是似乎制造了更大的“麻煩”，一行代碼變成了幾十行代碼，這就是代價。至於值不值，自在個人心中！

其實很多很簡單的方法后面都隱藏了很多東西，為了簡單，往往要付出一定的代價，舉個例子，java中的system.out.println（）；為什么什么都能打印出來嗎？如果去翻看底層代碼，你會發現為了讓你實現system.out.println（）什么都能打印，底層支撐這個方法的代碼至少超過1000行! 再bb一句，java的system.out.println（）的確比c#中Console.WriteLine(" ")吊，支持的更廣！

1.4  OracleDataReader使用　　

　　OracleDataReader一般是用於用來操作多條記錄的，可以用OracleDataReader對一個查詢語句的所有記錄做一個遍歷！OracleDataReader的遍歷要利用它的一些屬性和方法。它的方法和屬性對應表如下：

　　以上來自微軟官網，我挑了幾個重要的方法和屬性進行了嘗試！一些重要的屬性：

　　實現返回OracleDataReader的方法如下：（參數化，傳入數組的可稍作修改！）

  //返回OracleDataReader
        public static OracleDataReader ExecuteReader(string connectionString, string strsql)
        {
            OracleConnection conn = new OracleConnection(connectionString);
            conn.Open();
            OracleCommand cmd = new OracleCommand(strsql, conn);
            try
            {
                //CommandBehavior是一個枚舉類型
                OracleDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
                
                return rdr;
            }
            catch
            {
                conn.Close();
                throw;
            }
        }

測試代碼：

private void button6_Click(object sender, EventArgs e)
        {
            try
            {
                string sql1 = @"select * from student where sid='100' ";
                OracleDataReader odr = ExecuteReader(connectionString, sql1);
                textBox1.Text = odr.GetName(2).ToString()+"---";//返回第三列的列名
                textBox1.Text += odr.HasRows + "---";//返回是否查詢到數據
                textBox1.Text += odr.FieldCount + "---";//返回查詢到結果每行的欄位數
                odr.Close();
            }
            catch (Exception ex)
            {
                textBox1.Text += ex.Message;
            }

        }

輸出：

　　掌握了這舉個簡單的屬性之后，就能完成一些最簡單的業務了，比如遍歷查詢記錄集，也就將查詢到一條或n條數據全顯示出來：

   private void button10_Click(object sender, EventArgs e)
        {
            try
            {
                string sql1 = @"select * from student ";
                OracleDataReader odr = ExecuteReader(connectionString, sql1);

                for (int j = 0; j < odr.FieldCount;j++ ) {
                    textBox1.Text += odr.GetName(j).ToString() + "\t";
                }
                textBox1.Text += "\r\n";
                while(odr.Read()){
                    for(int i=0;i<odr.FieldCount;i++){
                        textBox1.Text += odr[i] + "\t";
                    }
                    textBox1.Text += "\r\n";//換行


                }
                odr.Close();//OracleDataReade用完一定要關閉
            }
            catch (Exception ex)
            {
                textBox1.Text += ex.Message;
            }

        }

輸出：

　　看到這個數據表設置，很自然就想到一定要實現一個登陸的業務了，要實現登陸要不將用戶輸入的sname和spass逐條與數據庫中的記錄集做比對，一旦符合就跳出循環，要不就把SQL語句條件限定死，看是否可以read到數據，即HasRows數據，這個寫沒多大意義。一般比較復雜的業務都有可能涉及到在遍歷中作比較，即第一種方式。實現如下：

 private void button11_Click(object sender, EventArgs e)
        {
            bool flag = false;
              
            if (textBox2.Text == string.Empty || textBox3.Text == string.Empty)
            {
                MessageBox.Show("賬戶和密碼不能為空！");
            }
            else {

                try
                {
                    string sql1 = @"select * from student ";
                    OracleDataReader odr = ExecuteReader(connectionString, sql1);

                    while (odr.Read())
                    {
                        
                    if (odr["sname"].ToString() == textBox2.Text && odr["spass"].ToString() == textBox3.Text) {

                        textBox1.Text= "你好！" + odr["sname"].ToString() + "你今年" + odr["sage"].ToString();
                        flag = true;
                        break;
                        }
                     
                    }
                    if(flag==false){
                        textBox1.Text = "請先注冊！";
                    }
                    flag = false;
                    odr.Close();//OracleDataReade用完一定要關閉
                }
                catch (Exception ex)
                {
                    textBox1.Text += ex.Message;
                }

            
            }

輸出：

　　到此有關c#操作oracle最最基本簡單的操作就結束了，之所以是最最，因為這些只是冰山一角，學會了這些就能完成什么課程設計，畢業設計以及公司的什么實習生級別的業務什么的了！

《暫時 end》