initial commit

2026-08-04 14:41:21 +03:00
parent 3cb8fcde60
commit 1a1d6186d8
101 changed files with 23239 additions and 0 deletions
--- a/App_Code/SQLBuilder.cs
+++ b/App_Code/SQLBuilder.cs
@@ -0,0 +1,226 @@
+using Microsoft.Data.SqlClient;
+using System.Text;
+using System.Data;
+using System.Data.SqlTypes;
+
+namespace Library;
+
+public class SQLBuilder
+{
+	private readonly SqlConnection m_DBConnection;
+	private readonly string m_BaseQuery;
+	private readonly string? m_OrderBy;
+	private List<string>? m_Where;
+	private Dictionary<string,object?>? m_Parameters;
+
+	private struct OutputParameter
+	{
+		public OutputParameter( string id , SqlDbType type )
+		{
+			m_ID = id;
+			m_Parameter = new SqlParameter
+			{
+				ParameterName = id ,
+				SqlDbType = type ,
+				Direction = ParameterDirection.Output ,
+			};
+		}
+
+		public string ID
+		{
+			get { return m_ID; }
+		}
+
+		public SqlParameter Parameter
+		{
+			get { return m_Parameter; }
+		}
+
+		private readonly string m_ID;
+		private readonly SqlParameter m_Parameter;
+	}
+	private List<OutputParameter>? m_OutputParameters;
+
+	private int m_ItemsPerPage = 0;
+	private int m_CurrentPage = 0;
+
+	public SQLBuilder( SqlConnection conn , string query , string? order_by = null )
+	{
+		m_DBConnection = conn;
+		m_BaseQuery = query;
+		m_OrderBy = order_by;
+	}
+
+	public SQLBuilder SetPaging( int page , int items_per_page )
+	{
+		m_ItemsPerPage = items_per_page;
+		m_CurrentPage = page;
+		return this;
+	}
+
+	public SQLBuilder AddWhere( string where )
+	{
+		if ( m_Where == null )
+			m_Where = new( );
+		m_Where.Add( where );
+		return this;
+	}
+
+	public SQLBuilder AddClause( string where , string parameter , object value )
+	{
+		AddWhere( where );
+		AddParameter( parameter , value );
+		return this;
+	}
+
+	static private string StripVariable( string input )
+	{
+		StringBuilder result = new( );
+		foreach ( char c in input )
+			if ( char.IsLetterOrDigit( c ) )
+				result.Append( c );
+		return result.ToString( );
+	}
+
+	public SQLBuilder AddLike( string column , string value )
+	{
+		if ( value == null || value.Length <= 0 )
+			return this;
+
+		string[] parts = value.Split( ' ' , System.StringSplitOptions.RemoveEmptyEntries );
+		if ( parts != null && parts.Length > 0 )
+		{
+			int part_index = 0;
+			string variable_prefix = StripVariable( column );
+			foreach ( string p in parts )
+			{
+				string variable = "@" + variable_prefix + (++part_index).ToString( ) + "@";
+				AddClause( column + " LIKE " + variable , variable , "%" + p + "%" );
+			}
+		}
+		return this;
+	}
+
+	public SQLBuilder AddParameter( string name , object? value )
+	{
+		if ( m_Parameters == null )
+			m_Parameters = new( );
+		m_Parameters[name] = value;
+		return this;
+	}
+
+	public SQLBuilder AddOutputParameter( string name , SqlDbType type )
+	{
+		if ( m_OutputParameters == null )
+			m_OutputParameters = new( );
+		m_OutputParameters.Add( new OutputParameter( name , type ) );
+		return this;
+	}
+
+	public object? GetOutputParameter( string name )
+	{
+		if ( m_OutputParameters == null )
+			return null;
+
+		foreach ( OutputParameter p in m_OutputParameters )
+		{
+			if ( p.ID == name )
+				return p.Parameter.Value;
+		}
+
+		return null;
+	}
+
+	public SqlCommand PrepareCommand( )
+	{
+		string sql = m_BaseQuery;
+		if ( m_Where != null && m_Where.Count > 0 )
+		{
+			sql += " WHERE ( " + m_Where[0] + " ) ";
+			for ( int x = 1 ; x < m_Where.Count ; x++ )
+				sql += " AND ( " + m_Where[x] + " ) ";
+		}
+		if ( m_OrderBy != null )
+			sql += " ORDER BY " + m_OrderBy;
+
+		if ( m_ItemsPerPage > 0 )
+			sql += " OFFSET " + ( m_CurrentPage * m_ItemsPerPage ).ToString( ) + " ROWS FETCH FIRST " + m_ItemsPerPage.ToString( ) + " ROWS ONLY";
+
+		SqlCommand command = new( sql , m_DBConnection );
+		command.CommandType = CommandType.Text;
+		if ( m_Parameters != null )
+		{
+			foreach ( var it in m_Parameters )
+			{
+				if ( it.Value != null )
+					command.Parameters.AddWithValue( it.Key , it.Value! );
+				else
+					command.Parameters.AddWithValue( it.Key , System.DBNull.Value );
+			}
+		}
+
+		if ( m_OutputParameters != null )
+		{
+			foreach ( var it in m_OutputParameters )
+				command.Parameters.Add( it.Parameter );
+		}
+
+		return command;
+	}
+
+	public SqlDataReader ExecuteReader( )
+	{
+		return PrepareCommand( ).ExecuteReader( );
+	}
+
+	public int ExecuteNonQuery( )
+	{
+		return PrepareCommand( ).ExecuteNonQuery( );
+	}
+	public int ExecuteAndReadInteger( int on_error_value )
+	{
+		using SqlDataReader reader = ExecuteReader( );
+		if ( reader == null || !reader.Read( ) )
+			return on_error_value;
+
+		SqlInt32 value = reader.GetSqlInt32( 0 );
+		if ( value.IsNull )
+			return on_error_value;
+
+		return value.Value;
+	}
+
+	public int ReadSingleInteger( int on_error_value )
+	{
+		using SqlDataReader reader = ExecuteReader( );
+		if ( reader == null || !reader.Read( ) )
+			return on_error_value;
+
+		SqlInt32 value = reader.GetSqlInt32( 0 );
+		if ( value.IsNull )
+			return on_error_value;
+
+		return value.Value;
+	}
+
+	public string? ReadSingleStringUnsafe( )
+	{
+		using SqlDataReader reader = ExecuteReader( );
+		if ( reader == null || !reader.Read( ) )
+			return null;
+
+		return reader.String( 0 );
+	}
+
+	public string? ReadSingleString( )
+	{
+		try
+		{
+			return ReadSingleStringUnsafe( );
+		}
+		catch ( Exception )
+		{
+			return null;
+		}
+	}
+}