將datatable 插入數據庫


using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Data.SqlClient;

namespace MyApp
{
    class Program
    {
        static void Main(string[] args)
        {
            // 連接字符串
            string cnnString = "Data Source=(LocalDB)\\MSSQLLocalDB;AttachDbFilename=C:\\Users\\jonaszhang\\Downloads\\示例源碼\\示例源碼\\第17章\\示例數據庫\\示例數據庫\\TestDB.mdf;Integrated Security=True;Connect Timeout=30";// "Data Source=(LocalDB)\\MSSQLLocalDB;AttachDbFilename=F:\\pauls_file\\BOOKCD022619\\示例源碼\\第17章\\示例數據庫\\示例數據庫\\TestDB.mdf;Integrated Security=True;Connect Timeout=30";
            // 創建連接對象
            SqlConnection conn = new SqlConnection(cnnString);
            try
            {     
                // 打開連接
                conn.Open();
                // 創建命令對象
                SqlCommand cmd = conn.CreateCommand();
                // 設置SQL語句
                cmd.CommandText = "SELECT TOP 10 * FROM products";

                // 執行SQL語句並返回數據閱讀器
                SqlDataReader reader = cmd.ExecuteReader();
                // 讀取每一行數據,並輸出到屏幕上
                while (reader.Read())
                {
                    Console.WriteLine("產品ID:{0},產品名稱:{1}", reader.GetInt32(0), reader.GetString(1));
                }
                // 關閉閱讀器
                reader.Close();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.Message);
            }
            finally
            {
                // 關閉連
                conn.Close();
            }

            Console.Read();
        }
    }
}
View Code

 

/*

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace jonastrysql
{
    class Program
    {
        static void Main(string[] args)
        {
        }
    }
}


*/



using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data.SqlClient;
using System.Collections;
using System.Data;
 
namespace ConsoleApplication1
{
    class Program
    {
        static void Main(string[] args)
        {
            string connectString = "Data Source=(localdb)\\MSSQLLocalDB;Initial Catalog=JonasTry;Integrated Security=True"; // "Data Source=leaf-home\\sqlserver2005;Initial Catalog=Test;Persist Security Info=True;User ID=site_dev;Password=???";
            using (SqlConnection conn = new SqlConnection(connectString))
            {
                conn.Open();
                Console.Write("ni hao");
               /* SqlCommand sqlCom = new SqlCommand();
                sqlCom.Connection = conn;
                sqlCom.CommandType = CommandType.Text;
                sqlCom.CommandText = "select * from [JonasTry].[DBO].[tb]";
                SqlDataReader tableList = sqlCom.ExecuteReader();

                while (tableList.Read())
                {
                    Console.Write(tableList["A"].ToString()+"\t");
                    Console.Write(tableList["B"].ToString() + "\t");
                    Console.Write("\n");
                }
                tableList.Close();
                */




                //-------- 創建要測試的數據 begin -------------
                DataTable dtNew = new DataTable();
                dtNew.Columns.Add(new DataColumn("A", typeof(int)));
                dtNew.Columns.Add(new DataColumn("B", typeof(string)));

                DataRow dr = dtNew.NewRow();
                dr["A"] = 99;
                dr["B"] = "";
                dtNew.Rows.Add(dr);
                dr = dtNew.NewRow();
                dr["A"] = 101;
                dr["B"] = "";
                dtNew.Rows.Add(dr);
                //-------- 創建要測試的數據 end -------------

                //得到原表結構
                //conn.Open();
                string strSql = "SELECT * FROM dbo.tb WHERE 1=0";
                SqlDataAdapter adapter = new SqlDataAdapter(strSql, conn);
                SqlCommandBuilder builder = new SqlCommandBuilder(adapter);


                DataSet ds = new DataSet();
                adapter.Fill(ds, "flag");
                DataTable table = ds.Tables["flag"];


                //將新數據傳到對應的datatable中
                foreach (DataRow drNew in dtNew.Rows)
                {
                    DataRow row = table.NewRow();
                    foreach (DataColumn dc in table.Columns)
                    {
                        row[dc.ColumnName] = drNew[dc.ColumnName];
                    }
                    table.Rows.Add(row);
                }

                //更新數據庫
                adapter.Update(table);

                //讀取數據庫中的數據
                SqlCommand sqlCom = new SqlCommand();
                sqlCom.Connection = conn;
                sqlCom.CommandType = CommandType.Text;
                sqlCom.CommandText = "select * from [JonasTry].[DBO].[tb]";
                SqlDataReader tableList = sqlCom.ExecuteReader();

                while (tableList.Read())
                {
                    Console.Write(tableList["A"].ToString() + "\t");
                    Console.Write(tableList["B"].ToString() + "\t");
                    Console.Write("\n");
                }
                tableList.Close();
                //讀完了
                Console.Write("\n show finish");
            }
            Console.Read();
        }//end of Main
    }//end of class
}//end of namespace
View Code

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM