一:首先是Execl导入到数据库(数据库以2008为例)
需求:把Execl的数据导入到数据库。
方法:把Execl的数据导入到本地数据库,再从本地数据库读取数据,添加到要添加的数据库即可。
1,把Execl第一行命名,这里导入到数据库对应的是数据库的字段属性,下方的Execl名称对应的是数据库表名称。
2.链接本地数据库,把Excel的数据导入到数据库。如下图
选择要导入到的数据库名称,右键》任务》导入数据》弹出对话框,直接点击“下一步”
点击下一步
点击“下一步”》“完成”即可。就这么简单。
再看一下数据库就有数据啦:
3.下面就是读取本地的数据添加到要添加的数据库去。
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Reflection;
using System.Web;
using System.Web.UI;
using Whir.Framework;
using Whir.Repository;
using Whir.Service;
using System.Data;
using System.Collections.Generic;
using System.Text;
using System.Data.SqlClient;
using System.Configuration;
public partial class whir_system_import : System.Web.UI.Page
{
public int result = 0;
protected void Page_Load(object sender, EventArgs e)
{
string sql = "select Title,Content,AddDate,ishot from LHWeb_Collection where ClassID in(1,2,3,4)";
DataTable table = GetDataSet(sql);
if (table.Rows.Count > 0)
{
foreach (DataRow dr in table.Rows)
{
string title = Convert.ToString(dr["Title"].ToString());
string Content = Convert.ToString(dr["Content"].ToString());
DateTime CreateDate = Convert.ToDateTime(dr["AddDate"].ToString());
try
{
//string sqls = string.Format("INSERT INTO [dbo].[Whir_U_Content]([Title]--标题,[CategoryID]--信息类别 ,[IsDefault]--首页推荐,[IsTop]--置顶,[Content]--内容,[TypeID]--栏目ID,[State]--状态,[IsDel]--是否删除1,[CreateDate]--创建时间,[CreateUser]--admin,[UpdateUser]--admin)VALUES(‘{0}‘,6,{1},0,‘{2}‘,17,0,0,‘{3}‘,‘admin‘,‘admin‘)", title, IsDefault, Content, CreateDate);
string sqls = string.Format("insert into Whir_U_Content(Title,Content,CreateDate,IsDefault,IsTop,TypeID,IsDel,[State],SubjectID)values(‘{0}‘,‘{1}‘,‘{2}‘,0,0,140,0,0,0)", title, Content, CreateDate);
Bind(sqls);
}
catch (Exception ex)
{
Response.Write(ex + "返回值:" + result.ToString());
}
}
}
}
public void Bind(string sql)
{
result = DbHelper.CurrentDb.Execute(sql);
}
/// <summary>
/// 根据 SQL语句 查询数据
/// </summary>
/// <param name="sql">参数 接受一个 SQL语句</param>
/// <returns>返回 DataTable 类型</returns>
///
public static DataTable GetDataSet(string sql)
{
DataSet ds = new DataSet();
SqlCommand cmd = new SqlCommand(sql, Connection);
SqlDataAdapter sda = new SqlDataAdapter(cmd);//sqlDataAdapter用于填充DataSet
sda.Fill(ds);//向DataTable中添加数据
return ds.Tables[0];//获得表的集合
}
private static SqlConnection connection;
/// <summary>
/// 连接数据库
/// </summary><returns>返回 SqlConnection 对象</returns>
public static SqlConnection Connection
{
get
{
string connectionstring = ConfigurationManager.ConnectionStrings["conn"].ConnectionString.ToString();
if (connection == null)
{
connection = new SqlConnection(connectionstring);
connection.Open();
}
else if (connection.State == System.Data.ConnectionState.Closed)
{
connection.Open();
}
else if (connection.State == System.Data.ConnectionState.Broken)
{
connection.Close();
connection.Open();
}
return connection;
}
}
/// <summary>
/// 根据 SQL语句、预编译数组 查询得到的条数,执行查询,返回第一行第一列的值
/// </summary>
/// <param name="sql">参数 SQL 语句</param>
/// <param name="values">参数 预编译数组</param>
/// <returns>返回 int 类型</returns>
public static int GetScalar(string sql,params SqlParameter[] values)
{
SqlCommand cmd = new SqlCommand(sql,Connection);
cmd.Parameters.AddRange(values);
int result = Convert.ToInt32(cmd.ExecuteScalar());//cmd.ExecuteScalar()返回的是一个Ojbect类型的
return result;
}
//关闭数据库连接的方法
public static void CloesConnection()
{
try
{
if (connection.State != ConnectionState.Closed)
{
connection.Close();
}
}
catch (Exception e)
{
}
}
}