Category Archives: Asp.net

微软企业库5.0 学习之路——第二步、使用VS2010+Data Access模块建立多数据库项目

在通过上一篇文章:[EntLib]微软企业库5.0 学习之路——第一步、基本入门对EntLib5.0的相关知识进行了了解，并通过微软给出的学习例子我们可以了解企业库的各模块的基本用法（由于园子里的好几位兄弟都已经把企业库的各模块的使用都介绍过了，所以我这边就不进行具体功能的介绍，我写的学习之路是以企业库如何在一个项目中的使用为基础来介绍，以一个简单的学生信息管理系统项目为基础，如何使用企业库来对这个项目进行开发、优化）。（本文内容比较简单，高手们可以直接忽略不看了，仅仅就是数据库访问操作和工厂分层）现在我就开始进入学习之路的第二步——Data Access模块，这个模块是企业库中被使用频率最高的模块，它很好的封装了数据库操作应用，为我们进行多数据库系统开发提供了便利，只需更改配置文件就可以很快的切换数据库访问（可惜还是要重写SQL语句，没法和ORM比）。下面是我在配置企业库的时候碰到问题，如果没有碰到可以略去不看（可能有点小白）注意：此处切换数据库配置必须是计算机中已经安装好相应的数据库访问模块，如需要进行从MS SQL向SQLite数据库的变更时，计算机中必须安装好SQLite数据库访问模块（在这里我就碰到了这个问题，原来我机器上在VS2008开发时已经安装过SQLite数据库访问模块，但是新装了VS2010，在VS2010引用对话框中也能访问到在VS2008安装的SQLite（但是在企业库5.0配置器中无法查看到SQLite),但是发现更改企业库的配置文件后无法访问SQLite数据库，尝试了很多方法都没用，结果死马当活马医又重新装了一遍SQLite数据库访问模块再重新打开企业库配置器就可以看到SQLite数据库了（所以请确保在企业库编辑器中可以查看到要切换的数据库，否则可能导致无法访问数据库）。看下图：回归正题，这次的学习由于VS2010发布了，而且企业库5.0也都支持.NET4.0，所以决定企业库的学习之路采用VS2010进行学习（顺便熟悉下.NET4的特性，毕竟公司的项目不可能立马转移到.NET4.0的，现在就当练手吧）好了，现在就开始进行第2步的学习了,首先看下项目的结构: 项目采用仿MS PetShop架构，如不了解此架构可以到此查看了解：PetShop的系统架构设计其中DAL和DALSQLite层对应MS SQL和SQLite数据库，Helper为整个项目的帮助器现在来具体了解下DAL层在DAL层中引用了Helper,IDAL,EnterpriseLibrary.Common和EnterpriseLibrary.Data这4个项目,其中Helper项目中有个DBHelper.cs,用于获取当前的数据对象,其代码如下（采用了C#4.0的语法特性，默认参数，数据库对象名默认为空，这样则会调用企业库默认的数据库对象，同时也可以在调用的时候赋值，这样则根据传递过来的数据库对象名来创建数据库，通过这个参数我们将原来需要重载的2个方法才能实现合并成了一个方法）:

using Microsoft.Practices.EnterpriseLibrary.Common.Configuration;

using Microsoft.Practices.EnterpriseLibrary.Data;

namespace EntLibStudy.Helper

{

public static class DBHelper

{

/// <summary>

/// 获取数据库对象

/// </summary>

/// <param name="name">数据库实例名(默认name为空,调用默认数据库实例)</param>

/// <returns>数据库对象</returns>

public static Database CreateDataBase(string name = "")

{

//return DatabaseFactory.CreateDatabase(name);

return EnterpriseLibraryContainer.Current.GetInstance<Database>(name);

}

在DAL层中则引用Helper来获取数据库对象，进行数据库操作，我们现在来看下具体的数据库访问类编写代码，学员操作类:

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

using System;

using System.Collections.Generic;

using System.Data;

using System.Data.Common;

using System.Linq;

using System.Text;

using Microsoft.Practices.EnterpriseLibrary.Data;

using EntLibStudy.Model;

using EntLibStudy.Helper;

namespace EntLibStudy.DAL

{

public class StudentService : EntLibStudy.IDAL.IStudentService

{

/// <summary>

/// 新增学生

/// </summary>

/// <param name="student">学生对象</param>

/// <returns></returns>

public int Add(Student student)

{

Database db = DBHelper.CreateDataBase();

StringBuilder sb = new StringBuilder();

sb.Append("insert into Student values(@ClassId,@SID,@Password,@Name,@Sex,@Birthday,@IsAdmin);SELECT @@IDENTITY;");

DbCommand cmd = db.GetSqlStringCommand(sb.ToString());

db.AddInParameter(cmd, "@ClassId", DbType.String, student.ClassId);

db.AddInParameter(cmd, "@SID", DbType.String, student.Sid);

db.AddInParameter(cmd, "@Password", DbType.String, student.Password);

db.AddInParameter(cmd, "@Name", DbType.String, student.Name);

db.AddInParameter(cmd, "@Sex", DbType.Int32, student.Sex);

db.AddInParameter(cmd, "@Birthday", DbType.DateTime, student.Birthday);

db.AddInParameter(cmd, "@IsAdmin", DbType.Int32, student.IsAdmin);

int id = Convert.ToInt32(db.ExecuteScalar(cmd));

return id;

}

/// <summary>

/// 更新

/// </summary>

/// <param name="classInfo">学生对象</param>

/// <returns>是否成功</returns>

public bool Update(Student student)

{

Database db = DBHelper.CreateDataBase();

StringBuilder sb = new StringBuilder();

sb.Append("update Student set ClassId=@ClassId,");

sb.Append("SID=@SID,");

sb.Append("Password=@Password,");

sb.Append("Name=@Name,");

sb.Append("Sex=@Sex,");

sb.Append("Birthday=@Birthday,");

sb.Append("IsAdmin=@IsAdmin ");

sb.Append(" where ID=@ID");

DbCommand cmd = db.GetSqlStringCommand(sb.ToString());

db.AddInParameter(cmd, "@ClassId", DbType.String, student.ClassId);

db.AddInParameter(cmd, "@SID", DbType.String, student.Sid);

db.AddInParameter(cmd, "@Password", DbType.String, student.Password);

db.AddInParameter(cmd, "@Name", DbType.String, student.Name);

db.AddInParameter(cmd, "@Sex", DbType.Int32, student.Sex);

db.AddInParameter(cmd, "@Birthday", DbType.DateTime, student.Birthday);

db.AddInParameter(cmd, "@IsAdmin", DbType.Int32, student.IsAdmin);

db.AddInParameter(cmd, "@ID", DbType.Int32, student.Id);

return db.ExecuteNonQuery(cmd) > 0 ? true : false;

}

/// <summary>

/// 删除

/// </summary>

/// <param name="id">学生ID</param>

/// <returns>是否成功</returns>

public bool Delete(int id)

{

Database db = DBHelper.CreateDataBase();

StringBuilder sb = new StringBuilder();

sb.Append("delete from Student ");

sb.Append(" where ID=@ID");

DbCommand cmd = db.GetSqlStringCommand(sb.ToString());

db.AddInParameter(cmd, "@ID", DbType.Int32, id);

return db.ExecuteNonQuery(cmd) > 0 ? true : false;

}

/// <summary>

/// 根据学生ID查询学生对象

/// </summary>

/// <param name="id">学生ID</param>

/// <returns></returns>

public Student SelectById(int id)

{

Student student = null;

Database db = DBHelper.CreateDataBase();

StringBuilder sb = new StringBuilder();

sb.Append("select * from Student ");

sb.Append(" where ID=@ID");

DbCommand cmd = db.GetSqlStringCommand(sb.ToString());

db.AddInParameter(cmd, "@ID", DbType.Int32, id);

using (IDataReader reader = db.ExecuteReader(cmd))

{

if (reader.Read())

{

student = new Student()

{

Id = reader.GetInt32(0),

ClassId = reader.GetInt32(1),

Sid = reader.GetString(2),

Password = reader.GetString(3),

Name = reader.GetString(4),

Sex = reader.GetInt32(5),

Birthday = reader.GetDateTime(6),

IsAdmin = reader.GetInt32(7)

};

}

return student;

}

/// <summary>

/// 查询所有学生信息

/// </summary>

/// <returns></returns>

public IList<Student> SelectAll()

{

List<Student> list = new List<Student>();

Database db = DBHelper.CreateDataBase();

StringBuilder sb = new StringBuilder();

sb.Append("select * from Student ");

DbCommand cmd = db.GetSqlStringCommand(sb.ToString());

using (IDataReader reader = db.ExecuteReader(cmd))

{

while (reader.Read())

{

list.Add(new Student()

{

Id = reader.GetInt32(0),

ClassId = reader.GetInt32(1),

Sid = reader.GetString(2),

Password = reader.GetString(3),

Name = reader.GetString(4),

Sex = reader.GetInt32(5),

Birthday = reader.GetDateTime(6),

IsAdmin = reader.GetInt32(7)

});

}

return list;

}

/// <summary>

/// 查询所有学生信息

/// </summary>

/// <returns></returns>

public IList<Student> SelectAllMapper()

{

var list = new List<Student>();

Database db = DBHelper.CreateDataBase();

DataAccessor<Student> studentAccessor;

//studentAccessor = db.CreateSqlStringAccessor("select * from Student",

// MapBuilder<Student>.MapAllProperties().

// Build()

// );

studentAccessor = db.CreateSqlStringAccessor("select * from Student",

MapBuilder<Student>.MapAllProperties().

Map(p => p.Id).ToColumn("ID").

Map(p => p.Sid).ToColumn("SID").

Map(p => p.Password).WithFunc(f => "******").//将密码转换为"*",无法直接查看

Map(p => p.Name).WithFunc(ToUpperName).//将学员名称转换为大写

Map(p => p.Sex).ToColumn("Sex").

Map(p => p.Birthday).ToColumn("Birthday").

Build()

);

list = studentAccessor.Execute().ToList();

return list;

}

/// <summary>

/// 将学员名称转换为大写

/// </summary>

/// <param name="dataRecord"></param>

/// <returns></returns>

private string ToUpperName(IDataRecord dataRecord)

{

var name = (string)dataRecord["Name"];

return name.ToUpper();

}

public Student SelectBySid(string sid)

{

Student student = null;

Database db = DBHelper.CreateDataBase();

StringBuilder sb = new StringBuilder();

sb.Append("select * from Student ");

sb.Append(" where SID=@SID");

DbCommand cmd = db.GetSqlStringCommand(sb.ToString());

db.AddInParameter(cmd, "@SID", DbType.String, sid);

using (IDataReader reader = db.ExecuteReader(cmd))

{

if (reader.Read())

{

student = new Student()

{

Id = reader.GetInt32(0),

ClassId = reader.GetInt32(1),

Sid = reader.GetString(2),

Password = reader.GetString(3),

Name = reader.GetString(4),

Sex = reader.GetInt32(5),

Birthday = reader.GetDateTime(6),

IsAdmin = reader.GetInt32(7)

};

}

return student;

}

其中的代码都是采用了比较常见的老套路: 1、获取数据库对象 2、构建Command对象并进行执行语句及参数赋值 3、通过数据库对象调用相应方法执行Command 企业库在Data Access上帮我们做了比较好的封装，相当于为我们提供了如SQLHelper,OracleHelper类,只不过这个帮助类转换了一个个数据库的对象,通过数据库对象来对数据库数据进行操作（个人认为通过这种方式进行操作更加直观，而且企业库的对SQL语句的参数操作方法也很直观：AddInParameter，AddOutParameter，GetParameterValue很好的区分了参数的操作，比原来的SQLCommand好多了）如果仔细看了上面操作代码的朋友肯定发现了类中有个叫SelectAllMapper的方法，这个方法采用的是企业库5.0中新提供的Accessor进行RowMapper来直接为实体赋值，相比原来的使用reader方式取值赋值更加优雅，只要SQL查询出来的对象字段和实体对象属性一样就可以使用MapAllProperties()方法直接赋值,如果不同的话可以使用map方法来对个别属性单独映射，而且在映射的时候还可以使用WithFunc来进行进一步操作，在代码中我将密码进行了替换，以“*”的形式展示，同时把学员的名称以大写的形式展示。（注：更多的企业库Data Access模块方法使用可以点击这里下载微软给出的学习例子和http://www.entlib.com/发布的学习手册) 在完成底层的操作，现在我们就开始对企业库的数据库访问进行配置：在Web层的Web.config上右键打开企业库配置器：Blocks-Add Data Settings-Add DataBase Connstring,新建2个数据库对象，一个是MS SqlServer数据库,一个是SQLite数据库. 新建一个数据库设置新建二个数据库连接一个为EntLibStudy，另一个为EntLibSQLite 我们来看下具体的配置文件代码：

</configSections>

<add name="EntLibStudy" connectionString="server=VOLK\SQL2005;database=EntLibStudy;Integrated Security=True;"

providerName="System.Data.SqlClient" />

<add name="EntLibStudySQLite" connectionString="data source=|DataDirectory|EntLibStudySQLite.db3"

providerName="System.Data.SQLite" />

</connectionStrings>

</appSettings>

<system.web>

</expressionBuilders>

</compilation>

</authentication>

</system.web>

</configuration>

至此我们就完成了Data Access模块的代码编写和基本设置（具体代码请到文章底部下载源代码，类似代码则不再描述）。这时如果项目需求发生了变更,由于成本太高不能使用MS SQL SERVER，而要改用SQLite数据库时则只需更改配置文件，将dataConfiguration配置节中defaultDatabase更改为EntLibStudySQLite，将appSettings配置节中DAL的值改为EntLibStudy.DALSQLite即可立刻切换到SQLite数据库。下面我来看下运行出来的效果：红色框中地址采用了ASP.NET4中的路由功能,实现了地址重写红框中如上面的分析,在DAL层进行属性映射的时候已经将密码以*代替，学员姓名以大写形式展现（此页面仅用来展示属性映射，无其他用处，页面地址为：~/Student/StudentList.aspx) 至此，学习之路的第二步——Data Access模块的学习就到此为止了，其他一些东西请下载源代码查看。注意： 1、MSSQL数据库在DataBase目录下（需要自行附加数据库），SQLite数据库在Web目录的App_Data下，由于考虑到项目的大小，所以每个项目的BIN目录都已经删除，如出现无法生成项目请自行添加相关企业库的DLL。 2、由于微软企业库5.0 学习之路这个系列我是准备以一个小型项目的形式介绍企业库的各模块，所以源代码会根据系列文章的更新而更新，所以源代码不能保证与文章中所贴代码相同。 3、项目开发环境为：VS2010+SQL2005。 4、管理员帐户：admin 密码：admin 项目下载地址：点我下载转自：http://www.cnblogs.com/kyo-yo/archive/2010/06/10/Learning-EntLib-Second.html

龙生 01 Apr 2013

View Details

微软企业库5.0 学习之路——第一步、基本入门

话说在大学的时候帮老师做项目的时候就已经接触过企业库了但是当初一直没明白为什么要用这个，只觉得好麻烦啊,竟然有那么多的乱七八糟的配置（原来我不知道有配置工具可以进行配置，请原谅我的小白）。直到去年在做项目的时候在看代码生成工具的时候看到了许多生成工具都内置了企业库的数据库访问及一些相关模块，才突然顿悟了，可能企业库应该还是有点用的，于是就试着使用了企业库的一些模块（当时版本是4.1），果然觉得企业库还是很不错的，微软在企业库中为我们封装了许多日常经常使用的模块，如：数据库访问，缓存，日志，异常处理，加密，IOC等等，在日常的项目开发中，企业库已经贯穿了一个项目从底层到表示层基本上需要用到的模块，大大方便了我们的开发，毕竟自己再重复造轮子还不如就用微软的（毕竟企业库现在都到5.0）最近在看园子里有好几位都在写，如：virus,huangcong。我现在写的其实基本上都是自己的学习之路（可能没前面2位写的好，但就当自己的学习笔记吧）。废话不多说了，首先开始学习企业库的基本概念，一下摘自sfbirp的企业库学习笔记: 一、什么是企业库？企业库包含一系列应用程序模块和核心架构。这些高复用的组件旨在帮助开发者解决一些共同的企业开发问题。企业库同时提供高可配置的特性，使我们管理重复的工作更加容易，例如我们知道的在应用的很多地方发生的横切关注点。包括像日志记录、缓存、异常管理等。另外，它提供的依赖注入容器能够简化和分解你的设计，使他们更加可实验和容易理解，帮助你创建更加高性能的设计和各种应用。二、使用企业库的3个简单步骤： 1.引用和配置你需要的程序集。 2.通过企业库配置应用。 3.在你的代码中创建和使用企业库对象。三、企业库的好处：应用模块帮助解决开发者从一个项目到另一个项目面对的共同问题。他们的设计封装了微软推荐的做法，这些都是基于微软框架的应用开发。例如，数据访问应用模块提供了对ADO.NET访问最频繁使用的特征。在某些情况下，应用模块还添加了一些基础类库没有直接提供的相关功能。四、企业库的目标： 1.一致。所有的企业库模块都坚持一致的设计模式和实现方式。 2.可扩展性。所有的应用模块包括定义扩展点，允许开发人员通过添加自己的代码定制应用模块的行为。 3.易用性。企业库提供了许多实用性的东西，包括一个图形化配置工具，简单的安装过程，完成的文档和示例。 4.集成。企业库应用模块被设计得能够一起很好的工作，并且也被这样测试过。但是你不必一起使用他们。我们可以单独使用这些应用模块，同时这些应用模块之间也有些依赖，比如在企业库核心和Unity中的一些通用组件。上面是企业库的基本概念，理解了企业库的相关知识后，我们可以开始来安装企业库了 1、下载地址：点我进入下载页面（不是直接下载），安装后就可以使用了。这次5.0相比4.1的最大改动就是整个配置工具采用了WPF重新构建和实例化和管理对象生命周期的全依赖注入的实现，同时支持VS2008SP1和VS2010，话说虽然这次的配置工具变化挺大的，但是一旦熟悉了就觉得比4.1的好，因为可以清楚的看见每个模块的之间的依赖关系。附相关改动，还是摘自sfbirp的企业库学习笔记: 一、Unity和对象生成器的整合在这个版本中，用于创建对象的基本技术是一个单一的依赖注入容器，默认的是Unity。你可以使用容器生成企业库对象的实例并注入到其他的对象。企业库提供一个标准的接口从Unity容器中来获得定义在企业库配置中的对象的实例，如SqlDatabase或LogWriter.另外，注入友好的实例门面处理静态门面之外是有效的，因为静态门面不能用注入，但是为了向后兼容以前的版本而存在。在本版本中的示例中都是用依赖注入，但是以前版本中是用的静态工厂类和静态门面在这个版本中还是支持的。对象生成器，一个低版本的依赖注入机制在这个版本中被归入Unity中，在项目中不再需要单独引用对象生成器集。支持Unity容器，必须引用一个被包含在企业库中的Microsoft.Practices.ServiceLocation程序集。如果要使用一个第3方的依赖注入容器，必须直接实现IServiceLocator接口或者通过适配器实现。二、影响所有模块的变化: 1.在企业库中主要修正是使用依赖注入机制。所用的应用模块以及核心系统都是用依赖注入机制，并使用Unity作为默认的依赖注入容器，来创建和管理企业库对象。 2.自主容器的实现通过实现Common Service Locator项目提供的 IServiceLocator 接口来完成。 3.由于错误配置引发的错误将提供更多有用的错误信息。 4.配置系统公开了一个 fluent接口，用来为单个对象或整个应用创建和填充配置源。fluent API使得为各种情景创建配置源更加容易。 5.ConfigurationView类被删除. 6.一些配置元素有默认值,可能不同于以前版本的隐式默认值. 7.企业库现在允许你通过另一个配置文件合成一个混合配置文件. 8.可以可通过不同的配置文件读取不同的配置信息. 9.企业库不支持XAML浏览器应用程序（XBAP). 10.WmiEnabled标志为了像前兼容仍然存在企业库中,但是在5.0中是被忽略的,而且将来会被删除. 11.改进式的安装允许你只安装部分应用模块及配置工具. 12.在以前版本中要做统一集成，必须添加核心企业库的扩展和每个模块的扩展。现在如果你只需要直接访问容器，那么只有核心扩展是必须的。单独模块将自动支持。旧的功能为了保持像前兼容仍然保留，但已经不起作用。 13.FileConfigurationSource.Save 的签名已经改变，参数由3个变为2个。 14.快速入门不再包含在主安装程序中。三、Breaking变化： 1.企业库现在抛出了一个配置错误ActivationException，之前是System.Configuration.ConfigurationErrorsException。这包括试着解决没有配置信息错误的一个实例提供者。 2.以前版本在获取应用模块错误时抛出BuildFailedException错误，现在对于所有的应用模块都抛出ActivationException 3 .之前的版本，在讲一个空源传到容器来调用容器的时候，会抛出ArgumentNullException，现在抛出NullReferenceException 4.ObjectBuilder2不再是一个单独的程序集，而是集成到了Unity集合中，在项目中也不需要引用ObjectBuilder2.dll。 5.WMI支持已经从企业库中删除，除了在logging模块中的WMI跟踪监听器。 6.如果你没有关闭DbDataReader，可能会导致随机的、很难在您的代码中找到的错误，尤其是当你正在一个由TransactionScope上下文创建的隐式事务下操作时。你必须始终确保您的应用程序及时关闭DbDataReader，无论是明确的DbDataReader.Close方法关闭或是逼迫DbDataReader释放。 7.如果你使用 validator 特性必须引用 System.ComponentModel.DataAnnotations程序集。 8.为FileConfigurationSource.Save方法签名已更改。该方法有两个参数，而不是3个参数 9.Microsoft.Practices.EnterpriseLibrary.Configuration.Design.dll集合的功能和其他设计时集合被一个新的集合Microsoft.Practices.EnterpriseLibrary.Configuration.DesignTime.dll代替。 10，性能计数器异常从PolicyInjection.CallHandlers移到 PolicyInjection 程序集。 11.包含在Policy Injection Application Block中的CachingCallHandler有未处理的安全漏洞，已经从Policy Injection Application Block中移除。四、配置工具的改变： 1.新的企业拥有一个新的GUI库和一个元数据驱动的可扩展性模。 2.支持向导 3.新的类型选择。 4.不支持对依赖策略的Environmental Overrides 。日志模块处理Categories。五、缓存模块变化： 1.缓存清除已被完全重写的性能优化六、数据库访问模块： 1.ExecuteReader, ExecuteXmlReader, ExecuteScalar, and ExecuteNonQuery方法具有异步版本。 2.包含了很多新的方法和类允许你提取数据作为对象序列。例如在合适的时候使用客户端查询技术，如LINQ. 3.存在的方法ExecuteReader和新的方法BeginExecuteReader不接收CommandBehavior 参数。默认的当调用这些方法的时候这些方法会自动设置CommandBehavior 属性到reder中用来关闭连接直到指定一个事务。七、异常处理模块： 1.日志异常处理重新使用日志模块的Log Writer and Trace Listeners 。这在之前版本中不是默认设置。 2.增加一个功能，通过ExceptionManager.Process 方法接收一个默认值并返回一个值。在安装完企业库同时知道了5.0的变化后，就开始正式的学习了，学习的最好办法不是看企业库的源代码（我是看不懂），而是下载微软发布的学习例子学习例子下载地址：点我进入下载页面（不是直接下载）这个学习例子里面已经包含了所需的类库及代码演示（C#和VB.NET都有）,同时可以右键例子中的App.config来看下例子中的模块是怎么配置的。同时,在学习例子的时候可以看下由http://www.entlib.com/发布的中文学习手册,虽然是4.1的,但是里面的所有内容都和5.0的例子一样(5.0只不过是重新实现了1遍)，把例子和文档结合起来看学习起来就快了很多了：中文学习手册：点我下载 Entlib5程序：点我进入下载页面（不是直接下载），到此，Entlib5的学习之路的第一步就结束了,基本上通过微软发布的学习例子和对应的中文学习手册可以对5.0的使用已经有了个基本的了解。转自：http://www.cnblogs.com/kyo-yo/archive/2010/06/07/Study-Entlib5-First.html

龙生 01 Apr 2013

View Details

ADO.NET Entity Framework 学习（2）

ADO.NET Entity Framework，即下一代的ADO.NET。它是比Linq To SQL更加强大的ORM，让开发人员只需要着眼于领域对象模型的开发，而不需要考虑它们是如何与关系数据库交互。上一篇文章简单介绍了在项目中如何使用ADO.NET实体框架，从现在开始，正式进入了ADO.NET的学习之旅。这篇文章主要介绍在ADO.NET实体框架中如何进行查询（以Northwind数据库为例）。 1. 使用EntityCommand进行查询在实体框架中，我们可以通过EntityCommand进行查询，它的使用方法就像ADO.NET中的SqlCommand。不同的是SqlCommand使用标准SQL语句对数据库进行查询，而EntityCommand使用Entity SQL对EntityContainer进行查询，当然最终实体框架会将Entity SQL转换成标准SQL语句查询数据库。

EntityConnection con = newEntityConnection("Name=NorthwindEntities");

con.Open();

using (EntityCommand cmd =

newEntityCommand("select value c from NorthwindEntities.Customers as c", con))

{

EntityDataReader reader = cmd.ExecuteReader(CommandBehavior.SequentialAccess);

while (reader.Read())

{

Console.WriteLine("ID [{0}], ContactTitle [{1}]",

reader["CustomerID"], reader["ContactTitle"]);

}

首先是建立一个EntityConnection，它接受一个参数，表明使用的是在config文件中的哪个连接字符串。 <connectionStrings> <add name="NorthwindEntities" connectionString="metadata=.\Northwind.csdl|.\Northwind.ssdl|.\Northwind.msl;provider=System.Data.SqlClient;provider connection string="Data Source=localhost\sqlexpress;Initial Catalog=Northwind;Integrated Security=True"" providerName="System.Data.EntityClient" /> </connectionStrings> 可以看到这个连接字符串和以往ADO.NET中使用的连接字符串并不一样。metadata：指明.csdl/.ssdl/.msl三个文件的路径，这三个文件的作用以后再做说明。provider：表示使用的是SqlClient或者Oledb或者Odbc。provider connection string：这一项便是以往所用的连接字符串。providerName表示现在用的是EntityClient。接着构造EntityCommand，最后通过EntityDataReader进行数据的读取，值得注意的是这里的EntityCommand接受的是Entity SQL语句，而不是标准SQL语句，具体的Entity SQL语法可以参考帮助文档。 2. 使用ObjectQuery进行查询实体框架提供一个名为ObjectQuery的类，它让开发人员通过Entity SQL进行查询，查询结果以对象的形式供使用。

using (NorthwindEntities ctx = newNorthwindEntities())

{

ObjectQuery<Customer> query

= ctx.CreateQuery<Customer>("NorthwindEntities.Customers");

ObjectResult<Customer> result = query.Execute(MergeOption.NoTracking);

foreach (Customer c in result)

{

Console.WriteLine("ID [{0}], ContactTitle [{1}]",

c.CustomerID, c.ContactTitle);

}

首先调用CreateQuery方法来创建ObjectQuery对象（当然这里也可以使用new，只是传进的参数不同而已），它接受Entity SQL语句作为参数。然后调用Execute方法进行查询，它接受MergeOption枚举型的参数，表示解决冲突的方法。查询结果以对象的形式（这里是Customer）保存在ObjectResult中。下面是使用new的写法：

{

ObjectQuery<Customer> query = newObjectQuery<Customer>("Customers", ctx);

foreach (Customer c in query)

{

Console.WriteLine("ID [{0}], ContactTitle [{1}]",

c.CustomerID, c.ContactTitle);

}

3. ADO.NET Entity Framework Tool自动生成Entities和各个对象的代码，帮助开发人员减少了很多体力活。这样，我们可以简单写成：

{

foreach (Customer c in ctx.Customers)

{

Console.WriteLine("ID [{0}], ContactTitle [{1}]",

c.CustomerID, c.ContactTitle);

}

其实这里，也是使用ObjectQuery来进行查询。当然，可以给查询加上更多的条件，在上一篇文章中也有说明这里就不写了。值得关注的是：自动生成的实体类中有这样一个方法，比如Customer：

publicstaticCustomer CreateCustomer(string customerID, string companyName)

{

Customer customer = newCustomer();

customer.CustomerID = customerID;

customer.CompanyName = companyName;

return customer;

}

并不像以前一样，提供带参数的构造函数，而是提供CreateCustomer的静态方法来构造Customer实例。这似乎和前一段时候贫血充血的问题有关了，实体对象该不该有行为，是贫血还是充血？虽然只是一个方法，不过相信这也表明了微软的态度吧。转自：http://www.cnblogs.com/blusehuang/archive/2007/10/14/923549.html

龙生 01 Apr 2013

View Details

ADO.NET Entity Framework 学习（1）

前一段时间园子里有很多文章介绍分析了Linq To SQL，它可以说是一个简单实现的ORM，是微软针对数据和对象的阻抗不平衡的问题。C# 3.0推出一些新的特性，比如Extension Method, Lambda Expression, Anonymous Type，其实这些新特性都是用来为Linq服务。Linq To SQL将程序员从以往写大量的sql查询语句、取值、赋值中解放出来，在intellisense和编译上做了很多工作，使得这些查询能够在编译期进行检查。同时微软推出ADO.NET Entity Framework，即下一代的ADO.NET。它是比Linq To SQL更加强大的ORM，让开发人员只需要着眼于领域对象模型的开发，而不需要考虑它们是如何与关系数据库交互。本文由一个简单的例子进行介绍Entity Framework是如何使用的。在此之前，必须下载ADO.NET Entity Framework runtime 和tools，官方也提供了很多示例下载。下面正式开始ADO.NET Entity Framework之旅（开发工具VS 2008 beta，以Northiwind数据库为例）。首先建立一个Console project（要选择.NET Framework 3.5），然后点击Add New Item，看见ADO.NET Entity Data Model选项：然后会出现Wizard，选择数据库，选择表、视图、存储过程等，按照向导一步步来就可以了，在这里只选择Customers和Orders表。在Solution Explore视图里面点击Northwind.edmx，可以看到Entity的信息（看上去很像Linq To SQL的dbml设计视图），然后将它们改名为Customer和Order。现在我们就可以进行查询了，先引用命名空间：

1 2	<span style="color: #0000ff;">using</span> System.Data.Objects; <span style="color: #0000ff;">using</span> NorthwindModel;

1	首先我们查询所有的Customer，代码和Linq To SQL中的十分相似。

{

foreach (var customer in ctx.Customers)

{

Console.WriteLine(customer.CustomerID);

}

接着来查询某个Customer，

1	<span style="color: #2b91af;">Customer</span> alfki = ctx.Customers.Where(<span style="color: #a31515;">"it.CustomerID = 'ALFKI'"</span>).First();

"it.CustomerID = 'ALFKI’"表示查询条件语句，该语句看着又像C#代码又像SQL，被成为Entity SQL Language，具体语法在帮助文档上有很详细的Reference。这里也可以使用Linq进行查询（Linq To Entities），需要引用System.Linq命名空间，似乎Entity Framework不支持Single方法，会抛出异常。

1	<span style="color: #2b91af;">Customer</span> alfki = ctx.Customers.First<<span style="color: #2b91af;">Customer</span>>(it => it.CustomerID == <span style="color: #a31515;">"ALFKI"</span>);

或者

Customer alfki = (from c in ctx.Customers

where c.CustomerID == "ALFKIA"select c).First();

1	在Entity Framework中进行一对多的查询很简单，但是值得注意的是Entity Framework默认是Lazy Load，即关联数据在需要的时候才加载。

1	在本例子中，如果直接查询该Customer关联的orders，查询不到结果。

foreach (var order in alfki.Orders)

{

Console.WriteLine(order.OrderID);

}

需要在使用orders之前调用 alfki.Orders.Load()，再次运行便可以得到正确的结果。

[未完待续]

转自：http://www.cnblogs.com/blusehuang/archive/2007/10/10/920020.html

龙生 01 Apr 2013

View Details

Microsoft Ajax调用Webservice

1.Default.aspx

<%@ Page Language="C#" AutoEventWireup="true" CodeBehind="Default.aspx.cs" Inherits="ScriptWebSerivce" %>

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">

function ShowResult(res) {

alert(res);}

</script>

</head>

<body>

<div>

<asp:ScriptManager ID="ScriptManager1" runat="server">

<asp:ServiceReference Path="MyWebService.asmx" />

</Services>

</asp:ScriptManager>

Ajax.MyWebService.GetTotal(5, 4, ShowResult, null, "abc");

</script>

</div>

</form>

</body>

</html>

2.MyWebService.asmx.cs

using System;

using System.Collections.Generic;

using System.Linq;

using System.Web;

using System.Web.Services;

using System.Web.Script.Services;

namespace Ajax

{

/// <summary>

/// MyWebService 的摘要说明

/// </summary>

[WebService(Namespace = "http://tempuri.org/")]

[WebServiceBinding(ConformsTo = WsiProfiles.BasicProfile1_1)]

//[System.ComponentModel.ToolboxItem(false)]

// 若要允许使用 ASP.NET AJAX 从脚本中调用此 Web 服务，请取消对下行的注释。

[ScriptService]

public class MyWebService : System.Web.Services.WebService

{

public MyWebService()

{

//Uncomment the following line if using designed components

//InitializeComponent();

}

[WebMethod]

public int GetTotal(int x, int y)

{

return x + y;

}

注意：此方法只适合在同一个域下调用。

龙生 22 Mar 2013

View Details

ASP.NET缓存全解析4：应用程序数据缓存

System.Web.Caching 命名空间提供用于缓存服务器上常用数据的类。此命名空间包括 Cache 类，该类是一个字典，您可以在其中存储任意数据对象，如哈希表和数据集。它还为这些对象提供了失效功能，并为您提供了添加和移除这些对象的方法。您还可以添加依赖于其他文件或缓存项的对象，并在从 Cache对象中移除对象时执行回调以通知应用程序。

<div style="margin:0px;padding:0px;line-height:21px;">///<summary> /// 获取当前应用程序指定CacheKey的Cache对象值 ///</summary> ///<param name="CacheKey">索引键值</param> ///<returns>返回缓存对象</returns> publicstaticobject GetCache(string CacheKey) {    System.Web.Caching.Cache objCache = HttpRuntime.Cache; return objCache[CacheKey]; } ///<summary> /// 设置当前应用程序指定CacheKey的Cache对象值 ///</summary> ///<param name="CacheKey">索引键值</param> ///<param name="objObject">缓存对象</param> publicstaticvoid SetCache(string CacheKey, object objObject) {    System.Web.Caching.Cache objCache = HttpRuntime.Cache;    objCache.Insert(CacheKey, objObject); } ///<summary> /// 设置当前应用程序指定CacheKey的Cache对象值 ///</summary> ///<param name="CacheKey">索引键值</param> ///<param name="objObject">缓存对象</param> ///<param name="absoluteExpiration">绝对过期时间</param> ///<param name="slidingExpiration">最后一次访问所插入对象时与该对象过期时之间的时间间隔</param> publicstaticvoid SetCache(string CacheKey, object objObject, DateTime absoluteExpiration, TimeSpan slidingExpiration) {    System.Web.Caching.Cache objCache = HttpRuntime.Cache;    objCache.Insert(CacheKey, objObject, null, absoluteExpiration, slidingExpiration); }       protectedvoid Page_Load(object sender, EventArgs e) { string CacheKey ="cachetest"; object objModel = GetCache(CacheKey);//从缓存中获取 if (objModel ==null)//缓存里没有    {        objModel = DateTime.Now;//把当前时间进行缓存 if (objModel !=null)        { int CacheTime =30;//缓存时间30秒            SetCache(CacheKey, objModel, DateTime.Now.AddSeconds(CacheTime), TimeSpan.Zero);//写入缓存        }    }    Label1.Text = objModel.ToString(); }</div>

　　以上几种方法都很好的解决了数据缓存的问题，但由一个最大的问题是当数据发生变化了，而缓存里还是过期的数据，只有等缓存过期后才会重新获取最新的数据，这样的话，很多时候用户获取的数据都是和实际数据不一致的过期数据。这同样给用户造成了比较大的麻烦，怎么办呢？接着往下看。转自：http://kb.cnblogs.com/page/69725/

龙生 18 Mar 2013

View Details

ASP.NET缓存全解析6：数据库缓存依赖

更多的时候，我们的服务器性能损耗还是在查询数据库的时候，所以对数据库的缓存还是显得特别重要，上面几种方式都可以实现部分数据缓存功能。但问题是我们的数据有时候是在变化的，这样用户可能在缓存期间查询的数据就是老的数据，从而导致数据的不一致。那有没有办法做到，数据如果不变化，用户就一直从缓存中取数据，一旦数据变化，系统能自动更新缓存中的数据，从而让用户得到更好的用户体验。　　答案是肯定的！.NET已经为我们提供了这样一种非常好的解决方法：SqlCacheDependency数据库缓存依赖。　　实现步骤：　　下面就让我们看一下如何实现数据库缓存依赖功能：　　第一步：修改web.config，让项目启用SqlCacheDependency 。　　将下列代码加入web.config的<system.web>节：

这里的connectionStringName指定了在<connectionStrings>中添加的某一个连接字符串。name则是为该SqlCacheDependency起的名字，这个名字将在第3步中用到。　　SqlCacheDependency类会自动完成对此配置节信息的读取以建立和数据库之间的联系。　　注意：在<databases>节的<add name="codematic" connectionStringName="strcodematic"/>中的name属性值必须和第三步的Page_Load代码中System.Web.Caching.SqlCacheDependency("codematic","P_Product"); 中的第一个参数（数据库名称）相一致。　　第二步：执行下述命令，为数据库启用缓存依赖。　　如果要配置SqlCacheDependency，则需要以命令行的方式执行。　　aspnet_regsql.exe工具位于Windows\\Microsoft.NET\\Framework\\[版本]文件夹中。　　aspnet_regsql -C "data source=127.0.0.1;initial catalog=codematic;user id=sa;password=" -ed -et -t "P_Product" 　　参数-C后面的字符串是连接字符串（请替换成自己所需要的值），　　参数-t后面的字符串是数据表的名字。　　运行结果如图15-3所示：图15-3 启用数据库缓存依赖　　命令执行后，在指定的数据库中会多出一个AspNet_SqlCacheTablesForChangeNotification表。　　注意：　　要使得7.0或者2000版本以上的SQLServer支持SqlCacheDependency特性，需要对数据库服务器执行相关的配置。　　有两种方法配置SQLServer：　　一使用aspnet_regsql命令行工具，　　二使用SqlCacheDependencyAdmin类。　　例如：　　aspnet_regsql -S "server"-E -d "database"–ed 或者　　aspnet_regsql -S "server"-E -d "database"-et -t "table"　　如果是Sql验证的话要把-E换成，-U (用户名),-P (密码) 　　以下是该工具的命令参数说明：　　-? 显示该工具的帮助功能；　　-S 后接的参数为数据库服务器的名称或者IP地址；　　-U 后接的参数为数据库的登陆用户名；　　-P 后接的参数为数据库的登陆密码；　　-E 使用当前登录用户的 Windows 集成认证进行身份验证。　　-d 后接参数为对哪一个数据库采用SqlCacheDependency功能；　　-C 连接数据库的连接字符串。如果您指定服务器(-S)和登录（-U和-P，或 -E）信息，则此选项不是必需的，因为连接字符串已经包含这些信息。　　-t 后接参数为对哪一个表采用SqlCacheDependency功能；　　-ed 允许对数据库使用SqlCacheDependency功能；　　-dd 禁止对数据库采用SqlCacheDependency功能；　　-et 允许对数据表采用SqlCacheDependency功能；　　-dt 禁止对数据表采用SqlCacheDependency功能；　　-lt 列出当前数据库中有哪些表已经采用sqlcachedependency功能。　　第三步：在代码中使用缓存，并为其设置SqlCacheDependency依赖：

<div style="margin:0px;padding:0px;line-height:21px;">///<summary> /// 获取当前应用程序指定CacheKey的Cache对象值 ///</summary> ///<param name="CacheKey">索引键值</param> ///<returns>返回缓存对象</returns> publicstaticobject GetCache(string CacheKey) {    System.Web.Caching.Cache objCache = HttpRuntime.Cache; return objCache[CacheKey]; } ///<summary> /// 设置以缓存依赖的方式缓存数据 ///</summary> ///<param name="CacheKey">索引键值</param> ///<param name="objObject">缓存对象</param> ///<param name="cacheDepen">依赖对象</param> publicstaticvoid SetCache(string CacheKey, object objObject, System.Web.Caching.CacheDependency dep) {    System.Web.Caching.Cache objCache = HttpRuntime.Cache;    objCache.Insert(        CacheKey,        objObject,        dep,        System.Web.Caching.Cache.NoAbsoluteExpiration,//从不过期        System.Web.Caching.Cache.NoSlidingExpiration,//禁用可调过期        System.Web.Caching.CacheItemPriority.Default, null); } protectedvoid Page_Load(object sender, EventArgs e) { string CacheKey ="cachetest"; object objModel = GetCache(CacheKey);//从缓存中获取 if (objModel ==null)//缓存里没有    {        objModel = GetData();//把当前时间进行缓存 if (objModel !=null)        { //依赖数据库codematic中的P_Product表变化来更新缓存            System.Web.Caching.SqlCacheDependency dep =new System.Web.Caching.SqlCacheDependency("codematic", "P_Product");            SetCache(CacheKey, objModel, dep);//写入缓存        }    }    GridView1.DataSource = (DataSet)objModel;    GridView1.DataBind(); } //查询数据 private DataSet GetData() { string conString ="data source=127.0.0.1;initial catalog=codematic;user id=sa;password="; string strSQL ="SELECT * FROM P_Product";    SqlConnection myConnection =new SqlConnection(conString);    DataSet ds =new DataSet();    myConnection.Open();    SqlDataAdapter adapter =new SqlDataAdapter(strSQL, myConnection);    adapter.Fill(ds, "Product");    myConnection.Close(); return ds; }</div>

[…]

龙生 18 Mar 2013

View Details

Global中方法的说明

Application_Init：在每一个HttpApplication实例初始化的时候执行。 Application_Disposed：在每一个HttpApplication实例被销毁之前执行。 Application_Error：所有没有处理的错误都会导致这个方法的执行。 Application_Start：在程序初始化的时候执行。在Web应用程序的生命周期里就执行一次（自动的重新启动算另外一次生命周期），这里只能放一些公用的信息，比如HttpApplicationState。 Application_End：应用程序结束时，在最后一个HttpApplication销毁之后执行。对应Application_Start，在整个生命周期里面也是只执行一次。执行顺序：Application_BeginRequest：BeginRequest是在收到Request时第一个触发的事件，这个方法自然就是第一个执行的了。 Application_AuthenticateRequest：当安全模块已经建立了当前用户的标识后执行。 Application_AuthorizeRequest：当安全模块已经验证了当前用户的授权时执行。 Application_ResolveRequestCache：当ASP.NET完成授权事件以使缓存模块从缓存中为请求提供服务时发生，从而跳过处理程序（页面或者是WebService）的执行。这样做可以改善网站的性能，这个事件还可以用来判断正文是不是从Cache中得到的。 Application_AcquireRequestState：当ASP.NET获取当前请求所关联的当前状态（如Session）时执行（真是拗口啊，msdn上就这样写的，我自己想不出什么好句子了）。 Application_PreRequestHandlerExecute：当ASP.Net即将把请求发送到处理程序对象（页面或者是WebService）之前执行。这个时候，Session就可以用了。 Application_PostRequestHandlerExecute：当处理程序对象（页面或者是WebService）工作完成之后执行。 Application_ReleaseRequestState：在ASP.NET执行完所有请求处理程序后执行。ReleaseRequestState事件将使当前状态数据被保存。 Application_UpdateRequestCache：在ASP.NET执行完处理程序后，为了后续的请求而更新响应缓存时执行。 Application_EndRequest：同上，EndRequest是在响应Request时最后一个触发的事件，这个方法自然就是最后一个执行的了。另外两个：这两个事件的顺序是无法确定的，按照MSDN的说法，它们随时都可能发生。下面就按这个顺序来解释一下它们在Global.asax.cs中相应的事件处理方法的含义。整理自：http://hi.baidu.com/czh8888/item/7371eea8ddcaaa9e151073df

龙生 08 Mar 2013

View Details

C#使用ICSharpCode.SharpZipLib.dll压缩文件夹和文件

大家可以到http://www.icsharpcode.net/opensource/sharpziplib/ 下载SharpZiplib的最新版本，本文使用的版本为0.86.0.518，支持Zip, GZip, BZip2 和Tar格式，其实没啥好说的直接上代码

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

/// <summary>

/// Zip压缩与解压缩

/// </summary>

public class ZipHelper

{

/// <summary>

/// 压缩单个文件

/// </summary>

/// <param name="fileToZip">要压缩的文件</param>

/// <param name="zipedFile">压缩后的文件</param>

/// <param name="compressionLevel">压缩等级</param>

/// <param name="blockSize">每次写入大小</param>

public static void ZipFile(string fileToZip, string zipedFile, int compressionLevel, int blockSize)

{

//如果文件没有找到，则报错

if (!System.IO.File.Exists(fileToZip))

{

throw new System.IO.FileNotFoundException("指定要压缩的文件: " + fileToZip + " 不存在!");

}

using (System.IO.FileStream ZipFile = System.IO.File.Create(zipedFile))

{

using (ZipOutputStream ZipStream = new ZipOutputStream(ZipFile))

{

using (System.IO.FileStream StreamToZip = new System.IO.FileStream(fileToZip, System.IO.FileMode.Open, System.IO.FileAccess.Read))

{

string fileName = fileToZip.Substring(fileToZip.LastIndexOf("\\") + 1);

ZipEntry ZipEntry = new ZipEntry(fileName);

ZipStream.PutNextEntry(ZipEntry);

ZipStream.SetLevel(compressionLevel);

byte[] buffer = new byte[blockSize];

int sizeRead = 0;

try

{

sizeRead = StreamToZip.Read(buffer, 0, buffer.Length);

ZipStream.Write(buffer, 0, sizeRead);

}

while (sizeRead > 0);

}

catch (System.Exception ex)

{

throw ex;

}

StreamToZip.Close();

}

ZipStream.Finish();

ZipStream.Close();

}

ZipFile.Close();

}

/// <summary>

/// 压缩单个文件

/// </summary>

/// <param name="fileToZip">要进行压缩的文件名</param>

/// <param name="zipedFile">压缩后生成的压缩文件名</param>

public static void ZipFile(string fileToZip, string zipedFile)

{

//如果文件没有找到，则报错

if (!File.Exists(fileToZip))

{

throw new System.IO.FileNotFoundException("指定要压缩的文件: " + fileToZip + " 不存在!");

}

using (FileStream fs = File.OpenRead(fileToZip))

{

byte[] buffer = new byte[fs.Length];

fs.Read(buffer, 0, buffer.Length);

fs.Close();

using (FileStream ZipFile = File.Create(zipedFile))

{

using (ZipOutputStream ZipStream = new ZipOutputStream(ZipFile))

{

string fileName = fileToZip.Substring(fileToZip.LastIndexOf("\\") + 1);

ZipEntry ZipEntry = new ZipEntry(fileName);

ZipStream.PutNextEntry(ZipEntry);

ZipStream.SetLevel(5);

ZipStream.Write(buffer, 0, buffer.Length);

ZipStream.Finish();

ZipStream.Close();

}

/// <summary>

/// 压缩多层目录

/// </summary>

/// <param name="strDirectory">The directory.</param>

/// <param name="zipedFile">The ziped file.</param>

public static void ZipFileDirectory(string strDirectory, string zipedFile)

{

using (System.IO.FileStream ZipFile = System.IO.File.Create(zipedFile))

{

using (ZipOutputStream s = new ZipOutputStream(ZipFile))

{

ZipSetp(strDirectory, s, "");

}

/// <summary>

/// 递归遍历目录

/// </summary>

/// <param name="strDirectory">The directory.</param>

/// <param name="s">The ZipOutputStream Object.</param>

/// <param name="parentPath">The parent path.</param>

private static void ZipSetp(string strDirectory, ZipOutputStream s, string parentPath)

{

if (strDirectory[strDirectory.Length - 1] != Path.DirectorySeparatorChar)

{

strDirectory += Path.DirectorySeparatorChar;

}

Crc32 crc = new Crc32();

string[] filenames = Directory.GetFileSystemEntries(strDirectory);

foreach (string file in filenames)// 遍历所有的文件和目录

{

if (Directory.Exists(file))// 先当作目录处理如果存在这个目录就递归Copy该目录下面的文件

{

string pPath = parentPath;

pPath += file.Substring(file.LastIndexOf("\\") + 1);

pPath += "\\";

ZipSetp(file, s, pPath);

}

else // 否则直接压缩文件

{

//打开压缩文件

using (FileStream fs = File.OpenRead(file))

{

byte[] buffer = new byte[fs.Length];

fs.Read(buffer, 0, buffer.Length);

string fileName = parentPath + file.Substring(file.LastIndexOf("\\") + 1);

ZipEntry entry = new ZipEntry(fileName);

entry.DateTime = DateTime.Now;

entry.Size = fs.Length;

fs.Close();

crc.Reset();

crc.Update(buffer);

entry.Crc = crc.Value;

s.PutNextEntry(entry);

s.Write(buffer, 0, buffer.Length);

}

/// <summary>

/// 解压缩一个 zip 文件。

/// </summary>

/// <param name="zipedFile">The ziped file.</param>

/// <param name="strDirectory">The STR directory.</param>

/// <param name="password">zip 文件的密码。</param>

/// <param name="overWrite">是否覆盖已存在的文件。</param>

public void UnZip(string zipedFile, string strDirectory, string password, bool overWrite)

{

if (strDirectory == "")

strDirectory = Directory.GetCurrentDirectory();

if (!strDirectory.EndsWith("\\"))

strDirectory = strDirectory + "\\";

using (ZipInputStream s = new ZipInputStream(File.OpenRead(zipedFile)))

{

s.Password = password;

ZipEntry theEntry;

while ((theEntry = s.GetNextEntry()) != null)

{

string directoryName = "";

string pathToZip = "";

pathToZip = theEntry.Name;

if (pathToZip != "")

directoryName = Path.GetDirectoryName(pathToZip) + "\\";

string fileName = Path.GetFileName(pathToZip);

Directory.CreateDirectory(strDirectory + directoryName);

if (fileName != "")

{

if ((File.Exists(strDirectory + directoryName + fileName) && overWrite) || (!File.Exists(strDirectory + directoryName + fileName)))

{

using (FileStream streamWriter = File.Create(strDirectory + directoryName + fileName))

{

int size = 2048;

byte[] data = new byte[2048];

while (true)

{

size = s.Read(data, 0, data.Length);

if (size > 0)

streamWriter.Write(data, 0, size);

else

break;

}

streamWriter.Close();

}

s.Close();

}

代码来自网络，略作修改，修改为静态方法，修改文件夹递归压缩时的bug.. 转自：http://www.cnblogs.com/xuanye/archive/2011/10/19/2217211.html

龙生 07 Mar 2013

View Details

ASP.NET缓存全解析5：文件缓存依赖

这种策略让缓存依赖于一个指定的文件，通过改变文件的更新日期来清除缓存。

<div style="margin:0px;padding:0px;line-height:21px;">///<summary> /// 获取当前应用程序指定CacheKey的Cache对象值 ///</summary> ///<param name="CacheKey">索引键值</param> ///<returns>返回缓存对象</returns> publicstaticobject GetCache(string CacheKey) {    System.Web.Caching.Cache objCache = HttpRuntime.Cache; return objCache[CacheKey]; } ///<summary> /// 设置以缓存依赖的方式缓存数据 ///</summary> ///<param name="CacheKey">索引键值</param> ///<param name="objObject">缓存对象</param> ///<param name="cacheDepen">依赖对象</param> publicstaticvoid SetCache(string CacheKey, object objObject, System.Web.Caching.CacheDependency dep) {    System.Web.Caching.Cache objCache = HttpRuntime.Cache;    objCache.Insert(        CacheKey,        objObject,        dep,        System.Web.Caching.Cache.NoAbsoluteExpiration, //从不过期        System.Web.Caching.Cache.NoSlidingExpiration, //禁用可调过期        System.Web.Caching.CacheItemPriority.Default, null); } protectedvoid Page_Load(object sender, EventArgs e) { string CacheKey ="cachetest"; object objModel = GetCache(CacheKey);//从缓存中获取 if (objModel ==null) //缓存里没有    {        objModel = DateTime.Now;//把当前时间进行缓存 if (objModel !=null)        { //依赖 C:\\test.txt 文件的变化来更新缓存            System.Web.Caching.CacheDependency dep =new System.Web.Caching.CacheDependency("C:\\test.txt");            SetCache(CacheKey, objModel, dep);//写入缓存        }    }    Label1.Text = objModel.ToString(); }</div>

　　当我们改变test.txt的内容时，缓存会自动更新。这种方式非常适合读取配置文件的缓存处理。如果配置文件不变化，就一直读取缓存的信息，一旦配置发生变化，自动更新同步缓存的数据。　　这种方式的缺点是，如果缓存的数据比较多，相关的依赖文件比较松散，对管理这些依赖文件有一定的麻烦。对于负载均衡环境下，还需要同时更新多台Web服务器下的缓存文件，如果多个Web应用中的缓存依赖于同一个共享的文件，可能会省掉这个麻烦。 FROM URI:http://kb.cnblogs.com/page/69726/

龙生 01 Mar 2013

View Details

« Previous 1 … 39 40 41 … 44 Next »

November 2024
M	T	W	T	F	S	S
« Oct
				1	2	3
4	5	6	7	8	9	10
11	12	13	14	15	16	17
18	19	20	21	22	23	24
25	26	27	28	29	30