1、获取数据库连接字符串 string connectString = DBFunc.GetCorpUserDBSelectConnectionString();
2、数据库语句: string sql = @"select PackageID from [CorpUserDB].[dbo].[Corp_MultiLangPackage] with(nolock)";
3、创建数据库连接,用DataSet去接收数据库的返回 Database db = DatabaseFactory.CreateDatabase(connectString); DbCommand dbCommand = db.GetSqlStringCommand(sql); DataSet ds = db.ExecuteDataSet(dbCommand);
4、若要带查询参数的数据库查询: string sql = @"select PackageID from [CorpUserDB].[dbo].[Corp_MultiLangPackage] with(nolock) where PackageName=@resname"; //string sql = @"select PackageID from [CorpUserDB].[dbo].[Corp_MultiLangPackage] with(nolock)"; Database db = DatabaseFactory.CreateDatabase(connectString); DbCommand dbCommand = db.GetSqlStringCommand(sql);
db.AddInParameter(dbCommand,"@resname",DbType.AnsiString,resname); DataSet ds = db.ExecuteDataSet(dbCommand);
5、解析整个DataSet的对象: ? ? ? ? ? ? foreach (DataRow dr in ds.Tables[0].Rows) ? ? ? ? ? ? { ? ? ? ? ? ? ? ? dr["PackageID"] ?//相应的查询出来的key值 ? ? ? ? ? ? }
6、相应的增删改查方法: 1对于sqlserver这一块 1、添加引用 using System.Data; using System.Data.SqlData; 2、建立于数据库的连接,建议将它做成一个方法,方便多次利用。 string sqlconnection = "data source = "注解1";database = 注解2;uid = "注解3";pwd ="注解4"";(其实还有很多种写法) 可以参考http://www.cnblogs.com/delphinet/archive/2011/06/24/2088765.html 3、经常用到的对象有:SqlConnection,SqlAdapter,SqlCommand、Dataset、DataGrid和 DataReader等,以SqlConnection,SqlAdapter,SqlCommand、Dataset、DataGrid对象,操作 SQL的实例数据库Northwind中的Categorys表为例说明(假定数据库在本地,数据库访问的用户名为user,密码为123456): 接下来做一下四个操作的实现 第一、查询数据: string MyConn="server=127.0.0.1;uid=user;pwd=123456;database=Northwind;Trusted_Connection=no";//定义数据库连接参数 SqlConnection MyConnection=new SqlConnection(MyConn);//定义一个数据连接实例 SqlCommand MyCommand=new SqlCommand("SELECT CategoryID,CategoryName,Description FROM Categories",MyConnection); //定义一个数据库操作指令 SqlDataAdapter SelectAdapter=new SqlDataAdapter();//定义一个数据适配器 SelectAdapter.SelectCommand=MyCommand;//定义数据适配器的操作指令 DataSet MyDataSet=new DataSet();//定义一个数据集 MyConnection.Open();//打开数据库连接 SelectAdapter.SelectCommand.ExecuteNonQuery();//执行数据库查询指令 MyConnection.Close();//关闭数据库 SelectAdapter.Fill(MyDataSet);//填充数据集 DataGrid1.DataSource=MyDataSet; DataGrid1.DataBind();//将数据表格用数据集中的数据填充 第二、添加数据 string MyConn="server=127.0.0.1;uid=user;pwd=123456;database=Northwind;Trusted_Connection=no"; SqlConnection MyConnection=new SqlConnection(MyConn); string MyInsert="insert into Categories(CategoryName,Description)values('"+Convert.ToString(TextBox2.Text)+"','"+Convert.ToString(TextBox3.Text)+"')"; SqlCommand MyCommand=new SqlCommand(MyInsert,MyConnection); try//异常处理 { MyConnection.Open(); MyCommand.ExecuteNonQuery(); MyConnection.Close(); } catch(Exception ex) { Console.WriteLine("{0} Exception caught.",ex); } 第三、修改数据 string categoryName=TextBox2.Text; string categoryDescription=TextBox3.Text; string MyConn="server=127.0.0.1;uid=user;pwd=123456;database=Northwind;Trusted_Connection=no"; SqlConnection MyConnection=new SqlConnection(MyConn); string MyUpdate="Update Categories set CategoryName='"+categoryName+"',Description='"+categoryDescription+"' where CategoryID="+TextBox1.Text; SqlCommand MyCommand=new SqlCommand(MyUpdate,MyConnection); try { MyConnection.Open(); MyCommand.ExecuteNonQuery(); MyConnection.Close(); TextBox1.Text=""; } catch(Exception ex) { Console.WriteLine("{0} Exception caught.",ex); } 第四、删除数据 string MyConn="server=127.0.0.1;uid=user;pwd=123456;database=Northwind;Trusted_Connection=no"; SqlConnection MyConnection=new SqlConnection(MyConn); string MyDelete="Delete from Categories where CategoryID="+TextBox1.Text; SqlCommand MyCommand=new SqlCommand(MyDelete,ex); }
//增删改查
(编辑:李大同)
【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!
|