C#代码CRUD操作MySQL数据库

首先Program.cs代码如下:

 class Program{static void Main(string[] args){//CrudDemo app = new CrudDemo("localhost", "b2cshop", "root", "123456");//测试连接状态app.TestConnection();app.CreateData();app.ReadData();app.UpdateData(7); app.ReadData();app.DeleteData(8); app.ReadData();app.BulkData();}}

CrudDemo.cs内容如下:

 public class CrudDemo{private string connString;//构造函数 初始化连接字符串public CrudDemo(string server,string database,string uid,string password){connString = string.Format("server={0};database={1};user={2};password={3}", server, database, uid, password);}//测试连接状态public void TestConnection(){try{MySqlConnection conn = new MySqlConnection(connString);conn.Open();Console.WriteLine("Connected");conn.Close();Console.WriteLine("Closed");}catch(MySqlException e){Console.WriteLine("Error: " + e.Message);}}//创建数据public void CreateData(){try{MySqlConnection conn = new MySqlConnection(connString);conn.Open();Console.WriteLine("Connected");string query = "insert into product(name,price,created) values(@name,@price,@created)";MySqlCommand cmd = new MySqlCommand(query, conn);cmd.Parameters.Add("@name", MySqlDbType.VarChar, 45);cmd.Parameters.Add("@price", MySqlDbType.Float);cmd.Parameters.Add("@created", MySqlDbType.DateTime);Console.Write("Inserting 10 data....");DateTime now = DateTime.Now;for (int i = 1; i <= 10;i++ ){cmd.Parameters[0].Value = "product-" + i;cmd.Parameters[1].Value = 0.26 * i;cmd.Parameters[2].Value = now;cmd.ExecuteNonQuery();}Console.WriteLine("Done");conn.Close();Console.WriteLine("Closed");}catch(MySqlException e){Console.WriteLine("Error: " + e.Message);}}//批量增加数据public void BulkData(){try{MySqlConnection conn = new MySqlConnection(connString);conn.Open();Console.WriteLine("Connected");MySqlBulkLoader bulk = new MySqlBulkLoader(conn);bulk.TableName = "product";bulk.FieldTerminator = "\t";bulk.LineTerminator = "\n";bulk.FileName = "D:/product.txt"; bulk.NumberOfLinesToSkip = 0;bulk.Columns.Add("name");bulk.Columns.Add("price");bulk.Columns.Add("created");Console.Write("Inserting bulk data....");int count = bulk.Load();Console.WriteLine("Done-" + count.ToString());conn.Close();Console.WriteLine("Closed");}catch (MySqlException e){Console.WriteLine("Error: " + e.Message);}}//读取数据public void ReadData(){try{MySqlConnection conn = new MySqlConnection(connString);conn.Open();Console.WriteLine("Connected");string query = "select idproduct,name,price,created from product";MySqlCommand cmd = new MySqlCommand(query, conn);MySqlDataReader rd = cmd.ExecuteReader();while(rd.Read()){Console.WriteLine("Id: " + rd["idproduct"].ToString());Console.WriteLine("Name: " + rd["name"].ToString());Console.WriteLine("Price: " + rd["price"].ToString());Console.WriteLine("Created: " + rd["created"].ToString());Console.WriteLine("---------------------------");}rd.Close();conn.Close();Console.WriteLine("Closed");}catch(MySqlException e){Console.WriteLine("Error: " + e.Message);}}//更新数据public void UpdateData(int id){try{MySqlConnection conn = new MySqlConnection(connString);conn.Open();Console.WriteLine("Connected");string query = "update product set name=@name,price=@price where idproduct=@id";MySqlCommand cmd = new MySqlCommand(query, conn);cmd.Parameters.Add("@name", MySqlDbType.VarChar, 45);cmd.Parameters.Add("@price", MySqlDbType.Float);cmd.Parameters.Add("@id", MySqlDbType.Int32);Console.Write("Updating data....");cmd.Parameters[0].Value = "product-update";cmd.Parameters[1].Value = 0.75;cmd.Parameters[2].Value = id;cmd.ExecuteNonQuery();Console.WriteLine("Done");conn.Close();Console.WriteLine("Closed");}catch(MySqlException e){Console.WriteLine("Error: " + e.Message);}}//删除数据public void DeleteData(int id){try{MySqlConnection conn = new MySqlConnection(connString);conn.Open();Console.WriteLine("Connected");string query = "delete from product where idproduct=@id";MySqlCommand cmd = new MySqlCommand(query, conn);cmd.Parameters.Add("@id", MySqlDbType.Int32);Console.Write("Deleting data....");cmd.Parameters[0].Value = id;cmd.ExecuteNonQuery();Console.WriteLine("Done");conn.Close();Console.WriteLine("Closed");}catch (MySqlException e){Console.WriteLine("Error: " + e.Message);}}}

product.txt数据如下:

product10    105 2014-01-09 19:26:30
product11   105 2014-01-09 19:26:30
product12   105 2014-01-09 19:26:30
product13   105 2014-01-09 19:26:30
product14   105 2014-01-09 19:26:30

b2cshop.sql脚步内容:

/*
Navicat MySQL Data TransferSource Server         : localhost_3306
Source Server Version : 50617
Source Host           : localhost:3306
Source Database       : b2cshopTarget Server Type    : MYSQL
Target Server Version : 50617
File Encoding         : 65001Date: 2016-07-31 22:06:36
*/SET FOREIGN_KEY_CHECKS=0;-- ----------------------------
-- Table structure for `product`
-- ----------------------------
DROP TABLE IF EXISTS `product`;
CREATE TABLE `product` (`idproduct` int(11) NOT NULL AUTO_INCREMENT,`name` varchar(200) DEFAULT NULL,`price` float DEFAULT NULL,`created` datetime DEFAULT NULL,PRIMARY KEY (`idproduct`)
) ENGINE=InnoDB AUTO_INCREMENT=16 DEFAULT CHARSET=utf8;-- ----------------------------
-- Records of product
-- ----------------------------
INSERT INTO `product` VALUES ('1', 'product-1', '0.26', '2016-07-30 00:36:02');
INSERT INTO `product` VALUES ('2', 'product-2', '0.52', '2016-07-30 00:36:02');
INSERT INTO `product` VALUES ('3', 'product-3', '0.78', '2016-07-30 00:36:02');
INSERT INTO `product` VALUES ('4', 'product-4', '1.04', '2016-07-30 00:36:02');
INSERT INTO `product` VALUES ('5', 'product-5', '1.3', '2016-07-30 00:36:02');
INSERT INTO `product` VALUES ('6', 'product-6', '1.56', '2016-07-30 00:36:02');
INSERT INTO `product` VALUES ('7', 'product-update', '0.75', '2016-07-30 00:36:02');
INSERT INTO `product` VALUES ('9', 'product-9', '2.34', '2016-07-30 00:36:02');
INSERT INTO `product` VALUES ('10', 'product-10', '2.6', '2016-07-30 00:36:02');
INSERT INTO `product` VALUES ('11', 'product10', '105', '2014-01-09 19:26:30');
INSERT INTO `product` VALUES ('12', 'product11', '105', '2014-01-09 19:26:30');
INSERT INTO `product` VALUES ('13', 'product12', '105', '2014-01-09 19:26:30');
INSERT INTO `product` VALUES ('14', 'product13', '105', '2014-01-09 19:26:30');
INSERT INTO `product` VALUES ('15', 'product14', '105', '2014-01-09 19:26:30');

C#代码CRUD操作MySQL数据库相关推荐

mysql crud操作_c#操作mysql数据库CRUD操作
[实例简介] c#操作mysql数据库 CRUD [实例截图] [核心代码] class SqlHelper { //返回链接数据库的字符串 public static string ConnStri ...
R操作MySQL数据库创建表、删除表、增删改查（CRUD）
R操作MySQL数据库创建表.删除表.增删改查(CRUD) 关系数据中的数据是按照一定范式去存储的.当我们需要非常高级和复杂的Sql查询就可以使用关系数据库的数据资产.不光java和python可以容 ...
MySQL学习笔记03【数据库表的CRUD操作、数据库表中记录的基本操作、客户端图形化界面工具SQLyog】
MySQL 文档-黑马程序员(腾讯微云):https://share.weiyun.com/RaCdIwas 1-MySQL基础.pdf.2-MySQL约束与设计.pdf.3-MySQL多表查询与事务 ...
C语言mysql_ping实例代码_c语言操作mysql数据库(示例代码)
c语言操作Mysql数据库,主要就是为了实现对数据库的增.删.改.查等操作,操作之前,得先连接数据库啊,而连接数据库主要有两种方法.一.使用mysql本身提供的API,在mysql的安装目录中可可以看 ...
php如何操作mysql数据库代码_php如何操作mysql数据库的类（附代码）
这篇文章主要介绍了php简单操作mysql数据库的类,涉及php操作mysql的连接.查询.插入.删除等基本操作方法,非常具有实用价值,需要的朋友可以参考下.<?php /** * Databa ...
php操作mysql数据库的扩展有哪些_8.PHP操作MySQL数据库（Mysqli扩展）
思考:如果数据库的操作都是需要我们手动去调用客户端发送指令,那么这样的操作有什么意义呢? 引入:手动通过客户端操作MySQL数据库,只是我们学习SQL的一种手段.要实现数据库的自动调用,就需要客户端能 ...
js修改mysql数据库数据_Node.js操作mysql数据库增删改查
关于node.js操作mysql数据库的相关介绍请阅读全文吧.下文介绍的非常详细,具体内容如下所示: 安装mysql模块 npm install mysql 数据库准备 mysql server所在的 ...
springboot使用spring-data-jpa操作MySQL数据库
我们在上一篇搭建了一个简单的springboot应用,这一篇将介绍使用spring-data-jpa操作数据库. 新建一个MySQL数据库,这里数据库名为springboot,建立user_info数 ...
Python FastAPI 框架操作Mysql数据库增删改查
2 比 1 更容易理解,可以先看2(单文件级别) 1.FastAPI 框架操作Mysql数据库(项目多文件级别) FastAPI 可以使用任何您想要的关系型数据库. 在这里,让我们看一个使用着SQL ...

C#代码CRUD操作MySQL数据库

C#代码CRUD操作MySQL数据库相关推荐

最新文章

热门文章