300分 寻求解决方案? 批量插入数据库的问题!???
2004-10-24 23:55
288 查看
因为我现在要做的一考试系统,当考试结束的时候,有4、5百人同时要交卷,每一份卷子都有100多条记录要插入。。。 所以就存在了并发性的问题!? 一条一条的插入会有好多人都交不了卷而出错的! 故特发此贴,希望有识之士能助小弟一把! 不甚感激!!!
在我们平时的开发过程中,经常要向数据库插入数据,有时可能要进行很多次类似的操作,比如向数据库中的同一个表同时插入若干数据,即批量插入数据。
向数据库中批量插入数据,可以将若干条数据一次插入道数据库,提高程序的执行效率,也可以减少我们的工作量。
批量插入数据,可以采用一下两种方法。
一、利用事务(Transaction)
‘定义执行批量插入数据的函数,参数为Insert SQL语句的数组
Sub ExeTransaction (Byval Sqlstrlist as string())
Dim Conn As String =
"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Tax.mdb"
Dim trans as OledbTransaction=Nothing
Try
If conn.State=connectionstate.closed then
Conn.open()
End if
Dim cmd as oledbCommand=new oledbcommand()
cmd.connection=conn
cmd.commandtype=commandtype.text
trans=conn.BeginTransaction()
cmd.Transaction=trans
dim I as integer
for I=0 to Sqlstrlist.GetupperBound(0)
cmd.commandText= Sqlstrlist(i) ‘取得参数(数组)中的值
cmd.ExecuteNonQuery()
Next
Trans.commit()
Catch ex as oledbexception
Trans.Rollback()
Fanlly
Conn.close()
End try
End sub
二、利用Dataset
public sub Insert()
‘建立datatable数据源
dim dt as DataTable=New DataTable()
Dim dr as DataRow
Dt.Columns.Add(new DataColumn(“name”))
Dim j as Integer
For j =0 to 10
Dr=dt.newrow()
Dr(0)=”name”+j.toString
Dt.Rows.Add(dr)
Next
Dim Conn As String = "Provider=Microsoft.Jet.OLEDB.4.0;Data
Source=Tax.mdb"
Conn.open()
Dim MyAdapter as Oledbdataadapter=new OleDataAdapter()
….
Dim cmd as Oledbcommand=New Oledbcommand(“Insert Into table(name)
values (@name)”,conn)
cmd.parameters.item(“@name”).SourceColumns=dt.columns(“name”).columnsName
myAdapter.update(dt)
conn.close()
end sub
利用以上的两种方法,都可以完成向数据库批量插入数据。
如果再不行的话用MSMQ吧。客户机提交给服务器后,将记录放在队列中,然后服务器在有空时从队列中取数据插入到数据库。
在我们平时的开发过程中,经常要向数据库插入数据,有时可能要进行很多次类似的操作,比如向数据库中的同一个表同时插入若干数据,即批量插入数据。
向数据库中批量插入数据,可以将若干条数据一次插入道数据库,提高程序的执行效率,也可以减少我们的工作量。
批量插入数据,可以采用一下两种方法。
一、利用事务(Transaction)
‘定义执行批量插入数据的函数,参数为Insert SQL语句的数组
Sub ExeTransaction (Byval Sqlstrlist as string())
Dim Conn As String =
"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Tax.mdb"
Dim trans as OledbTransaction=Nothing
Try
If conn.State=connectionstate.closed then
Conn.open()
End if
Dim cmd as oledbCommand=new oledbcommand()
cmd.connection=conn
cmd.commandtype=commandtype.text
trans=conn.BeginTransaction()
cmd.Transaction=trans
dim I as integer
for I=0 to Sqlstrlist.GetupperBound(0)
cmd.commandText= Sqlstrlist(i) ‘取得参数(数组)中的值
cmd.ExecuteNonQuery()
Next
Trans.commit()
Catch ex as oledbexception
Trans.Rollback()
Fanlly
Conn.close()
End try
End sub
二、利用Dataset
public sub Insert()
‘建立datatable数据源
dim dt as DataTable=New DataTable()
Dim dr as DataRow
Dt.Columns.Add(new DataColumn(“name”))
Dim j as Integer
For j =0 to 10
Dr=dt.newrow()
Dr(0)=”name”+j.toString
Dt.Rows.Add(dr)
Next
Dim Conn As String = "Provider=Microsoft.Jet.OLEDB.4.0;Data
Source=Tax.mdb"
Conn.open()
Dim MyAdapter as Oledbdataadapter=new OleDataAdapter()
….
Dim cmd as Oledbcommand=New Oledbcommand(“Insert Into table(name)
values (@name)”,conn)
cmd.parameters.item(“@name”).SourceColumns=dt.columns(“name”).columnsName
myAdapter.update(dt)
conn.close()
end sub
利用以上的两种方法,都可以完成向数据库批量插入数据。
xml... 每个人都会在客户端提交的过程中形成相应的XML文件 学号:9527 文件名: 9527.xml 等提交结束后,利用循环 讲所有xml写入数据库 |
首先,必须采用三层结构模式 我的一个同学所在的公司做跑马场的系统,在跑马的5分钟左右的间歇里头,大约有上千个投注点进行连接投注,每个投注点少说也有上百个单,人家采用了IBM的中间件技术,从没有出过问题 前台提交给中间件,然后中间件启动线程排队等候,只要前台提交成功而且数据完整,中间件就返回正确完成信息,剩余的工作交给中间件的线程完成。 在中间件中,也可以生成XML文件进行记录尚未写入数据库的缓存,以防备数据丢失 |
COM+就是为了解决这个问题诞生的。 你看看这方面资料,把提交的部分作一个服务端,再用客户端去调用。 所有并发问题微软的前辈都比较好的解决了,包括消息队列、多线程并发等等,根本用不着操心,呵呵。 |
相关文章推荐
- sql 批量插入(一个数据库的表数据,添加到另一个数据库表) 数据类型nText和varchar在运算符equals不兼容的问题解决方案
- 启用事务操作,解决批量插入或更新sqlite,mssql等数据库耗时问题
- 数据库批量数据插入问题分析
- 数据库插入超时问题的一个原因和解决方案
- 数据库批量数据插入问题分析
- 数据库批量数据插入问题分析
- 启用事务操作,解决批量插入或更新sqlite,mssql等数据库耗时问题
- 启用事务操作,解决批量插入或更新sqlite,mssql等数据库耗时问题
- 启用事务操作,解决批量插入或更新sqlite,mssql等数据库耗时问题
- 启用事务操作,解决批量插入或更新sqlite,mssql等数据库耗时问题
- 数据库批量数据插入问题分析
- 数据库 从 临时表 批量插入 并且 生成id 的问题
- 数据库批量数据插入问题分析
- 启用事务操作,解决批量插入或更新sqlite,mssql等数据库耗时问题 分类: .NET 2015-06-18 14:39 31人阅读 评论(0) 收藏
- 启用事务操作,解决批量插入或更新sqlite,mssql等数据库耗时问题
- 【转载】struts+spring+hibernate无法插入数据库数据的问题
- 连接数据库时常见的问题及解决方案
- MySQL 连接数据库出现问题时的解决方案。
- 利用数据库的存储过程批量建表和批量插入数据
- 如何解决程序中新插入ACCESS数据库表的记录无法及时在数据库中更新的问题。