草庐IT

高速批量插入

全部标签

java - 从postgresql中批量插入的行中检索序列号

这是有效的代码:Connectionc=ds.getConnection();c.setAutoCommit(false);PreparedStatementstmt=c.prepareStatement("INSERTINTOitems(name,description)VALUES(?,?)");while(!(items=bus.take()).isEmpty()){for(Itemitem:items){stmt.setString(1,item.name);stmt.setString(2,item.description);stmt.addBatch();}stmt.exe

java - 使用 Apache POI 将列标签插入数据透视表?

我使用ApachePOI3.11创建了一个数据透视表。像这样:FileInputStreamfile=newFileInputStream(newFile(path+fname));XSSFWorkbookworkbook=newXSSFWorkbook(file);XSSFSheetsheet=workbook.getSheetAt(0);//areaofpivotdataAreaReferencea=newAreaReference("A1:J4");CellReferenceb=newCellReference("N5");XSSFPivotTablepivotTable=she

java - Spring-Hibernate 坚持不导致插入

我正在尝试实现一个简单的DAO。我有道:@Repository("iUserDao")@Transactional(readOnly=true)publicclassUserDaoimplementsIUserDao{privateEntityManagerentityManager;@PersistenceContextpublicvoidsetEntityManager(EntityManagerentityManager){this.entityManager=entityManager;}@OverridepublicUsergetById(intid){returnentit

java - Apache Camel 示例在表中插入一行

我想将exchange.body插入到数据库表中,作为我的路线条件之一。有没有camel-jdbc组件插入消息体的例子/教程?我可以导入SQL语句本身并将exchange.body传递给它吗?我看了http://camel.apache.org/jdbc.html例如,但无法理解。这里的Spring示例让我感到困惑。我不明白为什么将正文设置为SQL查询并再次从类路径中导入一些查询。(这里没有提到插入查询的例子。) 最佳答案 如果您想使用相同的语句插入(仅更改参数)-使用SQLcomponent.如果您想使用任意SQL语句插入组件-使

java - 验证 spring JDBC 批量更新是否成功

我正在使用SpringJDBCTemplatebatchUpdate批量插入数据。我想验证数据是否已成功插入。JDBCTemplatebatchUpdate返回一个int[][],那么验证数据插入的正确方法是什么?这link说“所有批处理更新方法都返回一个int数组,其中包含每个批处理条目受影响的行数。此计数由JDBC驱动程序报告,它并不总是可用,在这种情况下,JDBC驱动程序仅返回-2值”。我无法理解在这里返回-2值的意义。是插入不成功吗? 最佳答案 -2不一定表示错误,可能如前所述,受影响行数的情况不可用。编辑-2是Statem

java - 通过 JAXB 将链接插入到 RESTEasy XML 结果中

我想通过RESTeasy/JAXB将链接插入到XML中。我尝试使用documentation对于我的代码,但这不起作用,所以我只是对文档中给定的示例进行编码:它仍然不起作用,我不知道为什么。背景:为了在我的JBossRESTEasyAPI中实现HATEOAS原则,我必须将链接插入到我的JAXBXML结果中,以便客户可以在API中导航。我现在正试图了解如何做到这一点,但我不确定documentation是否充满错误或者我无法理解示例和解释:不清楚的东西:据我了解,您必须使用@AddLinks来声明结果应该插入链接。然后我必须再次冗余(!?)使用@LinkResource和“有时”指定UR

java - Cassandra 批量查询与单次插入性能

我使用Cassandrajava驱动程序。我每秒收到150k个请求,我将这些请求插入到具有不同分区键的8个表中。我的问题是哪种方法更好:批量插入这些表一个一个插入。我问这个问题是因为,考虑到我的请求大小(150k),批处理听起来是更好的选择,但因为所有表都有不同的分区键,批处理看起来很昂贵。 最佳答案 请从以下链接查看我的回答:Cassandrabatchqueryperformanceontableshavingdifferentpartitionkeys批处理不是为了提高性能。它们用于确保原子性和隔离性。Batchingcanb

java - 批量解压.gz文件

我有100个.gz文件需要解压缩。我有几个问题a)我正在使用http://www.roseindia.net/java/beginners/JavaUncompress.shtml给出的代码解压缩.gz文件。它工作正常。任务:-有没有办法获取压缩文件的文件名。我知道Java的Zip类提供了要处理的输入文件的枚举。这可以给我存储在.zip文件中的文件名、大小等。但是,我们对.gz文件是否有相同的文件名,或者文件名是否与filename.gz相同但删除了.gz。b)是否有另一种通过调用java代码中的实用函数来解压缩.gz文件的优雅方法。就像从您的java类调用7-zip应用程序一样。然后

java - 如何删除 ThreadPoolExecutor 中的旧排队任务并插入新任务?

我使用ThreadPoolExecutor从互联网加载大量图像。当找到新图像时,我需要先渲染它,在这种情况下我想放弃仍在ThreadPoolExecutor中排队的旧任务并添加这些新项目进行下载。我发现ThreadPoolExecutor中没有“clearqueue”方法,“purge”方法听起来不太好。我该怎么办?我只是想调用这个执行器的“关闭”并重新创建一个新的执行器来执行此操作,不确定是否合适。 最佳答案 你试过吗?ThreadPoolExecutorpool=.....;pool.remove(task);task是您要删除

java - 尝试插入重复键时抛出正确的异常?

我反复看到关于避免抛出通用RuntimeException的评论,我正在努力遵循该指南。我有一个类将SortedMap与属性设置聚合在一起以允许或禁止重复键。我试图弄清楚当不允许重复键并尝试添加一个时我应该抛出什么异常。我检查了Exception类的Java文档,发现没有一个已知的直系后代适合。我是否只是继续创建自己的EDuplicateMapKey类并抛出它?如果是这样,我如何避免以一大堆类文件结束,每个自定义Exception类型一个?什么是这里的“最佳实践”? 最佳答案 创建您自己的异常(exception)。例如JavaEE