访问 grails/hibernate 为域类生成的 SQL

Question

在我的 grails (1.3.7) 应用程序中，我使用 JDBC 模板从 CSV 文件批量导入 1000 条记录（因为它比使用普通 GORM/hibernate 快得多，正如您所期望的那样）。

例如

class Book {
    String title
}

和

// For each CSV record...
insertStatementList.add("insert into book (id, title) values (nextval('hibernate_sequence'), thetitle)")
...
JdbcTemplate bulkInsert = ...
bulkInsert.batchUpdate(insertStatementList)

这种方法的问题在于域类的更改（例如添加subject 属性）需要同时更改域类和 SQL 插入语句。

由于 GORM/hibernate 堆栈最终必须从域类定义派生 SQL，有没有办法访问此功能，以便我不必单独维护 SQL 插入语句？或者在伪代码中，可能类似于以下内容：

// would return something like:
// "insert into book (id, title) values (nextval('hibernate_sequence'), 'thetitle')"
def insertStatement = hibernate.getSqlInsertForClass(Book, book.properties)

Answer 1

我对 grails 的了解还不足以说明其中是否有可能。我尝试通过列出类属性并动态组合它来生成 SQL 插入字段，但它出现了乱序。

您可以创建一个注释来定义该字段在 CSV 中的位置：

import java.lang.annotation.*

@Retention(RetentionPolicy.RUNTIME) @interface CSV { int position() }

class Product {
  @CSV(position=1) String description
  @CSV(position=3) BigDecimal price
  @CSV(position=4) Integer type
  @CSV(position=2) boolean soldout
}

如果您需要多个映射（例如，为了支持您自己的旧 CSV），您应该考虑映射结构或 XML，这将与实体分离。

然后你需要迭代字段来组成查询：

def csv = '''rice;10.0;3;false
beet;12.0;2;false
mango;22.0;2;true'''

def properties = Product.declaredFields
  .findAll { it.declaredAnnotations }
  .sort { it.declaredAnnotations[0].position() }

def templateQuery = "INSERT INTO product(#fields) VALUES (#values)"

csv.eachLine { line ->
  def fields = line.split( /;/ )
  def sqlFields = [:]

  fields.eachWithIndex { field, i ->
    sqlFields[properties[i].name] = field
  }

  println templateQuery
    .replace('#fields', sqlFields.keySet().join(","))
    .replace('#values', sqlFields.values().join(","))
}

哪些打印：

INSERT INTO product(description,price,type,soldout) VALUES (rice,10.0,3,false)
INSERT INTO product(description,price,type,soldout) VALUES (beet,12.0,2,false)
INSERT INTO product(description,price,type,soldout) VALUES (mango,22.0,2,true)

它非常原始，需要一些修饰，例如引号和一些反对 sql 注入的东西，但它可以工作，更像是概念证明。

在我工作的旧系统中，我们使用 jboss seam 并且在我们使用 jpa 批处理的那些散装东西上，即在所有 persist() 完成后手动刷新。你确定 grails 上没有类似的东西可以与 gorm 一起使用吗？

This link 展示了一篇在 grails 中使用批量更新的博文，使用 withTransaction 同时定期应用会话清除：

    List <Person> batch =[]
    (0..50000).each{
       Person person= new Person(....)
        batch.add(person)
        println "Created:::::"+it
        if(batch.size()>1000){
            Person.withTransaction{
                for(Person p in batch){
                    p.save()
                }
            }
            batch.clear()
        }
      session = sessionFactory.getCurrentSession()
      session.clear()             
    }

你确定这不起作用？如果没有，那么注释可能是一个解决方案。

由于java的驼峰大小写和db中的下划线之间的差异，列命名也存在问题。在休眠状态下，该翻译背后的人是ImprovedNamingStrategy。也许你能从他那里得到一些东西。或者在 @CSV 注释中添加列名。听起来像是回收 JPA :-)。

还有log4jdbc，但我认为它不会解决你的问题：你需要潜入休眠sql生成。