- A+
所属分类：.NET技术
今天数据库实验是“掌握数据库应用开发的一般方法”，开发环境是vs（我这里用的是19版）
一、准备
- 操作环境：win7以上
- DBMS：MySQL 5.5
- 开发环境：vs19（12及以上都可以）
二、建立工程项目
新建工程后默认模板
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Data; using MySql.Data.MySqlClient; namespace LiwkerApp { class Program { static void Main(string[] args) { } } } 后面就不多说了，一定要先导入程序包，再安装
三、实验
1.随机查询一个学生
static void Main(string[] args) { //定义好功能函数后，在main调用 //show(); //delOne(); //Find(); //showAll(); //addOne1(); } 代码
//显示学生的函数 static void show() { // 定义一个连接到数据库的字符串 // 这里连接的是本地服务器(localhost),登录用户名是root，有密码就加 string conStr = "server=localhost;user=root;database=Liwker;password=1110"; // 定义一个数据库连接对象con,可以理解它是连接程序连接数据库的通道 // 这里表明用上面的连接串来建立与目标数据库的连接 MySqlConnection con = new MySqlConnection(conStr); // 连接到数据库,即通常所说的打开数据库 // 注意如果运行时在这里报错,要么是服务器没启动 // 要么就是前面的 conStr中的连接信息写错了! con.Open(); // 定义一个S0L命令对象,用于存储给服务器发送的SQL命令及参数等信息 MySqlCommand cmd = new MySqlCommand(); // 该SQL命令对象通过con连接到我们的数据库 cmd.Connection = con; // 该SQL命令对象将向服务器发送命令字符串,当然可以使用存储过程等其它类型 cmd.CommandType = System.Data.CommandType.Text; // 编制将要执行的SQL命令,这里命令的功能是随机取回一名学生的姓名和性别 cmd.CommandText = "select * from student order by rand() limit 1;"; // 定义一个基于cmd的数据适配器,它专用于接收cmd命令执行后的结果 MySqlDataAdapter adapter = new MySqlDataAdapter(cmd); // 定义一个数据集，相当于表的集合, 用于接收SQL命令对象执行后的结果 DataSet ds = new DataSet(); // 用适配器执行命令来填充ds数据集,即将取回的数据装入ds adapter.Fill(ds); // 这个方法是有返回值的，返回装入的行数 // 前面的SQL命令成功取回 学生的信息后会放入ds的tables[0]表的rows[0]行 // 没有的话，则tables[0]表的rows的行数为0 if (ds.Tables[0].Rows.Count > 0) { System.Console.WriteLine("学号: {0}", ds.Tables[0].Rows[0]["学号"]); // 显示返回的姓名 System.Console.WriteLine("姓名: {0}", ds.Tables[0].Rows[0]["姓名"]); // 显示返回的性别 System.Console.WriteLine("性别: {0}", ds.Tables[0].Rows[0]["性别"]); System.Console.WriteLine("年龄: {0}", ds.Tables[0].Rows[0]["年龄"]); System.Console.WriteLine("系别: {0}", ds.Tables[0].Rows[0]["系别"]); } else { System.Console.WriteLine("目前还没有学生！"); } // 命令用完了,记得关闭连接,以便服务器更好地为其它连接服务 con.Close(); } 结果
2.删除学生
代码
// 通过学号删除一个学生 static void delOne() { string who; // 存储查找的学号 Console.Write("删除者学号："); //输出提示信息 who = Console.ReadLine(); //接受键盘输入 // 任何数据库操作，其连接数据库以及SQL命令的准备都是一样的，所以可以直接用下面的 string conStr = "server=localhost;user=root;database=Liwker;password=1110"; MySqlConnection con = new MySqlConnection(conStr); con.Open(); MySqlCommand cmd = new MySqlCommand(); cmd.Connection = con; cmd.CommandType = System.Data.CommandType.Text; // 编辑发出给服务器的删除学生的SQL命令，其中@xh是一个参数 cmd.CommandText = "delete from student where 学号=@xh"; //提供命令所需要的参数，这里提供刚才输入的学号 cmd.Parameters.AddWithValue("@xh", who); //非查询类的SQL命令的执行用以下方法，返回1 代表成功，0则失败 int r = cmd.ExecuteNonQuery(); if(r == 1) { System.Console.WriteLine("删除成功！"); } else { System.Console.WriteLine("删除失败，也可能是根本没有此人！"); } // 命令用完了,记得关闭连接,以便服务器更好地为其它连接服务 con.Close(); } //通过学号查询一个学生的信息 static void Find() { string who; Console.Write("请输入学号查询："); who = Console.ReadLine(); string conStr = "server=localhost;user=root;database=Liwker;password=1110"; // 连接数据库的字符串 MySqlConnection con = new MySqlConnection(conStr); // 定义一个数据库新链接 con.Open(); // 打开数据库 MySqlCommand cmd = new MySqlCommand(); // 定义一个新SQL命令 cmd.Connection = con; // SQL命令链接到数据库 cmd.CommandType = System.Data.CommandType.Text; // 发送命令字符串 cmd.CommandText = "select * from student where 学号=@xh;"; // 写入SQL命令字符串 cmd.Parameters.AddWithValue("@xh", who); // 替换参数 MySqlDataAdapter adapter = new MySqlDataAdapter(cmd); // 定义一个接受cmd对象执行结果的数据适配器 DataSet ds = new DataSet(); // 定义一个接受SQL对象执行结果的数据集 adapter.Fill(ds); // 将适配器里的数据装入ds if (ds.Tables[0].Rows.Count > 0) { System.Console.WriteLine("学号: {0}", ds.Tables[0].Rows[0]["学号"]); System.Console.WriteLine("姓名: {0}", ds.Tables[0].Rows[0]["姓名"]); System.Console.WriteLine("性别: {0}", ds.Tables[0].Rows[0]["性别"]); System.Console.WriteLine("年龄: {0}", ds.Tables[0].Rows[0]["年龄"]); System.Console.WriteLine("系别: {0}", ds.Tables[0].Rows[0]["系别"]); } else { System.Console.WriteLine("查无此人！"); } con.Close(); } 结果
3.查询所有学生信息
代码
// 查询所有学生的信息 static void showAll() { string conStr = "server=localhost;user=root;database=Liwker;password=1110"; MySqlConnection con = new MySqlConnection(conStr); con.Open(); MySqlCommand cmd = new MySqlCommand(); cmd.Connection = con; cmd.CommandType = System.Data.CommandType.Text; cmd.CommandText = "select * from student;"; MySqlDataAdapter adapter = new MySqlDataAdapter(cmd); DataSet ds = new DataSet(); adapter.Fill(ds); // 利用循环来遍历所有的行（学生） for (int i = 0; i < ds.Tables[0].Rows.Count; i++) { System.Console.WriteLine("学号: {0}", ds.Tables[0].Rows[i]["学号"]); System.Console.WriteLine("姓名: {0}", ds.Tables[0].Rows[i]["姓名"]); System.Console.WriteLine("性别: {0}", ds.Tables[0].Rows[i]["性别"]); System.Console.WriteLine("年龄: {0}", ds.Tables[0].Rows[i]["年龄"]); System.Console.WriteLine("系别: {0}", ds.Tables[0].Rows[i]["系别"]); System.Console.WriteLine("n"); } con.Close(); } 结果
4.查询单个学生
代码
//通过学号查询一个学生的信息 static void Find() { string who; Console.Write("请输入学号查询："); who = Console.ReadLine(); string conStr = "server=localhost;user=root;database=Liwker;password=1110"; // 连接数据库的字符串 MySqlConnection con = new MySqlConnection(conStr); // 定义一个数据库新链接 con.Open(); // 打开数据库 MySqlCommand cmd = new MySqlCommand(); // 定义一个新SQL命令 cmd.Connection = con; // SQL命令链接到数据库 cmd.CommandType = System.Data.CommandType.Text; // 发送命令字符串 cmd.CommandText = "select * from student where 学号=@xh;"; // 写入SQL命令字符串 cmd.Parameters.AddWithValue("@xh", who); // 替换参数 MySqlDataAdapter adapter = new MySqlDataAdapter(cmd); // 定义一个接受cmd对象执行结果的数据适配器 DataSet ds = new DataSet(); // 定义一个接受SQL对象执行结果的数据集 adapter.Fill(ds); // 将适配器里的数据装入ds if (ds.Tables[0].Rows.Count > 0) { System.Console.WriteLine("学号: {0}", ds.Tables[0].Rows[0]["学号"]); System.Console.WriteLine("姓名: {0}", ds.Tables[0].Rows[0]["姓名"]); System.Console.WriteLine("性别: {0}", ds.Tables[0].Rows[0]["性别"]); System.Console.WriteLine("年龄: {0}", ds.Tables[0].Rows[0]["年龄"]); System.Console.WriteLine("系别: {0}", ds.Tables[0].Rows[0]["系别"]); } else { System.Console.WriteLine("查无此人！"); } con.Close(); } 结果
5.新增一个学生
方法一
// 新增学生（方法一） // 有点缺陷，因为学号属性是固定的5个字符，这里就用了 if 来判断比较（所以查出来的有空格） // 例如：输入“S02”是找不到的，必须输入“S02 ” static void addOne() { string xh, name, sex, age, xb, sg; // 声明接收学生信息的不同字符串 Console.Write("新增者n学号："); xh = Console.ReadLine(); // 先输入学号，以便判断是否有重复 // 连接数据库 string conStr = "server=localhost;user=root;database=Liwker;password=1110"; MySqlConnection con = new MySqlConnection(conStr); con.Open(); MySqlCommand cmd = new MySqlCommand(); cmd.Connection = con; cmd.CommandType = System.Data.CommandType.Text; // 先获取已有的学生的学号 cmd.CommandText = "select 学号 from student"; MySqlDataAdapter adapter = new MySqlDataAdapter(cmd); DataSet ds = new DataSet(); adapter.Fill(ds); // 学号重复判断 for(int i = 0; i < ds.Tables[0].Rows.Count; i++) { if (xh == (string)ds.Tables[0].Rows[i]["学号"]) //加string强制转换 { Console.Write("此学号已存在，请重新输入：n"); xh = Console.ReadLine(); i = -1; } } Console.Write("姓名："); name = Console.ReadLine(); Console.Write("性别："); sex = Console.ReadLine(); Console.Write("年龄："); age = Console.ReadLine(); Console.Write("系别："); xb = Console.ReadLine(); Console.Write("身高："); sg = Console.ReadLine(); // 定义SQL插入命令 cmd.CommandText = "insert into student values(@xh,@name,@sex,@age,@xb,@sg)"; cmd.Parameters.AddWithValue("@xh", xh); cmd.Parameters.AddWithValue("@name", name); cmd.Parameters.AddWithValue("@sex", sex); cmd.Parameters.AddWithValue("@age", age); cmd.Parameters.AddWithValue("@xb", xb); cmd.Parameters.AddWithValue("@sg", sg); int r = cmd.ExecuteNonQuery(); // 非查询类SQL命令的返回（0 或 1） if (r == 1) { System.Console.WriteLine("新增成功！"); } else { System.Console.WriteLine("新增失败！"); } con.Close(); } 方法二
// 新增学生（方法二） // 此方法就不存在空格问题 // 每输入学号就会运行SQL查看有没有重复的 static void addOne1() { string xh, name, sex, age, xb, sg; int f = 0; // 定义一个标志，以便后面判断重复 Console.Write("新增者n学号："); xh = Console.ReadLine(); // 连接数据库 string conStr = "server=localhost;user=root;database=Liwker;password=1110"; MySqlConnection con = new MySqlConnection(conStr); con.Open(); // 学号重复判断 do { // 先来判断是否有重复 if (f != 0) { Console.Write("此学号已存在，请重新输入：n"); xh = Console.ReadLine(); } // 定义一个新的SQL命令 MySqlCommand cmd1 = new MySqlCommand(); cmd1.Connection = con; cmd1.CommandType = System.Data.CommandType.Text; // 定义查询这个学号是否重复的SQL命令 cmd1.CommandText = "select * from student where 学号=@xh"; cmd1.Parameters.AddWithValue("@xh", xh); MySqlDataAdapter adapter = new MySqlDataAdapter(cmd1); DataSet ds = new DataSet(); f = adapter.Fill(ds); // f接受行数，0为没有，n为有n行数据 } while (f > 0); // 一直循环到没有重复为止 Console.Write("姓名："); name = Console.ReadLine(); Console.Write("性别："); sex = Console.ReadLine(); Console.Write("年龄："); age = Console.ReadLine(); Console.Write("系别："); xb = Console.ReadLine(); Console.Write("身高："); sg = Console.ReadLine(); MySqlCommand cmd = new MySqlCommand(); cmd.Connection = con; cmd.CommandType = System.Data.CommandType.Text; // 定义SQL插入命令 cmd.CommandText = "insert into student values(@xh,@name,@sex,@age,@xb,@sg)"; cmd.Parameters.AddWithValue("@xh", xh); cmd.Parameters.AddWithValue("@name", name); cmd.Parameters.AddWithValue("@sex", sex); cmd.Parameters.AddWithValue("@age", age); cmd.Parameters.AddWithValue("@xb", xb); cmd.Parameters.AddWithValue("@sg", sg); int r = cmd.ExecuteNonQuery(); // 非查询类SQL命令的返回（0 或 1） if (r == 1) { System.Console.WriteLine("n新增成功！"); } else { System.Console.WriteLine("n新增失败！"); } con.Close(); } 结果
