操作 MySql 數(shù)據(jù)庫使用MySql.Data程序包(MySql 開發(fā)，其他第三方可能會有些問題)。

project.json 代碼：

{

"version": "1.0.0-*",

"buildOptions": {

"emitEntryPoint": true

},

"dependencies": {

"Microsoft.NETCore.App": {

"type": "platform",

"version": "1.0.1"

},

"Dapper": "1.50.2",

"MySql.Data": "7.0.6-IR31"

},

"frameworks": {

"netcoreapp1.0": {

"imports": "dnxcore50"

}

}

}

測試數(shù)據(jù)庫腳本：

CREATE TABLE `products` (

`ProductID` int(11) NOT NULL AUTO_INCREMENT,

`Name` varchar(255) DEFAULT NULL,

`Quantity` int(11) DEFAULT NULL,

`Price` int(11) DEFAULT NULL,

PRIMARY KEY (`ProductID`)

) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=gbk;

Product 代碼：

public class Product

{

[Key]

public int ProductId { get; set; }

public string Name { get; set; }

public int Quantity { get; set; }

public double Price { get; set; }

}

ProductRepository 代碼(數(shù)據(jù)訪問操作)：

public class ProductRepository

{

private string connectionString;

public ProductRepository()

{

connectionString = @"server=localhost;database=dapperdemo;uid=root;pwd=123456;";

}

public IDbConnection Connection

{

get

{

return new MySqlConnection(connectionString);

}

}

public void Add(Product prod)

{

using (IDbConnection dbConnection = Connection)

{

string sQuery = "INSERT INTO Products (Name, Quantity, Price)"

+ " VALUES(@Name, @Quantity, @Price)";

dbConnection.Open();

dbConnection.Execute(sQuery, prod);

}

}

public IEnumerable GetAll()

{

using (IDbConnection dbConnection = Connection)

{

dbConnection.Open();

return dbConnection.Query("SELECT * FROM Products");

}

}

public Product GetByID(int id)

{

using (IDbConnection dbConnection = Connection)

{

string sQuery = "SELECT * FROM Products"

+ " WHERE ProductId = @Id";

dbConnection.Open();

return dbConnection.Query(sQuery, new { Id = id }).FirstOrDefault();

}

}

public void Delete(int id)

{

using (IDbConnection dbConnection = Connection)

{

string sQuery = "DELETE FROM Products"

+ " WHERE ProductId = @Id";

dbConnection.Open();

dbConnection.Execute(sQuery, new { Id = id });

}

}

public void Update(Product prod)

{

using (IDbConnection dbConnection = Connection)

{

string sQuery = "UPDATE Products SET Name = @Name,"

+ " Quantity = @Quantity, Price= @Price"

+ " WHERE ProductId = @ProductId";

dbConnection.Open();

dbConnection.Execute(sQuery, prod);

}

}

public void TransactionTest()

{

using (IDbConnection dbConnection = Connection)

{

string sQuery = "UPDATE Products SET Name = 'xishuai222'"

+ " WHERE ProductId = 1";

dbConnection.Open();

using (var transaction = dbConnection.BeginTransaction())

{

dbConnection.Execute(sQuery);

///to do throw exception

transaction.Commit();

}

}

}

}

調(diào)用代碼：

public class Program

{

public static void Main(string[] args)

{

var productRepository = new ProductRepository();

var product = new Product() { Name = "xishuai" };

productRepository.Add(product);

var products = productRepository.GetAll();

foreach (var item in products)

{

Console.WriteLine($"id: {item.ProductId}; name: {item.Name}");

}

productRepository.TransactionTest();

Console.ReadKey();

}

}

參考資料：

《新程序員》：云原生和全面數(shù)字化實(shí)踐50位技術(shù)專家共同創(chuàng)作，文字、視頻、音頻交互閱讀

總結(jié)

以上是生活随笔為你收集整理的asp.net mysql 事务_ASP.NET Core 1.0 使用 Dapper 操作 MySql（包含事务）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。