微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

C# 对mysql 操作的封装

在C#中,可以使用MysqL Connector/Net库来操作MysqL数据库。这个库提供了与MysqL数据库的交互功能,并且可以使用它来封装对MysqL数据库的操作。以下是一个简单的示例:

using System;
using MysqL.Data.MysqLClient;

namespace MysqLExample
{
    public class MysqLHelper
    {
        private string connectionString; // MysqL数据库连接字符串
        
        public MysqLHelper(string server, string database, string username, string password)
        {
            // 构建连接字符串
            connectionString = $"server={server};database={database};uid={username};password={password}";
        }
        
        public void ExecuteNonQuery(string sql)
        {
            using (var connection = new MysqLConnection(connectionString))
            {
                connection.open();
                
                var command = new MysqLCommand(sql, connection);
                command.ExecuteNonQuery();
            }
        }
        
        public object ExecuteScalar(string sql)
        {
            using (var connection = new MysqLConnection(connectionString))
            {
                connection.open();
                
                var command = new MysqLCommand(sql, connection);
                return command.ExecuteScalar();
            }
        }
        
        public MysqLDataReader ExecuteReader(string sql)
        {
            var connection = new MysqLConnection(connectionString);
            connection.open();
            
            var command = new MysqLCommand(sql, connection);
            return command.ExecuteReader(CommandBehavior.CloseConnection);
        }
    }
    
    public class Program
    {
        public static void Main(string[] args)
        {
            var helper = new MysqLHelper("localhost", "mydatabase", "myusername", "mypassword");
            
            // 执行查询
            var reader = helper.ExecuteReader("SELECT * FROM mytable");
            while (reader.Read())
            {
                var column1 = reader.GetString(0);
                var column2 = reader.GetString(1);
                Console.WriteLine($"{column1}, {column2}");
            }
            
            // 执行更新
            helper.ExecuteNonQuery("UPDATE mytable SET column1 = 'newvalue' WHERE id = 1");
            
            // 执行插入,并获取自动生成的ID
            var newId = (int)helper.ExecuteScalar("INSERT INTO mytable (column1, column2) VALUES ('value1', 'value2'); SELECT LAST_INSERT_ID();");
            Console.WriteLine($"New ID: {newId}");
        }
    }
}

在上面的示例中,我们创建了一个名为MysqLHelper的类,它封装了对MysqL数据库的常见操作,如执行查询、执行更新和执行插入。在Main方法中,我们创建了一个MysqLHelper实例,并使用它来执行一些简单的操作。

请注意,示例中的连接字符串是使用serverdatabaseuidpassword参数构建的。你需要将这些参数替换为你自己的MysqL服务器的详细信息。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐