ОСНОВНЫЕ ТЕМЫ
АРХИВ ПО ТЭГУ "GRAILS"
Первый нах!
Hi,
peopools, whatsup?
Я тут заимплементил пруф оф консепт (ПОК) нашего группового задания (хотя все пришлось писать одному 
) за пару послерабочих вечеро-ночей на Grails + MySQL. Суть системы: University Admission Process, вобщем-то функционал для ПОКа минимальный: 0) разделение юзеров по ролям, 1) посылка сообщений, 2) загрузка документов, 3) менеджмент юзеров, 4) редактирование своего профиля.
Код выложил на гитхаб может кому интересно будет: https://github.com/chupakabr/uol-sp-poc. Баги там есть, я даже знаю о них, но не скажу никому, сами найдутся
Выглядит эта ботва примерно так (индекс пейж):
Такие дела.
Ушел курить бамбук.
Hi,
Рябы рябские, как дела?
Меня тут вдруг запарила проблема с оптимистик локинг фейлур (StaleObjectStateException, OptimisticLockingFailureException, HibernateOptimisticLockingFailureException) в Grails, когда слишком частые запросы на сервер приводят к синхронному обновлению домена в персистенс, что в свою очередь приводит к падению одного из запросов, т.к. version уже обновлен другим потоком (запросом). Собсно я решил написать небольшой хелпер для сохранения доменов, в итоге это оказало не хелпером, а заижекченым методом во все доменные классы проекта. Ща покажу как это юзается, а потом уже саму имплементацию.
Домен
-
// по дефолту в грейлс каждый домен
-
// юзает optimistic locking, используя
-
// version колонку (проперти)
-
class Something {
-
String name
-
String value
-
}
Стандартное сохранение домена
-
// загружаем и обновляем значение
-
def e = Something.get(1)
-
-
// если в этот момент другой запрос (поток) обновит
-
// эту запись, то грейлс кинет StaleObjectStateException
-
e.value = "asdasd"
-
e.save flush: true, failOnError: true
Сохранение с optimistic locking with retry вариант 1
-
// загружаем и обновляем
-
def e = Something.get(1)
-
-
// если в этот момент другой запрос (поток) обновит
-
// эту запись, то мы рефрешнем запись в сессии и
-
// попробуем обновить еще разок
-
e.saveOptimisticWithRetry flush: true, failOnError: true, retryCount: 2, { obj ->
-
obj.value = "asd"
-
}
Сохранение с optimistic locking with retry вариант 2
-
// все параметры опциональны, их можно опустить
-
// по дефолту:
-
// retryCount = 2
-
// flush = false
-
// failOnError = true
-
def e = Something.get(1)
-
e.saveOptimisticWithRetry retryCount: 5, { obj ->
-
obj.value = "asd"
-
}
Сохранение с optimistic locking with retry вариант 3
-
// все параметры опциональны, их можно опустить
-
def e = Something.get(1)
-
e.saveOptimisticWithRetry { obj ->
-
obj.value = "asd"
-
}
Имплементация optimistic locking with retry
-
// в Bootstrap.groovy к примеру можно
-
// заинжектить метод во все домены
-
for (dc in grailsApplication.domainClasses) {
-
dc.metaClass.saveOptimisticWithRetry = { args = null, setter ->
-
final int retryCount = args?.containsKey('retryCount') ? args.retryCount : 2
-
final boolean failOnError = args?.containsKey('failOnError') ? args.failOnError : true
-
final boolean flush = args?.containsKey('flush') ? args.flush : true
-
-
int i = 0
-
while (true) {
-
try {
-
// Save domain
-
setter(delegate)
-
delegate.save(failOnError: failOnError, flush: flush)
-
return
-
}
-
catch (StaleObjectStateException e) {
-
// Throw exception if retry count bounds reached
-
if (++i > retryCount) {
-
throw e
-
}
-
-
// Refresh object within session
-
delegate.refresh()
-
}
-
}
-
}
-
}
—
Хорошего дня!
PS Можно вобщем-то подменить и сам метод save() у доменов, добавив в него имплементацию ретрая при оптимистик логинг фейлуре ексепшене.
Hi,
Just a note: А вы знали, что Grails не будет создавать индексы в базе (например, строковые), если в датасурсе (DataSource.groovy) прописан режим dbCreate = «update», индексы буду создавать только при dbCreate = «create» или dbCreate = «create-drop».
Hey.
Grails замечательная штука, но иногда чтобы понять как оно работает, нужно все таки в код посмотреть
Например задача: нужно на один и тот же урл в зависимости от HTTP метода заюзать различные контроллеры. Для различных экшенов и одного контроллера это делается легко:
«/api/stuff/$id» (controller: 'stuff') {
-
action = [ GET: 'show', PUT: 'update', DELETE: 'delete' ]
-
}
Т.е. на «/api/stuff/123 DELETE» мы вызовем StuffController::deleteAction().
А мы хотим различные контроллеры:
- «/api/stuff/123 DELETE» мы вызовем StuffCustomController::deleteAction(),
- для остальных хттп методов: ApiController::stuffAction().
Тогда нужно немножко копнуть в грейлс код. В таком замечательном интерфейсе как org.codehaus.groovy.grails.web.mapping.UrlMapping можно увидеть, что в getActionName() и getControllerName() возвращается Closure или String. Собсно нас интересует closure. Раз это замыкание, то мы легко можем сделать свитч по текущему методу из реквест объекта и таким образом динамически сказать какой контроллер нужно бы сейчас заюзать.
В итоге:
«/api/stuff/$id» {
-
controller = {
-
switch (request?.method) {
-
case 'DELETE':
-
return 'stuffCustom'
-
default:
-
return 'api'
-
}
-
}
-
action = {
-
switch (request?.method) {
-
case 'DELETE':
-
return 'delete'
-
default:
-
return 'stuff'
-
}
-
}
-
}
Hi.
Ох уж этот оракл, юзабильность это не о нем.
На этот раз проблема с Oracle 9i драйвером для Java. Возникла проблема сохранения CLOB / BLOB данных в базу, используя драйвер для Oracle 9i. На 10g все вроде как даже работает..
Так вот когда пытаешься работать с CLOB / BLOB, то возникают различные ексепшены типа
- java.sql.SQLException: Data size bigger than max size for this type: 50584
- java.sql.SQLException: operation not allowed: streams type cannot be used in batching
Аха, можете попробовать, ни для какого типа данных у меня не получилось сохранить большой объект простым способом. А я пробовал много чего: CLOB, BLOB, LONG, LONG RAW. Но фига — больше 4-50kb не сохраняет.
В итоге пришел к изврашенному решению описанному где то в потайных документациях оракла. Решение использует Java JDBC для сохранения модели если это оракл драйвер версии 9. Для других баз и других версий оракла будет использоваться стандартное сохранение доменного класса Grails.
—
Моделька Grails
package my.com
-
-
class MyDomain {
-
-
String bigData
-
-
static constraints = {
-
bigData(maxSize: 1024 * 1024) // 1 MB
-
}
-
-
static mapping = {
-
bigData type:"text" // this will create CLOB data type column
-
}
-
}
—
Методы сервиса для сохранения большого CLOB’а
def isOracle9Driver = {
-
boolean isOracle9 = false
-
-
try {
-
Connection conn = sessionFactory.getCurrentSession().connection()
-
DatabaseMetaData dbmd = conn.getMetaData()
-
-
if (dbmd != null) {
-
String dbName = dbmd.getDatabaseProductName()
-
String dbDriverVer = dbmd.getDriverVersion()
-
-
if ("Oracle".equals(dbName) && (dbDriverVer != null && dbDriverVer.startsWith("9."))) {
-
isOracle9 = true
-
}
-
}
-
} catch (Exception e) {
-
log.warn "Error getting DB Driver version — " + e.getMessage()
-
e.printStackTrace()
-
}
-
-
return isOracle9
-
}
-
-
def saveMyDomain(def bigData) {
-
-
// RAW SQL USING JDBC FOR Oracle 9i DRIVER
-
if (isOracle9Driver()) {
-
-
Connection conn = sessionFactory.getCurrentSession().connection()
-
PreparedStatement stmt
-
CallableStatement callableStmt
-
-
try {
-
-
//
-
// Insert new entry with empty clob
-
String sql = "BEGIN INSERT INTO my_domain (id,version,big_data) values (HIBERNATE_SEQUENCE.NEXTVAL,1,empty_clob()) RETURNING id INTO ?; END;"
-
callableStmt = conn.prepareCall(sql)
-
callableStmt.registerOutParameter(1, Types.INTEGER);
-
callableStmt.executeUpdate()
-
-
long newId = callableStmt.getLong(1)
-
if (newId < 0) {
-
throw new IllegalStateException("Cannot get autogenerated ID of my_domain: got id=" + newId)
-
}
-
callableStmt.close()
-
-
//
-
// Select for update
-
sql = "SELECT big_data FROM my_domain WHERE id=? FOR UPDATE"
-
stmt = conn.prepareStatement(sql)
-
stmt.setLong(1, newId)
-
-
ResultSet rss = stmt.executeQuery()
-
if (!rss.next()){
-
throw new IllegalStateException("Cannot get result for 'select for update' of my_domain")
-
}
-
-
//
-
// Update create entry with clob data
-
CLOB clob = (CLOB) rss.getClob("big_data")
-
clob.putString(1, bigData)
-
-
sql = "UPDATE my_domain SET big_data=? WHERE id=?"
-
stmt = conn.prepareStatement(sql)
-
stmt.setClob(1, clob)
-
stmt.setLong(2, newId)
-
stmt.executeUpdate()
-
stmt.close()
-
-
conn.commit()
-
-
} catch (Exception e) {
-
log.error "Cannot save my_domain — " + e.getMessage()
-
e.printStackTrace()
-
conn.rollback()
-
} finally {
-
if (callableStmt != null) callableStmt.close()
-
if (stmt != null) stmt.close()
-
}
-
} else {
-
// DOMAIN CLASS SAVE
-
new MyDomain(
-
bigData: bigData
-
).save(flush:true)
-
}
-
}