ADO 数据库的 导出和导入实例（从数据表导入到文件和把文本文件导入到数据库的数据表中）

using System;

using System.Collections.Generic;

using System.Linq;

using System.Web;

using System.Web.UI;

using System.Web.UI.WebControls;

using System.Data.SqlClient;

using System.IO;

namespace ADO详解11_26

{

public partial class Database_import_export : System.Web.UI.Page

{

protected void Page_Load(object sender, EventArgs e)

{

}

protected void btnimport_Click(object sender, EventArgs e)

{//从数据表导入到文件

string conStr = "data source=.;initial catalog=School; user Id=sa;password=liang68221";

using (SqlConnection con = new SqlConnection(conStr))

{

string sql = "select * from T_User";

using (SqlCommand cmd = new SqlCommand(sql, con))

{

con.Open();

using (SqlDataReader reader = cmd.ExecuteReader())

{

if (reader.HasRows)

{

//有数据被查询出

//当有数据的时候，就创建文本文件，并向其中写入数据。

using (StreamWriter sw = new StreamWriter(@"E:\学习成果\VS2010\ado学习1\ADO详解11、26\ADO详解11、26\tbuser.txt"))

{

while (reader.Read())

{

object userN = reader.GetValue(1);

object pwd = reader.GetValue(2);

string line = string.Format("{0}-{1}", userN, pwd);

sw.WriteLine(line);

}

Response.Write("导出完毕！");

}

}

else

{

Response.Write("数据表中没有数据，没有导出任何数据！");

}

}

}

}

}

protected void btnexport_Click(object sender, EventArgs e)

{

//1把文本文件导入到数据库的数据表中，先读取文本文件，然后再插入到数据库的数据表中

using (StreamReader sr = new StreamReader(@"E:\学习成果\VS2010\ado学习1\ADO详解11、26\ADO详解11、26\tbuser.txt"))

{

string conStr = "data source=.;initial catalog=School; user Id=sa;password=liang68221";

using (SqlConnection con = new SqlConnection(conStr))

{

string sql = "insert into T_User(FuserName,FpassWord) values(@username,@pwd)";

using (SqlCommand cmd = new SqlCommand(sql, con))

{

SqlParameter p1 = new SqlParameter("@username",System.Data.SqlDbType.VarChar);

SqlParameter p2 = new SqlParameter("@pwd", System.Data.SqlDbType.VarChar);

cmd.Parameters.Add(p1);

cmd.Parameters.Add(p2);

while (!sr.EndOfStream)

{

string line = sr.ReadLine();

string[] column = line.Split('-');

//将读出的的内容放到数据库中

//SqlParameter p1=new SqlParameter("@username",column[0]);

// SqlParameter p2=new SqlParameter("@pwd",column[1]);

con.Open();

p1.Value=column[0];

p2.Value=column[1];

cmd.ExecuteNonQuery();

con.Close();

}

Response.Write("导入到数据库已完毕");

}

}

}

}

}

}