85
}
86
88
>
batch := h.Session.NewBatch(gocql.LoggedBatch).WithContext(ctx)
89
>
batch.Query(v2templateInsertTree,
90
>
branchInfo.TreeId,
91
>
branchInfo.BranchId,
92
>
treeInfoDataBlob.Data,
93
>
treeInfoDataBlob.EncodingType.String(),
94
>
)
95
>
batch.Query(v2templateUpsertHistoryNode,
96
>
branchInfo.TreeId,
97
>
branchInfo.BranchId,
98
>
node.NodeID,
99
>
node.PrevTransactionID,
100
>
node.TransactionID,
101
>
node.Events.Data,
102
>
node.Events.EncodingType.String(),
103
>
)
104
>
if err := h.Session.ExecuteBatch(batch); err != nil {
105
return convertTimeoutError(gocql.ConvertError("AppendHistoryNodes", err))
106
}
108
}
109