码迷,mamicode.com
首页 > 数据库 > 详细

c#对(oracle\sqlce\sqlite)简单操作

时间:2014-06-05 00:09:39      阅读:476      评论:0      收藏:0      [点我收藏+]

标签:数据库   c#   

1:连接oracle

 A:安装oracle服务端(11G/10G)

 B:添加引用:

bubuko.com,布布扣

C:引入命名空间:using System.Data.OracleClient;

D:连接字符:

		/// <summary>
		/// 	获取连接对象
		/// </summary>
		/// <param name="user">用户名</param>
		/// <param name="password">密码</param>
		/// <param name="url">连接url,如(localhost:1521/orcl)</param>
		/// <returns>OracleConnection</returns>
		public OracleConnection getOracleConnection(String user,String password,String url)
		{
			String source = "Data source="+url+";Integrated Security=no;User ID="+user+";Password="+password;
			OracleConnection oraConn = new OracleConnection(source);
			oraConn.Open();
			return oraConn;
		}

2:连接sqlCE

A:安装SQLCE

 bubuko.com,布布扣

 B:添加引用:

 bubuko.com,布布扣

C:引入命名空间:using System.Data.SQLite;

D:测试连接

		/// <summary>
		/// 	获取连接对象
		/// </summary>
		/// <param name="source">数据源(数据库存放路径),如:E:\dataSource\PostingSys.sdf</param>
		/// <param name="password">密码</param>
		/// <returns>SqlCeConnection</returns>
		public SqlCeConnection getSqlceConnection(String source,String password)
		{
			source = @"Data Source="+source+";Password="+password;
			SqlCeConnection sqlce = new SqlCeConnection(source);
			sqlce.Open();	
			return sqlce;
		}

3:连接SQLite

A:安装SQLite

 bubuko.com,布布扣

B:添加引用:

 bubuko.com,布布扣

C:命名空间:using System.Data.SQLite;

D:测试连接:

		/// <summary>
		/// 	获取连接对象
		/// </summary>
		/// <param name="source">数据源(数据库存放路径),如E:\dataSource\openises.db</param>
		/// <returns>SQLiteConnection连接对象</returns>
		public SQLiteConnection getSQLiteConnection(String db)
		{
			SQLiteConnection slc = new SQLiteConnection("DateTimeKind = Utc;Data Source = " + db);
			slc.Open();
			return slc;
		}

4:由于本人发现c#对数据库的操作重复性很高,下面只贴出对oracle封装操作。因为其他两个思想也基本一致,只是对象及方法不同。下载

  • Oracle
更新
		/// <summary>
		/// 	操作:update\add\delete
		/// 如果是采用更新的话,则需注意以下
		/// 1:更新指定其字段,保存占位符的参数不能为null
		/// </summary>
		/// <param name="oc">连接对象</param>
		/// <param name="sqlText">执行的sql语句</param>
		/// <param name="arrayPara">占位符参数</param>
		/// <returns>int 返回操作后改变的行数</returns>
		public int ExecuteUpdate(OracleConnection oc,String sqlText,List<OracleParameter> arrayPara) {
			
			OracleCommand oraCom = null;
			int edit = 0;
			try{
				
				oraCom = new OracleCommand();
				oraCom.Connection = oc;
				oraCom.CommandText = sqlText;
				
				foreach(OracleParameter op in arrayPara){
					oraCom.Parameters.Add(op);
				}
				
				oraCom.Transaction = oc.BeginTransaction();//开启事务
				edit = oraCom.ExecuteNonQuery();
				oraCom.Transaction.Commit();//事务提交后,就把事务对象为null,但会话没有结束!
				
			}catch(Exception ex){
				if(oraCom!=null){
					oraCom.Transaction.Rollback();//回滚
				}
				Console.WriteLine("\n操作失败,异常:{0}",ex.Message);
				throw;
			}
			
			return edit;
		}
查询
		/// <summary>
		/// 	操作:查询
		/// 默认是查询所有。sqlText为条件后语句
		/// </summary>
		/// <param name="oc">Oracle连接对象</param>
		/// <param name="sqlText">条件语句(and xx=:xx)</param>
		/// <param name="arrayPara">占位符参数(如:id_x,:name_x)</param>
		/// <param name="clazz">查询表对应的实体类</param>
		/// <returns>list符合条件数据</returns>
		public List<Object> ExecuteSelect(OracleConnection oc,String sqlText,List<OracleParameter> arrayPara,Type clazz)
		{
			List<Object> clazzArray = new List<Object>();
			
			//执行对象
			OracleCommand comm = new OracleCommand();
			comm.CommandText = "select * from " + clazz.Name + " where 1=1 " +sqlText;
			comm.Connection = oc;
			//参数
			foreach(OracleParameter op in arrayPara){
				comm.Parameters.Add(op);
			}
			//执行sql
			OracleDataReader dataReader = comm.ExecuteReader();
			
			int fieLen = dataReader.FieldCount;
			while(dataReader.Read())
			{
				Object objTemp = Activator.CreateInstance(clazz);
				
				//获取每一行的每一个列。
				for(int x = 0; x < fieLen;x++)
				{
					String fieName = dataReader.GetName(x);
					Object fieValue= dataReader.GetValue(x);
					
					FieldInfo fieInfo = clazz.GetField(fieName,BindingFlags.IgnoreCase|BindingFlags.NonPublic|BindingFlags.Instance);
					
					/*类型转换:*/
					String typeName = fieInfo.FieldType.Name;
					
					if(fieValue.ToString()==String.Empty || fieValue.ToString().Length < 1)
						continue;
							
					fieValue = TransformationUtils.typeTransform(typeName,fieValue);
					fieInfo.SetValue(objTemp,fieValue);
				}
				clazzArray.Add(objTemp);
			}
			return clazzArray;
		}	

工具类下载


c#对(oracle\sqlce\sqlite)简单操作,布布扣,bubuko.com

c#对(oracle\sqlce\sqlite)简单操作

标签:数据库   c#   

原文地址:http://blog.csdn.net/hubiao_0618/article/details/27186105

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!