sqljourneldb.cs

来自「《精通ASP.NET2.0网络应用系统开发》书中的源码」· CS 代码 · 共 390 行

CS
390 行
字号 
using System;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Diagnostics;

namespace webvisitStatistic.Reporter.DBLayer
{
	/// <summary>
	/// SqlJournelDB 的摘要说明。
	/// </summary>
	public class SqlJournelDB : IJournelDB
	{
		public SqlJournelDB()
		{
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}

		#region IJournelDB 成员

		public void Open()
		{
			// TODO:  添加 SqlJournelDB.Open 实现
			_connString = ConfigurationSettings.AppSettings["ConnStrAdmin"];
			_connection = new SqlConnection( _connString );
			_connection.Open();
		}

		public System.Data.IDataReader SelHitsOfWebInClientIp(int webid, DateTime sdt, DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfClientIp 实现
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = "SelHitsOfWebInFullIp";
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}
		public IDataReader SelHitsOfWebInThreeIp(int webid,DateTime sdt ,DateTime edt)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = "SelHitsOfWebInThreeIp";
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}
		public IDataReader SelHitsOfWebInTwoIp(int webid,DateTime sdt ,DateTime edt)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = "SelHitsOfWebInTwoIp";
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();

		}
		public IDataReader SelHitsOfWebInOneIp(int webid,DateTime sdt ,DateTime edt)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = "SelHitsOfWebInOneIp";
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}

		public IDataReader SelHitsOfWebInScreenWidth(int webid ,DateTime sdt ,DateTime edt)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelHitsOfWebInScreenWidth;
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}
		public System.Data.IDataReader SelHitsOfWebInBrowser(int webid, DateTime sdt, DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsInBrowser 实现
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelHitsOfWebInBrowser;
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}

		public System.Data.IDataReader SelHitsOfWebInOs(int webid, DateTime sdt, DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfUrlInOs 实现
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelHitsOfWebInOs;
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}

		public System.Data.IDataReader SelHitsOfWebInUrl(int webid, DateTime sdt, DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfWebInUrl 实现
			return null;
		}

		public System.Data.IDataReader SelHitsOfWebInHour(int webid ,DateTime sdt ,DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHistOfWebInHour 实现
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelHitsOfWebInHour;
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}

		public System.Data.IDataReader SelHitsOfWebInWeekDay(int webid ,DateTime sdt ,DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfWebInWeekDay 实现
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelHitsOfWebInWeekDay;
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}

		public System.Data.IDataReader SelHitsOfWebInMonthDay(int webid ,DateTime sdt ,DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfWebInWeek 实现
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelHitsOfWebInMonthDay;
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}

		public System.Data.IDataReader SelHitsOfWebInMonth(int webid ,DateTime sdt ,DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfWebInMonth 实现
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelHitsOfWebInMonth;
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}

		public System.Data.IDataReader SelHitsOfWebInYear(int webid ,DateTime sdt ,DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfWebInYear 实现
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = "SelHitsOfWebInYear";
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}

		public System.Data.IDataReader SelHitsOfUrlInHour(String url, DateTime sdt, DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfUrlInHour 实现
			return null;
		}

		public System.Data.IDataReader SelHitsOfUrlInWeekDay(String url, DateTime sdt, DateTime edt)
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfUrlInWeekDay 实现
			return null;
		}

		public System.Data.IDataReader SelHitsOfUrlInWeek()
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfUrlInWeek 实现
			return null;
		}

		public System.Data.IDataReader SelHitsOfUrlInMonth()
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfUrlInMonth 实现
			return null;
		}

		public System.Data.IDataReader SelHitsOfUrlInYear()
		{
			// TODO:  添加 SqlJournelDB.SelHitsOfUrlInYear 实现
			return null;
		}

		public System.Data.IDataReader SelInfoOfWeb(int webid)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelInfoOfWeb;
			
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;

			return 	cmd.ExecuteReader();
		}
		public System.Data.IDataReader SelHistoryOfIp(String ip)
		{
			// TODO:  添加 SqlJournelDB.SelHistoryOfIp 实现
			return null;
		}

		public IDataReader SelUrlOfWeb(int webid)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelUrlOfWeb;
			
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;

			return 	cmd.ExecuteReader();

		}

		public System.Data.DataSet SelWebsDS()
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = SqlSelWebsDS;
			SqlDataAdapter ad = new SqlDataAdapter(cmd);
			DataSet ds = new DataSet();
			ad.Fill(ds);
			return 	ds;
		}

		public IDataReader SelUnResolvedItems()
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand cmd = _connection.CreateCommand();
			cmd.CommandType	= CommandType.StoredProcedure;
			cmd.CommandText = "SelUnResolvedItems";

			return cmd.ExecuteReader();
		}

		public IDataReader SelHitsOfWebInRef(int webid ,DateTime sdt ,DateTime edt)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = "SelHitsOfWebInRef";
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}

		public IDataReader SelHitsOfWebInRes(int webid ,DateTime sdt ,DateTime edt)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = "SelHitsOfWebInRes";
			cmd.Parameters.Add("@webid",SqlDbType.Int).Value = webid;
			cmd.Parameters.Add("@start",SqlDbType.DateTime).Value = sdt;
			cmd.Parameters.Add("@end",SqlDbType.DateTime).Value = edt;
			
			return 	cmd.ExecuteReader();
		}


		public void UpdateIpPos(String ip ,Int64 startip)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText	= "UpdateIpPos";
			
			cmd.Parameters.Add("@ip" ,SqlDbType.Char ,15).Value = ip;
			cmd.Parameters.Add("@startip" , SqlDbType.BigInt ).Value = startip;

			cmd.ExecuteNonQuery();
		}
		public IDataReader ValidateUser(String name ,String password)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = "ValidateUser";
			
			cmd.Parameters.Add("@name",SqlDbType.VarChar,255).Value = name;
			cmd.Parameters.Add("@pwd" ,SqlDbType.VarChar ,255).Value = password;

			return 	cmd.ExecuteReader();
		}

		public IDataReader SelUserInfo(String name)
		{
			Debug.Assert(null!=_connection&&System.Data.ConnectionState.Open==_connection.State);
			
			SqlCommand	cmd = _connection.CreateCommand();
			cmd.CommandType = CommandType.StoredProcedure;
			cmd.CommandText = "SelUserInfo";
			
			cmd.Parameters.Add("@name",SqlDbType.VarChar, 255).Value = name;

			return 	cmd.ExecuteReader();
		}

		#endregion

		#region IDisposable 成员

		public void Dispose()
		{
			// TODO:  添加 SqlJournelDB.Dispose 实现
		}

		#endregion
		
		protected String			_connString;
		protected SqlConnection		_connection;
		protected const String		SqlSelHitsOfWebInOs = "SelHitsOfWebInOs";
		protected const String		SqlSelHitsOfWebInBrowser = "SelHitsOfWebInBrowser";
		protected const String		SqlSelHitsOfWebInScreenWidth = "SelHitsOfWebInScreenWidth";
		protected const String		SqlSelHitsOfWebInHour = "SelHitsOfWebInHour";
		protected const String		SqlSelHitsOfWebInWeekDay = "SelHitsOfWebInWeekDay";
		protected const String		SqlSelHitsOfWebInMonth	= "SelHitsOfWebInMonth";
		protected const String	    SqlSelHitsOfWebInMonthDay = "SelHitsOfWebInMonthDay";
		protected const String		SqlSelWebsDS = "SelWebsDS";
		protected const String      SqlSelInfoOfWeb = "SelWebInfo";
		protected const String      SqlSelUrlOfWeb = "SelUrlList";
	}
}

sqljourneldb.cs - 源码说明

本页面展示了「《精通ASP.NET2.0网络应用系统开发》书中的源码」中的 sqljourneldb.cs 源码文件，采用 CS 编程语言编写，共 390 行代码。您可以在线阅读完整代码内容，也可以返回资源详情页下载完整源码包进行本地学习和开发。

虫虫下载站收录了大量与ASP相关的技术资源，包括源代码、技术文档、电路图等，是电子工程师和嵌入式开发者的专业学习平台。

⌨️ 快捷键说明

复制代码Ctrl + C
搜索代码Ctrl + F
全屏模式F11
增大字号Ctrl + =
减小字号Ctrl + -
显示快捷键?