func()

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
}