修改SQL工具类

This commit is contained in:
Mili 2023-02-26 01:50:38 +08:00
parent df8ea4a8cc
commit f679c1884e
6 changed files with 27 additions and 102 deletions

View File

@ -8,7 +8,7 @@ namespace Milimoe.FunGame.Core.Api.Data
/// 需要在Server中继承此类实现。 /// 需要在Server中继承此类实现。
/// Milimoe.FunGame.Core.Service.SQLManager也是 /// Milimoe.FunGame.Core.Service.SQLManager也是
/// </summary> /// </summary>
public class SQLHelper : ISQLHelper public abstract class SQLHelper : ISQLHelper
{ {
public string Script { get; set; } = ""; public string Script { get; set; } = "";
@ -18,24 +18,10 @@ namespace Milimoe.FunGame.Core.Api.Data
public SQLResult Result { get; } public SQLResult Result { get; }
public SQLServerInfo ServerInfo { get; } public abstract SQLServerInfo ServerInfo { get; }
public int UpdateRows { get; } public int UpdateRows { get; }
public static SQLHelper GetHelper(EntityType type)
{
return new SQLHelper(type);
}
private SQLHelper(EntityType type = EntityType.Empty, SQLServerInfo? info = null, SQLResult result = SQLResult.Success, int rows = 0)
{
this.EntityType = type;
if (info == null) this.ServerInfo = SQLServerInfo.Create();
else this.ServerInfo = info;
this.Result = result;
this.UpdateRows = rows;
}
public virtual SQLResult Execute() public virtual SQLResult Execute()
{ {
return SQLResult.NotFound; return SQLResult.NotFound;

View File

@ -1,4 +1,5 @@
using Milimoe.FunGame.Core.Library.Constant; using Milimoe.FunGame.Core.Library.Common.Network;
using Milimoe.FunGame.Core.Library.Constant;
namespace Milimoe.FunGame.Core.Interface.Base namespace Milimoe.FunGame.Core.Interface.Base
{ {
@ -9,6 +10,6 @@ namespace Milimoe.FunGame.Core.Interface.Base
public object Entity { get; } public object Entity { get; }
public SQLResult Result { get; } public SQLResult Result { get; }
int UpdateRows { get; } int UpdateRows { get; }
public Library.Common.Network.SQLServerInfo ServerInfo { get; } public SQLServerInfo ServerInfo { get; }
} }
} }

View File

@ -1,84 +1,41 @@
using Milimoe.FunGame.Core.Api.Data; using System.Data;
using Milimoe.FunGame.Core.Library.Constant;
using System.Text; using System.Text;
using Milimoe.FunGame.Core.Api.Data;
using Milimoe.FunGame.Core.Library.Constant;
namespace Milimoe.FunGame.Core.Service namespace Milimoe.FunGame.Core.Service
{ {
/// <summary> /// <summary>
/// 需要在Server中继承此类实现 /// 需要在Server中继承此类实现
/// </summary> /// </summary>
public class SQLManager public abstract class SQLManager
{ {
internal SQLHelper SQLHelper { get; } public SQLHelper? SQLHelper { get; }
internal SQLManager(SQLHelper SQLHelper) public abstract int Add(StringBuilder sql, ref SQLResult result);
{
this.SQLHelper = SQLHelper;
}
protected virtual int Add(StringBuilder sql, ref SQLResult result) public abstract int Add(string sql, ref SQLResult result);
{
return 0;
}
protected virtual int Add(string sql, ref SQLResult result) public abstract SQLResult Execute();
{
return 0;
}
protected virtual SQLResult Execute() public abstract SQLResult Execute(StringBuilder sql);
{
return SQLResult.NotFound;
}
protected virtual SQLResult Execute(StringBuilder sql) public abstract SQLResult Execute(string sql);
{
return SQLResult.NotFound;
}
protected virtual SQLResult Execute(string sql) public abstract DataSet ExecuteDataSet(StringBuilder sql);
{
return SQLResult.NotFound;
}
protected virtual object Query(EntityType type, StringBuilder sql) public abstract DataSet ExecuteDataSet(string sql);
{
return General.EntityInstance;
}
protected virtual T? Query<T>(StringBuilder sql) public abstract object Query(EntityType type, StringBuilder sql);
{
return default;
}
protected virtual object Query(EntityType type, string sql) public abstract object Query(EntityType type, string sql);
{
return General.EntityInstance;
}
protected virtual T? Query<T>(string sql) public abstract int Remove(StringBuilder sql, ref SQLResult result);
{
return default;
}
protected virtual int Remove(StringBuilder sql, ref SQLResult result) public abstract int Remove(string sql, ref SQLResult result);
{
return 0;
}
protected virtual int Remove(string sql, ref SQLResult result) public abstract int Update(StringBuilder sql, ref SQLResult result);
{
return 0;
}
protected virtual int Update(StringBuilder sql, ref SQLResult result) public abstract int Update(string sql, ref SQLResult result);
{
return 0;
}
protected virtual int Update(string sql, ref SQLResult result)
{
return 0;
}
} }
} }

View File

@ -9,24 +9,12 @@ namespace Milimoe.FunGame.Core.Service
/// <summary> /// <summary>
/// 客户端专用Socket /// 客户端专用Socket
/// </summary> /// </summary>
internal static Socket? Socket internal static Socket? Socket => _Socket;
{
get
{
return _Socket;
}
}
/// <summary> /// <summary>
/// 服务器端专用Socket /// 服务器端专用Socket
/// </summary> /// </summary>
internal static Socket? ServerSocket internal static Socket? ServerSocket => _ServerSocket;
{
get
{
return _ServerSocket;
}
}
private static Socket? _Socket = null; private static Socket? _Socket = null;
private static Socket? _ServerSocket = null; private static Socket? _ServerSocket = null;

View File

@ -34,13 +34,7 @@ namespace Milimoe.FunGame.Core.Service
/// </summary> /// </summary>
/// <param name="name">Thread的Key</param> /// <param name="name">Thread的Key</param>
/// <returns>Thread对象</returns> /// <returns>Thread对象</returns>
internal BaseModel this[string name] internal BaseModel this[string name] => Threads[name];
{
get
{
return Threads[name];
}
}
/// <summary> /// <summary>
/// 向线程管理器中添加Thread /// 向线程管理器中添加Thread

View File

@ -329,7 +329,6 @@ namespace Milimoe.FunGame.Desktop.Model
Main.OnFailedConnectEvent(new GeneralEventArgs()); Main.OnFailedConnectEvent(new GeneralEventArgs());
Close(); Close();
} }
return result; return result;
} }