
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(); } } }

/* 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