in qldbdriver/communicator.go [72:84]
func (communicator *communicator) executeStatement(ctx context.Context, statement *string, parameters []*qldbsession.ValueHolder, txnID *string) (*qldbsession.ExecuteStatementResult, error) {
executeStatement := &qldbsession.ExecuteStatementRequest{
Parameters: parameters,
Statement: statement,
TransactionId: txnID,
}
sendInput := &qldbsession.SendCommandInput{ExecuteStatement: executeStatement}
result, err := communicator.sendCommand(ctx, sendInput)
if err != nil {
return nil, err
}
return result.ExecuteStatement, nil
}