1. 程式人生 > >C# 連線資料庫實現增刪改查

C# 連線資料庫實現增刪改查

 class Program
    {
        private static string urls = "server=127.0.0.1;port=3306;user=root;password=123; database=abc;";
        private MySqlConnection conn;
        
        //獲取連線
        private static MySqlConnection getConnect(){
            return new MySqlConnection(urls);
        }

        
//查詢 public void getUserData(string sql) { conn = getConnect(); conn.Open(); MySqlCommand cmd = new MySqlCommand(sql, conn); //執行ExecuteReader()返回一個MySqlDataReader物件 MySqlDataReader reader = cmd.ExecuteReader(); while
(reader.Read())//初始索引是-1,執行讀取下一行資料,返回值是bool { // Console.WriteLine(reader[0].ToString() + reader[1].ToString() + reader[2].ToString()); // Console.WriteLine(reader.GetInt32(0)+reader.GetString(1)+reader.GetString(2)); Console.WriteLine(reader.GetInt32("
id") + reader.GetString("name") + reader.GetString("password"));//"userid"是資料庫對應的列名,推薦這種方式 } reader.Close(); conn.Close(); } //插入、刪除、更改 public int updateUserData(string sql) { conn = getConnect(); conn.Open(); MySqlCommand cmd = new MySqlCommand(sql,conn); int result = cmd.ExecuteNonQuery(); return result; }
 /*  static void Main(string[] args)
        {

            Program p = new Program();
            string sql = "select *from user";
            p.getUserData(sql);

           string sql1 = "update user set name='chen',password='456' where id='1'";
            int i = p.updateUserData(sql1);
            Console.WriteLine("{0}",i);

           
           

            string sql3 = "delete from user where id='2'";
            int j = p.updateUserData(sql3);
            Console.WriteLine("{0}",j);

            string sql2 = "select *from user";
            p.getUserData(sql2);

            Console.WriteLine("hello world");
            Console.ReadLine();
        }*/
    }