Docker/documize
Docker/documize
1
0
Fork 0
mirror of https://github.com/documize/community.git synced 2025-07-24 15:49:44 +02:00
Code Releases Activity

Reuse ctx.Transaction during search index operations

Browse source
This commit is contained in:
Harvey Kandola 2018-04-11 14:29:33 +01:00
parent cc7bcc31be
commit a3157749f0
1 changed files with 12 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

24
domain/search/search.go
View file

@ -24,7 +24,7 @@ func (m *Indexer) IndexDocument(ctx domain.RequestContext, d doc.Document, a []a
method := "search.IndexDocument"
var err error
tx, err := m.runtime.Db.Beginx()
ctx.Transaction, err = m.runtime.Db.Beginx()
if err != nil {
m.runtime.Log.Error(method, err)
return
@ -32,12 +32,12 @@ func (m *Indexer) IndexDocument(ctx domain.RequestContext, d doc.Document, a []a
err = m.store.Search.IndexDocument(ctx, d, a)
if err != nil {
tx.Rollback()
ctx.Transaction.Rollback()
m.runtime.Log.Error(method, err)
return
}
tx.Commit()
ctx.Transaction.Commit()
}
// DeleteDocument removes all search entries for document.
@ -45,7 +45,7 @@ func (m *Indexer) DeleteDocument(ctx domain.RequestContext, ID string) {
method := "search.DeleteDocument"
var err error
tx, err := m.runtime.Db.Beginx()
ctx.Transaction, err = m.runtime.Db.Beginx()
if err != nil {
m.runtime.Log.Error(method, err)
return
@ -53,12 +53,12 @@ func (m *Indexer) DeleteDocument(ctx domain.RequestContext, ID string) {
err = m.store.Search.DeleteDocument(ctx, ID)
if err != nil {
tx.Rollback()
ctx.Transaction.Rollback()
m.runtime.Log.Error(method, err)
return
}
tx.Commit()
ctx.Transaction.Commit()
}
// IndexContent adds search index entry for document context.
@ -67,7 +67,7 @@ func (m *Indexer) IndexContent(ctx domain.RequestContext, p page.Page) {
method := "search.IndexContent"
var err error
tx, err := m.runtime.Db.Beginx()
ctx.Transaction, err = m.runtime.Db.Beginx()
if err != nil {
m.runtime.Log.Error(method, err)
return
@ -75,12 +75,12 @@ func (m *Indexer) IndexContent(ctx domain.RequestContext, p page.Page) {
err = m.store.Search.IndexContent(ctx, p)
if err != nil {
tx.Rollback()
ctx.Transaction.Rollback()
m.runtime.Log.Error(method, err)
return
}
tx.Commit()
ctx.Transaction.Commit()
}
// DeleteContent removes all search entries for specific document content.
@ -88,7 +88,7 @@ func (m *Indexer) DeleteContent(ctx domain.RequestContext, pageID string) {
method := "search.DeleteContent"
var err error
tx, err := m.runtime.Db.Beginx()
ctx.Transaction, err = m.runtime.Db.Beginx()
if err != nil {
m.runtime.Log.Error(method, err)
return
@ -96,10 +96,10 @@ func (m *Indexer) DeleteContent(ctx domain.RequestContext, pageID string) {
err = m.store.Search.DeleteContent(ctx, pageID)
if err != nil {
tx.Rollback()
ctx.Transaction.Rollback()
m.runtime.Log.Error(method, err)
return
}
tx.Commit()
ctx.Transaction.Commit()
}