using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MySqlConnector;
namespace BarCode.Web.Repositories
{
    public class MySqlDataAccess
    {
        private readonly string _connectionString;

        public MySqlDataAccess(string connectionString)
        {
            _connectionString = connectionString;
        }

        /// <summary>
        /// 执行查询并返回 DataTable
        /// </summary>
        /// <param name="query">SQL 查询语句</param>
        /// <returns>查询结果的 DataTable</returns>
        public DataTable ExecuteQuery(string query)
        {
            using (MySqlConnection connection = new MySqlConnection(_connectionString))
            {
                try
                {
                    connection.Open();
                    MySqlCommand command = new MySqlCommand(query, connection);
                    MySqlDataAdapter adapter = new MySqlDataAdapter(command);
                    DataTable dataTable = new DataTable();
                    adapter.Fill(dataTable);
                    return dataTable;
                }
                catch (Exception ex)
                {
                    Console.WriteLine($"查询出错: {ex.Message}");
                    return null;
                }
            }
        }

        /// <summary>
        /// 执行非查询操作（如 INSERT、UPDATE、DELETE）
        /// </summary>
        /// <param name="query">SQL 非查询语句</param>
        /// <returns>受影响的行数</returns>
        public int ExecuteNonQuery(string query)
        {
            using (MySqlConnection connection = new MySqlConnection(_connectionString))
            {
                try
                {
                    connection.Open();
                    MySqlCommand command = new MySqlCommand(query, connection);
                    return command.ExecuteNonQuery();
                }
                catch (Exception ex)
                {
                    Console.WriteLine($"执行非查询操作出错: {ex.Message}");
                    return -1;
                }
            }
        }
    }
}