提供了编程的基础技术教程

zl程序教程

您现在的位置是：首页 >  数据库

当前栏目

C#操作mysql数据库的代码实例

mysqlc#实例数据库代码 操作
2023-06-13 09:15:12 时间

直接看代码

复制代码代码如下:

usingSystem;
usingSystem.Configuration;
usingMySql.Data.MySqlClient;
///<summary>
///TestDatebase的摘要说明
///</summary>
publicclassTestDatebase
{
   publicTestDatebase()
   {
       //
       //TODO:在此处添加构造函数逻辑
       //
   }
   publicstaticvoidMain(String[]args)
   {
       MySqlConnectionmysql=getMySqlCon();
       //查询sql
       StringsqlSearch="select*fromstudent";
       //插入sql
       StringsqlInsert="insertintostudentvalues(12,"张三",25,"大专")";
       //修改sql
       StringsqlUpdate="updatestudentsetname="李四"whereid=3";
       //删除sql
       StringsqlDel="deletefromstudentwhereid=12";
       //打印SQL语句
       Console.WriteLine(sqlDel);
       //四种语句对象
       //MySqlCommandmySqlCommand=getSqlCommand(sqlSearch,mysql);
       //MySqlCommandmySqlCommand=getSqlCommand(sqlInsert,mysql);
       //MySqlCommandmySqlCommand=getSqlCommand(sqlUpdate,mysql);
       MySqlCommandmySqlCommand=getSqlCommand(sqlDel,mysql);
       mysql.Open();
       //getResultset(mySqlCommand);
       //getInsert(mySqlCommand);
       //getUpdate(mySqlCommand);
       getDel(mySqlCommand);
       //记得关闭
       mysql.Close();
      StringreadLine=Console.ReadLine();
   }
   ///<summary>
   ///建立mysql数据库链接
   ///</summary>
   ///<returns></returns>
   publicstaticMySqlConnectiongetMySqlCon()
   {
       StringmysqlStr="Database=test;DataSource=127.0.0.1;UserId=root;Password=root;pooling=false;CharSet=utf8;port=3306";
       //StringmySqlCon=ConfigurationManager.ConnectionStrings["MySqlCon"].ConnectionString;
       MySqlConnectionmysql=newMySqlConnection(mysqlStr);
       returnmysql;
   }
   ///<summary>
   ///建立执行命令语句对象
   ///</summary>
   ///<paramname="sql"></param>
   ///<paramname="mysql"></param>
   ///<returns></returns>
   publicstaticMySqlCommandgetSqlCommand(Stringsql,MySqlConnectionmysql)
   {
       MySqlCommandmySqlCommand=newMySqlCommand(sql,mysql);
       // MySqlCommandmySqlCommand=newMySqlCommand(sql);
       //mySqlCommand.Connection=mysql;
       returnmySqlCommand;
   }
   ///<summary>
   ///查询并获得结果集并遍历
   ///</summary>
   ///<paramname="mySqlCommand"></param>
   publicstaticvoidgetResultset(MySqlCommandmySqlCommand)
   {
       MySqlDataReaderreader=mySqlCommand.ExecuteReader();
       try
       {
           while(reader.Read())
           {
               if(reader.HasRows)
               {
                   Console.WriteLine("编号:"+reader.GetInt32(0)+"|姓名:"+reader.GetString(1)+"|年龄:"+reader.GetInt32(2)+"|学历:"+reader.GetString(3));
               }
           }
       }
       catch(Exception)
       {

           Console.WriteLine("查询失败了！");
       }
       finally
       {
           reader.Close();
       }
   }
   ///<summary>
   ///添加数据
   ///</summary>
   ///<paramname="mySqlCommand"></param>
   publicstaticvoidgetInsert(MySqlCommandmySqlCommand)
   {
       try
       {
           mySqlCommand.ExecuteNonQuery();
       }
       catch(Exceptionex)
       {
           Stringmessage=ex.Message;
           Console.WriteLine("插入数据失败了！"+message);
       }

   }
   ///<summary>
   ///修改数据
   ///</summary>
   ///<paramname="mySqlCommand"></param>
   publicstaticvoidgetUpdate(MySqlCommandmySqlCommand)
   {
       try
       {
           mySqlCommand.ExecuteNonQuery();
       }
       catch(Exceptionex)
       {

           Stringmessage=ex.Message;
           Console.WriteLine("修改数据失败了！"+message);
       }
   }
   ///<summary>
   ///删除数据
   ///</summary>
   ///<paramname="mySqlCommand"></param>
   publicstaticvoidgetDel(MySqlCommandmySqlCommand)
   {
       try
       {
           mySqlCommand.ExecuteNonQuery();
       }
       catch(Exceptionex)
       {
           Stringmessage=ex.Message;
           Console.WriteLine("删除数据失败了！"+message);
       }
   }
}

相关文章