CommitTransaction implements sql.TransactionSession.
(ctx *sql.Context, tx sql.Transaction)
| 116 | schema := provider.Pool().CurrentSchema(conn.ConnectionID) |
| 117 | if schema != "" { |
| 118 | logrus.Traceln("SessionBuilder: new session: current schema:", schema) |
| 119 | memSession.SetCurrentDatabase(schema) |
| 120 | } |
| 121 | |
| 122 | return NewSession(memSession, provider, opts...), nil |
| 123 | } |
| 124 | } |
| 125 | |
| 126 | var _ sql.TransactionSession = (*Session)(nil) |
| 127 | var _ sql.PersistableSession = (*Session)(nil) |
| 128 | var _ adapter.ConnectionHolder = (*Session)(nil) |
| 129 | |
| 130 | type Transaction struct { |
| 131 | memory.Transaction |
| 132 | tx *stdsql.Tx |