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);
}
//增删改查
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。