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

C#操作sql server

时间:2017-05-21 11:52:11      阅读:283      评论:0      收藏:0      [点我收藏+]

标签:oca   移除   开始   int   each   remove   中心   取数   form   

C#操作sqlserver跟操作其他数据没有太大差别,但是又一些细节要注意一下。

在安装sqlserver时不要选择默认实例,如果是则需要更改设置,还有远程连接要去连接服务中设置一下,如端口1433等,这些百度一下就可以了。下面开始介绍一些最基本的数据库操作。

(一)建立数据库

        static void SQLDBCreate(string dbname)
        {
            //通过连接到本身存在的db  master连接到sqlserver
            string connStr = "Server = localhost;User Id=sa;Password=******; database = master";
            SqlConnection conn = new SqlConnection(connStr);
            conn.Open();
            //如果当前数据库是正在状态是无法删除的,所以把master设置为当前状态,若数据库存在则删除重建
            //此处出问题一般为数据安装过程中为默认实例,改为特定实例,然后启动服务中心,在ip3更改相关ip为本机,并把tcp端口改为1433
            //其他更改为是,同时在服务中restart即可以
            string sql= "use master;" +
            "IF DB_ID(N‘{0}‘) IS NOT NULL " +
            "DROP DATABASE {0};" +
                "CREATE DATABASE {0}";
            sql = string.Format(sql, dbname);

            try
            {
                SqlCommand cmd = new SqlCommand(sql, conn);
                cmd.ExecuteNonQuery();
                Console.WriteLine("createdb_success");
            }
            catch (Exception ex)
            {
                Console.WriteLine("createdb_failed:"+ex.Message);
            }
            finally
            {
                conn.Close();
            }
        }

(二)在建立的数据库中建表

        static void TableCreate(string dbname,string tablename)
        {
            string connStr = "Server = localhost;User Id=sa;Password=********; database = {0}";
            connStr = string.Format(connStr, dbname);
            string sql= "IF OBJECT_ID(N‘{1}..{0}‘, N‘U‘) IS NOT NULL " +
                 "DROP TABLE {0};" +
                "CREATE TABLE {0}" +
                "(ID [int] NOT NULL Primary Key," +
                "Name [char] (40) NULL ," +
                "Price [char] (40) NULL," +
            "dPrice [char] (40) NULL)";
            sql = string.Format(sql, tablename, dbname);
            SqlConnection conn = new SqlConnection(connStr);
            conn.Open();

            try
            {
                SqlCommand cmd = new SqlCommand(sql, conn);
                cmd.ExecuteNonQuery();
                Console.WriteLine("createtable_success");
            }
            catch(Exception ex)
            {
                Console.WriteLine("createtable_failed:" + ex.Message);
            }
            finally
            {
                conn.Close();
            }
        }

(三)想表中添加数据

        static void FillTable(string dbname,string tablename)
        {
            string connStr = "Server = localhost;User Id=sa;Password=********; database = {0}";
            connStr = string.Format(connStr, dbname);
            SqlConnection conn = new SqlConnection(connStr);
            conn.Open();
            string sql= "INSERT INTO {0}(ID,name,price,dPrice)" +
                "values(@d,@a,@b,@c)";
            sql = string.Format(sql, tablename);
            try
            {
                for(int i=0;i<100;i++)
                {
                    SqlCommand cmd = new SqlCommand(sql, conn);
                    cmd.Parameters.AddWithValue("@d", i);
                    cmd.Parameters.AddWithValue("@a", Guid.NewGuid());
                    cmd.Parameters.AddWithValue("@b", i.ToString());
                    cmd.Parameters.AddWithValue("@c", i.ToString());
                    cmd.ExecuteNonQuery();                    
                }
                Console.WriteLine("filltable_success");
            }
            catch(Exception ex)
            {
                Console.WriteLine("filltable_failed:" + ex.Message);
            }
            finally
            {
                conn.Close();
            }
        }

(四)删除表格

        static void DeleteTable(string dbname,string tablename)
        {
            string connStr = "Server = localhost;User Id=sa;Password=*********; database = {0}";
            connStr = string.Format(connStr, dbname);
            SqlConnection conn = new SqlConnection(connStr);
            conn.Open();
            string sql= "IF OBJECT_ID(N‘{0}..{1}‘, N‘U‘) IS NOT NULL " +
                 "DROP TABLE {1};";
            sql = string.Format(sql, dbname, tablename);
            try
            {
                SqlCommand cmd = new SqlCommand(sql, conn);
                cmd.ExecuteNonQuery();
                Console.WriteLine("deletetable_success");
            }
            catch(Exception ex)
            {
                Console.WriteLine("deletetable_failed:" + ex.Message);
            }
            finally
            {
                conn.Close();
            }
        }

(五)读取数据库中数据

        static void TransToDS(string dbname,string tablename)
        {
            string connStr = "Server =.;User Id=sa;Password=*******; database = {0}";
            connStr = string.Format(connStr, dbname);
            SqlConnection conn = new SqlConnection(connStr);
            conn.Open();

            string sql = "select *from {0}";
            sql = string.Format(sql, tablename);
            SqlCommand cmd = new SqlCommand(sql, conn);
            SqlDataAdapter apt = new SqlDataAdapter(cmd);
            SqlCommandBuilder sb = new SqlCommandBuilder(apt);
            DataSet ds = new DataSet();
            
            try
            {
                
                apt.Fill(ds);
                Console.WriteLine("transTods_success");
            }
            catch (Exception ex)
            {
                Console.WriteLine("transTods_failed:" + ex.Message);
            }
            finally
            {
                conn.Close();
            }
            DataTable dt = ds.Tables[0];

            //int i = 0;
            //foreach(DataRow dr in ds.Tables[0].Rows)
            //{
            //    if(i>50)
            //    {
            //        ds.Tables[0].Rows.RemoveAt(i);
            //    }
            //    i++;
            //}

            int count = dt.Rows.Count;
            for(int i=0;i<count;i++)
            {
                if(i>50)
                {
                    //dt.Rows.RemoveAt(51);
                    dt.Rows[i].Delete();
                }
            }
            apt.Update(ds);           

            int j = 0;
            foreach (DataRow dr in ds.Tables[0].Rows)
            {
                Console.WriteLine(dr["Price"]+" "+j+" "+dr.RowState);
                j++;
            }         
        }

关于数据操作在此多说一点,可以用sqldatareader进行读取,插入修改数据等也可以采用insert等方法进行处理,在此采用dataset先把数据表缓存到本地表中进行操作,如果只需要。看需要自己选择,采用dataset包括更新数据表等都很方便,只需要用sqldataadapter进行一下update就可以。

注意:

1、在对datatable进行遍历并进行删除操作时,不要用foreach,其不允许进行增加和删除

2、如果数据表需要update,那么数据表进行增删是要用add和delete,不要用import和remove,因为在进行update时,是根据datarow的rowstate属性进行操作的。比如delete时,并不是删除row,而是把相应行的rowstate进行了修改,update时就根据此属性进行处理,本地数据表只有当采用acceptchange时才会根据rowstate属性进行数据表的相应删除。而采用import或者remove时则rowstate属性则会存在问题,比如采用remove时,整行移除后相应的rowstate也不存在,而update时,由于相应的行没有rowstate属性值,所以远程数据库不会进行删除。import倒入后rowstate状态不明,所以也无法进行远程数据库的数据更新。

总之,采用update时并不是拿本地datatable与sqlserver数据表进行对比然后更新,而是根据datatable中的datarow的rowstate属性直接修改sqlserver数据表。

 

C#操作sql server

标签:oca   移除   开始   int   each   remove   中心   取数   form   

原文地址:http://www.cnblogs.com/llstart-new0201/p/6884242.html

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