C#连接Oracle查询更新数据

本案例使用的是  using System.Data.OracleClient;方式连接Oracle数据库

private void button1_Click(object sender, EventArgs e)

        {

            string connString = "User ID=***;Password=***;Data Source=(DESCRIPTION = (ADDRESS_LIST= (ADDRESS = (PROTOCOL = TCP)(HOST = 127.0.0.1)(PORT = 1521)))  (CONNECT_DATA =(SERVICE_NAME = ***)))";

            OracleConnection conn = new OracleConnection(connString);

            conn.Open();

             string searchsql = "select * from mbs7_crm.custLoginHis";            

             OracleCommand cmd = new OracleCommand(searchsql, conn);

             cmd.CommandType = CommandType.Text;

             //大容量数据，可以进行修改，使用DataSet和DataAdapter

             DataSet ds = new DataSet();

             OracleDataAdapter da = new OracleDataAdapter();

             da.SelectCommand = cmd;

             da.Fill(ds);

             DataTable dt = new DataTable();

             if (ds != null && ds.Tables.Count > 0)

                 dt = ds.Tables[0];

             if (dt != null && dt.Rows.Count > 0)

             {

                 foreach(DataRow row in dt.Rows)

                 {

                     string encmobile =EncryptHelper.EncryptString( row["phone"].ToString());

                     string encemail = EncryptHelper.EncryptString(row["email"].ToString());

                     string cuscode = row["custcode"].ToString();

                     string sql = string.Format(@"update custLoginHis set encemail ='{0}',encmobile='{1}' where custcode='{2}'", encemail, encmobile, cuscode);

                     cmd = new OracleCommand(sql, conn); 

                     int count=cmd.ExecuteNonQuery();                    

                 }

             }

             conn.Close(); 

        }