C#连接mysql及相关工具_手机访问mysql数据库工具资源-CSDN文库

共3个文件

txt：1个

exe：1个

msi：1个

3星 · 超过75%的资源需积分: 9 98 浏览量 2011-09-28 17:55:35 上传评论收藏 5.92MB RAR 举报

在IT行业中，C#是一种广泛使用的编程语言，尤其在开发Windows桌面应用、Web应用以及游戏等领域。MySQL则是一款流行的开源关系型数据库管理系统，被许多企业和开发者用于存储和管理数据。当我们需要用C#来连接和操作MySQL数据库时，就需要了解相关的技术和工具。下面将详细介绍这个主题。 1. **C#与MySQL的连接基础** - ADO.NET：C#通过ADO.NET（数据访问对象）框架与数据库进行交互，它提供了DataSet、DataTable、SqlCommand等类来执行SQL语句和处理结果。 - MySqlConnection类：这是C#中用于连接MySQL数据库的主要类，需要提供服务器地址、用户名、密码和数据库名等信息。 2. **连接字符串** 在C#中建立MySQL连接，你需要创建一个MySqlConnection对象，并传入包含数据库连接信息的连接字符串。例如： ```csharp string connectionString = "Server=myServerAddress;Database=myDataBase;User Id=myUsername;Password=myPassword;"; MySqlConnection connection = new MySqlConnection(connectionString); ``` 3. **打开和关闭连接** 使用`Open()`方法打开连接，`Close()`或`Dispose()`方法关闭和释放资源。 4. **执行SQL语句** - `SqlCommand`类用于执行SQL命令，例如查询、插入、更新和删除数据。 - `ExecuteReader()`用于执行查询并返回DataReader对象，可遍历结果集。 - `ExecuteNonQuery()`用于执行不返回结果集的SQL命令，如INSERT、UPDATE和DELETE。 5. **数据填充与数据操作** - `MySqlDataAdapter`与`DataSet`配合，可以从数据库填充数据集，或者通过数据集更新数据库。 - `DataTable`和`DataRow`类用于在内存中操作数据。 6. **事务处理** 对于多条数据库操作，可以使用`BeginTransaction()`开始事务，`Commit()`提交事务，`Rollback()`回滚事务，确保数据一致性。 7. **相关工具** - MySQL Connector/NET：这是MySQL官方提供的C#驱动程序，允许C#应用程序与MySQL数据库无缝连接。 - Visual Studio集成：在Visual Studio中，可以通过服务器资源管理器直接连接到MySQL数据库，进行设计查询和数据操作。 - Entity Framework：一种ORM（对象关系映射）工具，简化了C#与数据库的交互，允许开发者使用面向对象的方式来操作数据。 8. **安全性与性能优化** - 参数化查询：防止SQL注入攻击，提高代码可读性。 - 连接池：通过重用已打开的连接，减少创建和销毁连接的开销。 - 使用预编译的SQL语句（PreparedStatement）提升执行效率。 9. **错误处理** 编程时应考虑异常处理，例如使用try-catch-finally块捕获和处理MySqlException。 10. **最佳实践** - 完成操作后立即关闭数据库连接，避免资源浪费。 - 使用连接池，减少数据库连接创建和销毁的次数。 - 适当优化SQL查询，避免全表扫描。以上是C#连接MySQL的基础知识，实际开发中还需要根据项目需求，灵活运用这些技术，结合设计模式和框架，如MVC、MVVM等，构建高效、稳定的数据库应用程序。在学习和实践中，不断积累经验，才能更好地驾驭这个领域。

资源推荐

资源详情

资源评论

收起资源包目录

MySql使用相关.rar （3个子文件）

MySql使用相关

MyODBC-3.51.11-2-win.exe 7.21MB

odbc_net.msi 875KB

C#连接MySql.txt 5KB

1.连接: 1.安装Microsoft ODBC.net。 2.安装MySQL的ODBC驱动程序。 2.解决方案管理中添加引用Microsoft.Data.Odbc.dll(1.0.3300) 3.代码中增加引用 using Microsoft.Data.Odbc; 4.编写代码 string MyConString = "DRIVER={MySQL ODBC 3.51 Driver};" + "SERVER=localhost;" + "DATABASE=samp_db;" + "UID=root;" + "PASSWORD=;" + "OPTION=3"; //Connect to MySQL using Connector/ODBC OdbcConnection MyConnection = new OdbcConnection(MyConString); MyConnection.Open(); Console.WriteLine("\n !!! success, connected successfully !!!\n"); MyConnection.Close(); 2.全部例程: /** * @sample : mycon.cs * @purpose : Demo sample for ODBC.NET using Connector/ODBC * @author : Venu, venu@mysql.com * * (C) Copyright MySQL AB, 1995-2003 * **/ /* build command * * csc /t:exe * /out:mycon.exe mycon.cs * /r:Microsoft.Data.Odbc.dll */ using Console = System.Console; using Microsoft.Data.Odbc; namespace myodbc3 { class mycon { static void Main(string[] args) { try { //Connection string for Connector/ODBC 2.50 /*string MyConString = "DRIVER={MySQL};" + "SERVER=localhost;" + "DATABASE=test;" + "UID=venu;" + "PASSWORD=venu;" + "OPTION=3"; */ //Connection string for Connector/ODBC 3.51 string MyConString = "DRIVER={MySQL ODBC 3.51 Driver};" + "SERVER=localhost;" + "DATABASE=test;" + "UID=venu;" + "PASSWORD=venu;" + "OPTION=3"; //Connect to MySQL using Connector/ODBC OdbcConnection MyConnection = new OdbcConnection(MyConString); MyConnection.Open(); Console.WriteLine("\n !!! success, connected successfully !!!\n"); //Display connection information Console.WriteLine("Connection Information:"); Console.WriteLine("\tConnection String:" + MyConnection.ConnectionString); Console.WriteLine("\tConnection Timeout:" + MyConnection.ConnectionTimeout); Console.WriteLine("\tDatabase:" + MyConnection.Database); Console.WriteLine("\tDataSource:" + MyConnection.DataSource); Console.WriteLine("\tDriver:" + MyConnection.Driver); Console.WriteLine("\tServerVersion:" + MyConnection.ServerVersion); //Create a sample table OdbcCommand MyCommand = new OdbcCommand("DROP TABLE IF EXISTS my_odbc_net",MyConnection); MyCommand.ExecuteNonQuery(); MyCommand.CommandText = "CREATE TABLE my_odbc_net(id int, name varchar(20), idb bigint)"; MyCommand.ExecuteNonQuery(); //Insert MyCommand.CommandText = "INSERT INTO my_odbc_net VALUES(10,'venu', 300)"; Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery());; //Insert MyCommand.CommandText = "INSERT INTO my_odbc_net VALUES(20,'mysql',400)"; Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery()); //Insert MyCommand.CommandText = "INSERT INTO my_odbc_net VALUES(20,'mysql',500)"; Console.WriteLine("INSERT, Total rows affected:" + MyCommand.ExecuteNonQuery()); //Update MyCommand.CommandText = "UPDATE my_odbc_net SET id=999 WHERE id=20"; Console.WriteLine("Update, Total rows affected:" + MyCommand.ExecuteNonQuery()); //COUNT(*) MyCommand.CommandText = "SELECT COUNT(*) as TRows FROM my_odbc_net"; Console.WriteLine("Total Rows:" + MyCommand.ExecuteScalar()); //Fetch MyCommand.CommandText = "SELECT * FROM my_odbc_net"; OdbcDataReader MyDataReader; MyDataReader = MyCommand.ExecuteReader(); while (MyDataReader.Read()) { if(string.Compare(MyConnection.Driver,"myodbc3.dll") == 0) { Console.WriteLine("Data:" + MyDataReader.GetInt32(0) + " " + MyDataReader.GetString(1) + " " + MyDataReader.GetInt64(2)); //Supported only by Connector/ODBC 3.51 } else { Console.WriteLine("Data:" + MyDataReader.GetInt32(0) + " " + MyDataReader.GetString(1) + " " + MyDataReader.GetInt32(2)); //BIGINTs not supported by Connector/ODBC } } //Close all resources MyDataReader.Close(); MyConnection.Close(); } catch (OdbcException MyOdbcException)//Catch any ODBC exception .. { for (int i=0; i < MyOdbcException.Errors.Count; i++) { Console.Write("ERROR #" + i + "\n" + "Message: " + MyOdbcException.Errors[i].Message + "\n" + "Native: " + MyOdbcException.Errors[i].NativeError.ToString() + "\n" + "Source: " + MyOdbcException.Errors[i].Source + "\n" + "SQL: " + MyOdbcException.Errors[i].SQLState + "\n"); } } } } } 3.使用dataset填充dataGrid: OdbcConnection con = new OdbcConnection("DRIVER={MySQL ODBC 3.51 Driver};" + "SERVER=glf;" + "DATABASE=qxk_db;" + "UID=root;" + "PASSWORD=;" + "OPTION=3"); da=new OdbcDataAdapter("select * from achi_eval",con); ds=new DataSet(); da.Fill(ds,"customers"); dtSource = ds.Tables["customers"]; pageSize=20; maxRec = dtSource.Rows.Count; PageCount = maxRec / pageSize; if ((maxRec % pageSize) > 0) { PageCount += 1; } currentPage = 1; recNo = 0; LoadPage(); 这是前一段需要用到,精选了一些资料,希望对大家有帮助.

评论收藏

内容反馈