0
我想要使用JPA/EclipseLink 2.4.1和MSSQL服務器使用Merlia驅動程序執行批量持久化。基於數據庫與日誌（下圖）一起反應的方式，每個插入看起來都發生在其自己的批次中。JPA批量更新似乎是插入每批更新
我已經設置了持久性的XML，如下所示：
<persistence xmlns="http://java.sun.com/xml/ns/persistence" version="2.0">
<persistence-unit name="EclipseLinkPersistenceUnit">
<provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
<class>com.mypackage.ViewInDatabaseEntity</class>
...
<exclude-unlisted-classes>true</exclude-unlisted-classes>
<properties>
<property name="javax.persistence.jdbc.driver" value="com.inet.tds.PDataSource4"/>
<property name="eclipselink.jdbc.batch-writing" value="jdbc" />
<property name="eclipselink.jdbc.batch-writing.size" value="1000" />
<property name="eclipselink.logging.level" value="FINEST"/>
</properties>
</persistence-unit>
</persistence>
代碼調用堅持這個樣子的。我通常使用@Transactional，但決定手動開始和提交事務，以確保註釋不會在底層做一些意想不到的事情。
//@Transactional
public void persistEntity(List<ViewInDatabaseEntity> entitiesToPersist) {
EntityManager entityManager = entityManagerProvider.get();
entityManager.setFlushMode(FlushModeType.COMMIT);
EntityTransaction transaction = entityManager.getTransaction();
transaction.begin();
for (ViewInDatabaseEntity entity : entitiesToPersist) {
entityManager.persist(entity);
}
transaction.commit();
}
日誌（設置爲FINEST）的輸出：
[EL Finer]: transaction: 2014-05-02 16:42:49.963--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--begin transaction
...
[EL Finest]: query: 2014-05-02 16:42:49.964--ClientSession(27801544)--Thread(Thread[qtp18824904-22,5,main])--Execute query ValueReadQuery(name="SEQ_GEN_SEQUENCE" sql="SELECT @@IDENTITY")
[EL Finer]: sql: 2014-05-02 16:42:56.422--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--Begin batch statements
[EL Fine]: sql: 2014-05-02 16:42:56.422--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--INSERT INTO dbo.ViewInDatabaseEntity(property1, property4, property3, property2, property5) VALUES (?, ?, ?, ?, ?)
[EL Fine]: sql: 2014-05-02 16:42:56.422--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])-- bind => [ABC, DEF, GHI, JKL, 0.3465443]
[EL Finer]: sql: 2014-05-02 16:42:56.422--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--End Batch Statements
[EL Fine]: sql: 2014-05-02 16:42:56.505--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--SELECT @@IDENTITY
[EL Finest]: sequencing: 2014-05-02 16:42:56.506--UnitOfWork(15091453)--Thread(Thread[qtp18824904-22,5,main])--assign sequence to the object (89,588 -> [email protected])
[EL Finest]: query: 2014-05-02 16:42:56.507--UnitOfWork(15091453)--Thread(Thread[qtp18824904-22,5,main])--Execute query InsertObjectQuery([email protected])
[EL Finest]: query: 2014-05-02 16:42:56.507--ClientSession(27801544)--Thread(Thread[qtp18824904-22,5,main])--Execute query ValueReadQuery(name="SEQ_GEN_SEQUENCE" sql="SELECT @@IDENTITY")
[EL Finer]: sql: 2014-05-02 16:42:56.507--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--Begin batch statements
[EL Fine]: sql: 2014-05-02 16:42:56.507--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--INSERT INTO dbo.ViewInDatabaseEntity(property1, property4, property3, property2, property5) VALUES (?, ?, ?, ?, ?)
[EL Fine]: sql: 2014-05-02 16:42:56.507--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])-- bind => [ABC, ZYX, WVU, RST, 0.35345634]
[EL Finer]: sql: 2014-05-02 16:42:56.507--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--End Batch Statements
[EL Fine]: sql: 2014-05-02 16:42:56.591--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--SELECT @@IDENTITY
[EL Finest]: sequencing: 2014-05-02 16:42:56.592--UnitOfWork(15091453)--Thread(Thread[qtp18824904-22,5,main])--assign sequence to the object (89,666 -> [email protected])
...
[EL Finer]: transaction: 2014-05-02 16:42:56.598--ClientSession(27801544)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--commit transaction
[EL Finest]: connection: 2014-05-02 16:42:56.605--ServerSession(2644459)--Connection(28732068)--Thread(Thread[qtp18824904-22,5,main])--Connection released to connection pool [default].
這似乎表明，每個刀片的是它自己的批次內發生的事情。根據persistence.xml;我已啓用
<property name="eclipselink.jdbc.batch-writing" value="jdbc" />
因此，據我所知，這些插入應作爲批處理髮生。 以下是我試圖堅持的實體。它作爲一個視圖覆蓋MSSQL Server數據庫中的幾個基礎表。
@javax.persistence.Table(name = "ViewInDatabase", schema = "dbo")
@Entity
@EqualsAndHashCode
@Getter
@Setter
public class ViewInDatabaseEntity {
@Id
@GeneratedValue(strategy = GenerationType.SEQUENCE)
private int id;
@javax.persistence.Column(name = "id", nullable = false, insertable = false, updatable = false,
length = 0, precision = 0)
@Basic
public int getId() {
return id;
}
@javax.persistence.Column(name = "property1", nullable = false, insertable = true,
updatable = true, length = 20, precision = 0)
@Basic
private String property1;
@javax.persistence.Column(name = "property2", nullable = true, insertable = true, updatable = true,
length = 0, precision = 0)
@Basic
private String property2;
@javax.persistence.Column(name = "property3", nullable = true, insertable = true,
updatable = true, length = 0, precision = 0)
@Basic
private String property3;
@javax.persistence.Column(name = "property4", nullable = false, insertable = true, updatable = true,
length = 10, precision = 0)
@Basic
private String property4;
@javax.persistence.Column(name = "property5", nullable = true, insertable = true, updatable = true,
length = 0, precision = 0)
@Basic
private BigDecimal property5;
@javax.persistence.Column(name = "property6", nullable = false, insertable = false,
updatable = false, length = 0, precision = 0)
@Basic
private int property6;
@javax.persistence.Column(name = "property7", nullable = false, insertable = false,
updatable = false, length = 0, precision = 0)
@Basic
private Date property7;
}