| | |
|---|
| | | // } |
|---|
| | | // return result; |
|---|
| | | // } |
|---|
| | | // 打开连接并开启事务 |
|---|
| | | public (OracleConnection, OracleTransaction) BeginTransaction() |
|---|
| | | { |
|---|
| | | var connection = new OracleConnection(_connectionString); |
|---|
| | | connection.Open(); |
|---|
| | | var transaction = connection.BeginTransaction(); |
|---|
| | | return (connection, transaction); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 关闭连接（提交或回滚后用） |
|---|
| | | public void CloseConnection(OracleConnection connection) |
|---|
| | | { |
|---|
| | | if (connection != null && connection.State != ConnectionState.Closed) |
|---|
| | | { |
|---|
| | | connection.Close(); |
|---|
| | | connection.Dispose(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | public object ExecuteScalarWithTransaction(OracleConnection conn, OracleTransaction tran, string sql, params OracleParameter[] parameters) |
|---|
| | | { |
|---|
| | | using (var cmd = conn.CreateCommand()) |
|---|
| | | { |
|---|
| | | cmd.Transaction = tran; |
|---|
| | | cmd.CommandText = sql; |
|---|
| | | if (parameters != null) |
|---|
| | | { |
|---|
| | | cmd.Parameters.AddRange(parameters); |
|---|
| | | } |
|---|
| | | return cmd.ExecuteScalar(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
