C#访问MySQL（二）：数据插入与修改（增改）
2024-09-08 17:24:48
前言：
前面说了数据库的连接查询，现在说数据库的增删改。这里引入一个数据库的实体类，就是将当前数据库的某一个表里面所有字段写成实体类，如下：
1.数据库的实体类：
需要项目里下载Chloe.dll和Chloe.Mysql.dll,如下：
例如有表如下：
它的实体类就是：
using System;
using Chloe.Entity;
using Chloe.Annotations;
namespace WpfApp1
{
/// <summary>
/// 实体类tb_a。(属性说明自动提取数据库字段的描述信息)
/// </summary>
[TableAttribute("tb_a")]
[Serializable]
public partial class Tb_A
{
#region Model
private int _ID;
private string _Name;
private int? _Age;
private int? _Sex;
/// <summary>
/// ID
/// </summary>
[ColumnAttribute(IsPrimaryKey = true)]
public int ID
{
get { return _ID; }
set
{
this._ID = value;
}
}
/// <summary>
/// 名字
/// </summary>
public string Name
{
get { return _Name; }
set
{
this._Name = value;
}
}
/// <summary>
/// 年龄
/// </summary>
public int? Age
{
get { return _Age; }
set
{
this._Age = value;
}
}
/// <summary>
/// 性别
/// </summary>
public int? Sex
{
get { return _Sex; }
set
{
this._Sex = value;
}
}
#endregion
}
}
2.增加一行数据：
封装一下IDbConnectionFactory。
public class MySqlConnectionFactory : IDbConnectionFactory
{
string _connString = null;
public MySqlConnectionFactory(string connString)
{
this._connString = connString;
}
public IDbConnection CreateConnection()
{
IDbConnection conn = new MySqlConnection(this._connString);
return conn;
}
}
插入一行数据方法：
internal static bool InsertNewData(Tb_A Model, out long lID)
{
MySqlContext context = new MySqlContext(new MySqlConnectionFactory("host = 数据库IP; Port = 数据库端口; Database = 数据库名; uid = 数据库账户; pwd = 数据库密码; Charset = utf8; Allow User Variables = true"));
using (MySqlContext dx = context)
{
IQuery<Tb_A> q = dx.Query<Tb_A>();
lID = dx.Insert<Tb_A>(Model).ID;
return true;
}
}
调用：
private void Button_Click(object sender, RoutedEventArgs e)
{
Tb_A Model = new Tb_A()
{
Age = 18,
Name = "张三",
Sex = 1,
};
long ID = 0;
InsertNewData(Model,out ID);
}
结果：
3.修改某一行数据：
方法：
internal static bool UpdateName(string name,long ID)
{
try
{
MySqlContext context = new MySqlContext(new MySqlConnectionFactory("host = 数据库IP; Port = 数据库端口; Database = 数据库名; uid = 数据库账户; pwd = 数据库密码; Charset = utf8; Allow User Variables = true"));
using (MySqlContext dx = context)
{
return dx.Update<Tb_A>(a => a.ID == ID, a => new Tb_A()
{
Name = name,
}) >= 0;
}
}
catch (Exception)
{
return false;
}
}
调用：
private void Button_Click(object sender, RoutedEventArgs e)
{
Tb_A Model = new Tb_A()
{
Age = 18,
Name = "张三",
Sex = 1,
};
long ID = 1;
UpdateName("李四" , ID);
}
结果：
最新文章
- 数百个 HTML5 例子学习 HT 图形组件 – WebGL 3D 篇
- Saltstack之Syndic（十）
- struts2框架 初始别
- VC++ 限制窗口的大小范围的方法
- JavaScript中的String对象
- Reference in the manifest does not match the identity of the downloaded assembly
- progressBar 自定义
- 基于matlab的GUI界面开发软件
- 浏览器的重绘(repaints)与重排(reflows)
- Js中Array数组学习总结
- Linux 使用 cp 命令强制覆盖功能
- 搭建vue环境
- codeforces570C
- 数字证书及CA的扫盲介绍
- html之间传递参数
- DB2的进程/线程解析（转）
- posix信号量与互斥锁
- MySQL测试报告
- Splunk Web页面的登录密码忘记了怎么办
- php iconv() : Detected an illegal character in input string