datatable数据数据库

❶ 如何将DataTable更新到数据库中

sqlDataAdapter adapter = new SqlDataAdapter(strSql, strConn);
SqlCommandBuilder builder = new SqlCommandBuilder(adapter);
DataSet ds = new DataSet();
adapter.Fill(ds, "Titles");

//插入记录
DataTable table = ds.Tables["Titles"];
DataRow row = table.NewRow();
row["Title_id"] = "JP1001";
row["title"] = "programming Microsoft .NET";
row["price"] = 59.99m;
row["ytd_sales"] = 100000;
row["type"] = "business";
row["pubdate"] = new DateTime(2002, 5, 1);
table.Rows.Add(row);
//更新数据库
adapter.Update(table);

❷ C# datatable 读取数据库

public SqlConnection getcon()
{
//连接本地数据库 server=localhost
string M_str_sqlcon = @"server=localhost;database=表名;Integrated Security=SSPI";
SqlConnection myCon = new SqlConnection(M_str_sqlcon);
return myCon;
}

/// <summary>
/// 创建一个DataTable对象
/// </summary>
/// <param name="M_str_sqlstr">SQL语句</param>
/// <param name="M_str_table">表名</param>
/// <returns>返回DataTable对象</returns>
DataTable mytable = new DataTable();
public DataTable gettable(string M_str_sqlstr)
{
SqlConnection sqlcon = this.getcon();
SqlDataAdapter sqlda = new SqlDataAdapter(M_str_sqlstr, sqlcon);

sqlda.Fill(mytable);
sqlcon.Close();
sqlcon.Dispose();
return mytable;
}
调用该方法:
DataTable mytable = gettable("select * from 表名")

❸ 怎么把DataTable里的值直接添加到数据库里

foreach(datarow dr in dt.rows)
{
string dym = dr["电影名"].toString();
......//类似的读取出 datatable里面的行的指定列的值；
Insert(参数);
}
public void Insert(string a,string b,string c,string,d,string e)
{
SqlConnetion sqlconn = new SqlConnection(“连接字符串");
sqlconn.open();
SqlCommand sqlcmd = new SqlCommand(sqlconn,"insert into biao values (a,b,c,d,e)");
sqlcmd.ExecuteNonQuery();
sqlconn.close();
}

❹ 数据是如何存入数据库中的

在一些数据量比较大，而且操作数据库频繁的。此时需要将数据表datatable整块的存入数据库中。

首先得新建一个数据库

DataTable once_rec_date = new DataTable();

这个数据库得跟目标数据库的列的位置和大小都得一样。特别是类型，和位置。就是列的位置和目标数据库的位置，顺序得 一模一样。因为都是块存储，所以地址什么的都得一样，千万不能少一列，自增列可以空在那边。

(4)datatable数据数据库扩展阅读

数据库入门基础知识：

数据库的分类

关系型数据库： 经过数学理论验证 可以保存现实生活中的各种关系数据， 数据库中存储数据以表为单位；非关系型数据库：通常用来解决某些特定的需求如：数据缓存，高并发访问。 存储数据的形式有多种，举例：Redis数据库：通过键值对的形式存储数据。

创建数据库：CREATE DATABASE database_name

删除数据库：DROP DATABASEdatabase_name

选择数据库：USEdatabase_name

创建数据表：CREATE TABLE table_name (column_name column_type)

删除数据表：DROP TABLE table_name

更新数据表信息：

添加表字段：ALTER TABLE table_name ADD new_column DATATYPE

使用FIRST关键字可以将新增列的顺序调整至数据表的第一列：ALTER TABLE table_name ADD new_column DATATYPE FIRST

使用AFTER关键字可以将新增列调整至数据表的指定列之后：ALTER TABLE table_name ADD new_column DATATYPE AFTER old_column

❺ .net如何将datatable数据保存到sql数据库

//1、使用sqlbulk.writetoserver(datatable)
SqlBulkCopysqlbulk=newSqlBulkCopy(connectionString,SqlBulkCopyOptions.UseInternalTransaction);
sqlbulk.DestinationTableName="Table_1";//数据库中的表名
sqlbulk.WriteToServer(dataset.Tables[0]);
//2、使用sqlcommand.executenonquery()方法插入
foreach(DataRowdatarowindatatable.Rows)
{
stringsql="INSERTINTO[Table_1]
([CompanyName],[CompanyCode],[Address],[Owner],[Memo])"+
"VALUES('"+datarow["CompanyName"].ToString()+"'"+
",'"+datarow["CompanyCode"].ToString()+"'"+
",'"+datarow["Address"].ToString()+"'"+
",'"+datarow["Owner"].ToString()+"'"+
",'"+datarow["Memo"].ToString()+"')";
using(SqlConnectionsqlconn=newSqlConnection(connectionString))
{
sqlconn.Open();
SqlCommandsqlcommand=newSqlCommand(sql,sqlconn);
sqlcommand.ExecuteNonQuery();
sqlconn.Close();
}
}
使用sqldataadapter.update(dataset,tablename);
SqlCommandinsertcommand=newSqlCommand("INSERTINTO[Table_1]([CompanyName],[CompanyCode],[Address],[Owner],[Memo])"+
"VALUES(@CompanyName,@CompanyCode,@Address,@Owner,@Memo)",newSqlConnection(connectionString));
insertcommand.Parameters.Add("@CompanyName",SqlDbType.NChar,50,"CompanyName");
insertcommand.Parameters.Add("@CompanyCode",SqlDbType.NChar,25,"CompanyCode");
insertcommand.Parameters.Add("@Address",SqlDbType.NChar,255,"Address");
insertcommand.Parameters.Add("@Owner",SqlDbType.NChar,25,"Owner");
insertcommand.Parameters.Add("@Memo",SqlDbType.NChar,255,"Memo");
sqldataadapter.InsertCommand=insertcommand;
sqldataadapter.Update(dataset,"Table_1");
使用sqlbulk.writetoserver(datatable)
SqlBulkCopysqlbulk=newSqlBulkCopy(connectionString,SqlBulkCopyOptions.UseInternalTransaction);
sqlbulk.DestinationTableName="Table_1";//数据库中的表名
sqlbulk.WriteToServer(dataset.Tables[0]);

❻ 如何把DataTable快速写入数据库

JDBC操作数据库其实只要掌握了六大步骤就基本差不多啦：

1.加载驱动

Class.forName(String);

String(驱动器的名称，分oracle,sql server等数据库驱动)

2.创建连接

DriverManager.getConnection(url,userName,passwd);

url是数据库的地址,后面分别是用户名和密码

3.创建会话statement(三种statement)

stmt(Statement):所有stmt的父类从connection对象获得，主要用于解析执行sql语句，返回响应结果，多执行异构的sql语句
pstmt(preparedStatement):主要用于执行同构的sql语句，stmt的子类。
cstmt:主要用于执行plsql的编程对象

4.执行sql语句

executeQuery();

5.处理结果集(有结果集返回，无则可省去，比如插入和删除)

ResultSet rs = 步骤4的结果

6.释放资源即连接，一般些在finally语句块中，目的是减轻服务器的压力

❼ C#如何将datatable中的数据批量更新到MYSQL数据库

C#利用update更新数据到oracle数据库：
第一步：打开oracle数据库
public static string connString = "";
public static OracleConnection conn = null;

//打开数据库连接
public static bool Open()
{
//从配置文件中获取连接字符串
//配置文件需要放在项目目录下的bin\Release中
connString = getXmlValue("connString");
conn = new OracleConnection(getXmlValue("connString"));
try
{
conn.Open();
Console.WriteLine("数据库连接成功");
return true;
}
catch (System.Exception ex)
{
Console.Write(ex.Message);
MessageBox.Show("未能连接到数据库");
return false;
}
第二步：执行更新方法：
public static int update(int ruleId, int equipmentId, String equipmentName, String propertyName, int ruleType, String ruleRequest, String ruleRequestOther, String ruleExplain)
{
String sql = "update Device_Attr t set t.BASEID = :equipmentId, t.BASENAME = :equipmentName,t.CA_NAME = :propertyName,t.CA_RULETYPE = :ruleType,t.CA_RULETEXT = :ruleRequest,t.CA_RULETEXT2 = :ruleRequestOther,t.CONTENT = :ruleExplain where t.CA_ID =:ruleId";
OracleCommand cmd = new OracleCommand(sql, conn);
OracleParameter param_1 = new OracleParameter(":equipmentId", equipmentId);
cmd.Parameters.Add(param_1);
OracleParameter param_2 = new OracleParameter(":equipmentName", equipmentName + "$");
cmd.Parameters.Add(param_2);
OracleParameter param_3 = new OracleParameter(":propertyName", propertyName);
cmd.Parameters.Add(param_3);
OracleParameter param_4 = new OracleParameter(":ruleType", ruleType);
cmd.Parameters.Add(param_4);
OracleParameter param_5 = new OracleParameter(":ruleRequest", ruleRequest);
cmd.Parameters.Add(param_5);
OracleParameter param_6 = new OracleParameter(":ruleRequestOther", ruleRequestOther);
cmd.Parameters.Add(param_6);
OracleParameter param_7 = new OracleParameter(":ruleExplain", ruleExplain);
cmd.Parameters.Add(param_7);
OracleParameter param_8 = new OracleParameter(":ruleId", ruleId);
cmd.Parameters.Add(param_8);
int result = cmd.ExecuteNonQuery();
return result;
}