sqldataprovider.cs

SharpNuke源代码

			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetProfile", userId, portalId));
		}

		public override void AddProfile (int userId, int portalId)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "AddProfile", userId, portalId);
		}

		public override void UpdateProfile (int userId, int portalId, string profileData)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdateProfile", userId, portalId, profileData);
		}
		#endregion
		
		#region users online
		public override void UpdateUsersOnline (Hashtable userList)
		{
			
			if (userList.Count == 0)
			{
				//No users to process, quit method
				return;
			}
			foreach (string key in userList.Keys)
			{
				if (userList[key] is AnonymousUserInfo)
				{
					AnonymousUserInfo user = ((AnonymousUserInfo) userList[key]);
					SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdateAnonymousUser", 
						user.UserID, user.PortalID, user.TabID, user.LastActiveDate);
				}
				else if (userList[key] is OnlineUserInfo)
				{
					OnlineUserInfo user = ((OnlineUserInfo) userList[key]);
					SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdateOnlineUser", 
						user.UserID, user.PortalID, user.TabID, user.LastActiveDate);
				}
			}
		}

		public override void DeleteUsersOnline (int timeWindow)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteUsersOnline", timeWindow);
		}
		#endregion
		
		#region urls
		public override IDataReader GetUrls(int portalID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetUrls", portalID));
		}

		public override IDataReader GetUrl(int portalID, string url)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetUrl", portalID, url));
		}

		public override void AddUrl (int portalID, string url)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "AddUrl", portalID, url);
		}

		public override void DeleteUrl (int portalID, string url)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteUrl", portalID, url);
		}

		public override IDataReader GetUrlTracking(int portalID, string url, int moduleID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetUrlTracking", 
				portalID, url, GetNull(moduleID)));
		}

		public override void AddUrlTracking (int portalID, string url, string urlType, bool logActivity, bool trackClicks, 
			int moduleID, bool newWindow)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "AddUrlTracking", 
				portalID, url, urlType, logActivity, trackClicks, GetNull(moduleID), newWindow);
		}

		public override void UpdateUrlTracking (int portalID, string url, bool logActivity, bool trackClicks, int moduleID, bool newWindow)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdateUrlTracking", 
				portalID, url, logActivity, trackClicks, GetNull(moduleID), newWindow);
		}

		public override void DeleteUrlTracking (int portalID, string url, int moduleID)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteUrlTracking", 
				portalID, url, GetNull(moduleID));
		}

		public override void UpdateUrlTrackingStats (int portalID, string url, int moduleID)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdateUrlTrackingStats", 
				portalID, url, GetNull(moduleID));
		}

		public override IDataReader GetUrlLog(int urlTrackingID, DateTime startDate, DateTime endDate)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetUrlLog", 
				urlTrackingID, GetNull(startDate), GetNull(endDate)));
		}

		public override void AddUrlLog (int urlTrackingID, int userID)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "AddUrlLog", urlTrackingID, GetNull(userID));
		}
		#endregion
		
		#region Permission
		public override IDataReader GetPermissionsByModuleID(int moduleID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetPermissionsByModuleID", moduleID));
		}
		
		public override IDataReader GetPermissionsByFolderPath(int portalID, string folder)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetPermissionsByFolderPath", GetNull(portalID), folder));
		}
		
		public override IDataReader GetPermissionByCodeAndKey(string permissionCode, string permissionKey)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetPermissionByCodeAndKey", 
				GetNull(permissionCode), GetNull(permissionKey)));
		}
		
		public override IDataReader GetPermissionsByTabID(int tabID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetPermissionsByTabID", tabID));
		}
		
		public override IDataReader GetPermission(int permissionID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetPermission", permissionID));
		}
		
		public override void DeletePermission (int permissionID)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeletePermission", permissionID);
		}
		
		public override int AddPermission(string permissionCode, int moduleDefID, string permissionKey, string permissionName)
		{
			return System.Convert.ToInt32(SqlHelper.ExecuteScalar(ConnectionString, DatabaseOwner + ObjectQualifier + "AddPermission", moduleDefID, permissionCode, permissionKey, permissionName));
		}
		
		public override void UpdatePermission (int permissionID, string permissionCode, int moduleDefID, string permissionKey, string permissionName)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdatePermission", permissionID, permissionCode, moduleDefID, permissionKey, permissionName);
		}
		#endregion
		
		#region ModulePermission
		public override IDataReader GetModulePermission(int modulePermissionID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetModulePermission", modulePermissionID));
		}
		
		public override IDataReader GetModulePermissionsByModuleID(int moduleID, int permissionID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetModulePermissionsByModuleID", moduleID, permissionID));
		}
		
		public override IDataReader GetModulePermissionsByPortal(int portalID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetModulePermissionsByPortal", portalID));
		}
		
		public override void DeleteModulePermissionsByModuleID (int moduleID)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteModulePermissionsByModuleID", moduleID);
		}
		
		public override void DeleteModulePermission (int modulePermissionID)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteModulePermission", modulePermissionID);
		}
		
		public override int AddModulePermission(int moduleID, int permissionID, int roleID, bool allowAccess)
		{
			return System.Convert.ToInt32(SqlHelper.ExecuteScalar(ConnectionString, DatabaseOwner + ObjectQualifier + "AddModulePermission", moduleID, permissionID, roleID, allowAccess));
		}
		
		public override void UpdateModulePermission (int modulePermissionID, int moduleID, int permissionID, int roleID, bool allowAccess)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdateModulePermission", modulePermissionID, moduleID, permissionID, roleID, allowAccess);
		}
		#endregion
		
		#region TabPermission
		public override IDataReader GetTabPermissionsByPortal(int portalID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetTabPermissionsByPortal", portalID));
		}
		
		public override IDataReader GetTabPermissionsByTabID(int tabID, int permissionID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetTabPermissionsByTabID", tabID, permissionID));
		}
		
		public override void DeleteTabPermissionsByTabID (int tabID)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteTabPermissionsByTabID", tabID);
		}
		
		public override void DeleteTabPermission (int tabPermissionID)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteTabPermission", tabPermissionID);
		}
		
		public override int AddTabPermission(int tabID, int permissionID, int roleID, bool allowAccess)
		{
			return System.Convert.ToInt32(SqlHelper.ExecuteScalar(ConnectionString, DatabaseOwner + ObjectQualifier + "AddTabPermission", 
				tabID, permissionID, roleID, allowAccess));
		}
		
		public override void UpdateTabPermission (int tabPermissionID, int tabID, int permissionID, int roleID, bool allowAccess)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdateTabPermission", tabPermissionID, tabID, permissionID, roleID, allowAccess);
		}
		#endregion
		
		#region Folders
		public override IDataReader GetFoldersByPortal(int portalID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetFolders", GetNull(portalID), - 1, ""));
		}

		public override IDataReader GetFolder(int portalID, int folderID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetFolders", GetNull(portalID), folderID, ""));
		}

		public override IDataReader GetFolder(int portalID, string folderPath)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetFolders", GetNull(portalID), - 1, folderPath));
		}

		public override int AddFolder(int portalID, string folderPath)
		{
			return System.Convert.ToInt32(SqlHelper.ExecuteScalar(ConnectionString, DatabaseOwner + ObjectQualifier + "AddFolder", GetNull(portalID), folderPath));
		}

		public override void UpdateFolder (int portalID, int folderID, string folderPath)
		{
			SqlHelper.ExecuteScalar(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdateFolder", GetNull(portalID), folderID, folderPath);
		}

		public override void DeleteFolder (int portalID, string folderPath)
		{
			SqlHelper.ExecuteScalar(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteFolder", GetNull(portalID), folderPath);
		}
		#endregion
		
		#region FolderPermission
		public override IDataReader GetFolderPermission(int folderPermissionID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetFolderPermission", folderPermissionID));
		}

		public override IDataReader GetFolderPermissionsByFolderPath(int portalID, string folderPath, int permissionID)
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetFolderPermissionsByFolderPath", 
				GetNull(portalID), folderPath, permissionID));
		}

		public override void DeleteFolderPermissionsByFolderPath (int portalID, string folderPath)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteFolderPermissionsByFolderPath", GetNull(portalID), folderPath);
		}

		public override void DeleteFolderPermission (int folderPermissionID)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "DeleteFolderPermission", folderPermissionID);
		}

		public override int AddFolderPermission(int folderID, int permissionID, int roleID, bool allowAccess)
		{
			return System.Convert.ToInt32(SqlHelper.ExecuteScalar(ConnectionString, DatabaseOwner + ObjectQualifier + "AddFolderPermission", 
				folderID, permissionID, roleID, allowAccess));
		}

		public override void UpdateFolderPermission (int folderPermissionID, int folderID, int permissionID, int roleID, bool allowAccess)
		{
			SqlHelper.ExecuteNonQuery(ConnectionString, DatabaseOwner + ObjectQualifier + "UpdateFolderPermission", folderPermissionID, folderID, permissionID, roleID, allowAccess);
		}
		#endregion
		
		#region search engine
		public override System.Data.IDataReader GetSearchIndexers()
		{
			return ((IDataReader) SqlHelper.ExecuteReader(ConnectionString, DatabaseOwner + ObjectQualifier + "GetSearchIndexers", null));
		}