using MySql.Data.MySqlClient;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
|
namespace 补片.DAL
|
{
|
public class MySqlSqHelper
|
{
|
/// <summary>
|
/// 连接数据库
|
/// </summary>
|
/// <param name="databasename"></param>
|
/// <returns></returns>
|
private static MySqlConnection GetConnection(string databasename, string ip = "")
|
{
|
try
|
{
|
|
StringBuilder sb = new StringBuilder();
|
#if ZYZ
|
sb.AppendFormat("server={0};","192.168.74.132");
|
sb.AppendFormat("user id={0};", "root");
|
sb.AppendFormat("password={0};", "123456");
|
#else
|
sb.AppendFormat("server={0};", ip == "" ? BuPianBll.ServerIP : ip);
|
sb.AppendFormat("user id={0};", "root");
|
sb.AppendFormat("password={0};", BuPianBll.ServerIP == "127.0.0.1" ? " " : "beibo.123/ ");
|
#endif
|
sb.AppendFormat("persistsecurityinfo={0};", "true");
|
sb.AppendFormat("sslmode={0};", "none");
|
sb.AppendFormat("database={0};", ip == "" ? "sap" + databasename : databasename);
|
MySqlConnection conn = new MySqlConnection(sb.ToString());
|
conn.Open();
|
return conn;
|
}
|
catch (MySqlException e)
|
{
|
//throw new Exception(e.Message);
|
gongchenglog.ShowErrorMessage("无法连接到任何指定的MySQL主机。\r\n请检查与MySQL主机网络连接是否正常。\r\n" + e.Message, "数据库连接提示");
|
return null;
|
}
|
}
|
|
|
|
|
#region
|
/// <summary>
|
/// 执行一句SQL
|
/// </summary>
|
/// <param name="sql"></param>
|
/// <param name="databaseName"></param>
|
/// <returns></returns>
|
public static bool ExecuteSql(string sql, string databaseName)
|
{
|
try
|
{
|
using (MySqlConnection connection = GetConnection(databaseName))
|
{
|
if (connection == null)
|
{
|
return false;
|
}
|
using (MySqlCommand cmd = new MySqlCommand(sql, connection))
|
{
|
int rows = cmd.ExecuteNonQuery();
|
connection.Close();
|
return rows > 0;
|
}
|
|
}
|
}
|
catch (MySqlException e)
|
{
|
throw new Exception(e.Message);
|
}
|
}
|
#endregion
|
|
}
|
}
|
