123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293 |
- using Npgsql;
- using System;
- using System.Collections.Generic;
- using System.Data;
- using System.Linq;
- using System.Text;
- using System.Threading.Tasks;
- using WWPipeLine.Commons;
- namespace WWPipeLine.MapBasic
- {
- public class NpgsqlHelper
- {
- public NpgsqlHelper() { }
- public static string ConStr = ComsStatic.ConfigsNpgsql;
- public int ExecuteNonQuery(string sql)
- {
- int result = -1;
- using (NpgsqlConnection connection = new NpgsqlConnection(ConStr))
- {
- using (NpgsqlCommand command = new NpgsqlCommand(sql, connection))
- {
- try
- {
- connection.Open();
- result = command.ExecuteNonQuery();
- }
- catch (NpgsqlException exception)
- {
- LogHelper.Error(string.Format("执行SQL[{0}]出错,详细信息为:{1}", sql, exception.Message));
- }
- finally
- {
- connection.Close();
- }
- }
- }
- return result;
- }
- public object ExecuteScalar(string sql)
- {
- object obj = null;
- using (NpgsqlConnection connection = new NpgsqlConnection(ConStr))
- {
- using (NpgsqlCommand command = new NpgsqlCommand(sql, connection))
- {
- try
- {
- connection.Open();
- obj = command.ExecuteScalar();
- }
- catch (NpgsqlException exception)
- {
- obj = -1;
- LogHelper.Error(string.Format("执行SQL[{0}]出错,详细信息为:{1}", sql, exception.Message));
- }
- finally
- {
- connection.Close();
- }
- }
- }
- return obj;
- }
- public DataSet ExecuteQuery(string sql)
- {
- DataSet result = new DataSet();
- using (NpgsqlConnection connection = new NpgsqlConnection(ConStr))
- {
- using (NpgsqlDataAdapter dataAdapter = new NpgsqlDataAdapter(sql, connection))
- {
- try
- {
- connection.Open();
- dataAdapter.Fill(result);
- }
- catch (NpgsqlException exception)
- {
- LogHelper.Error(string.Format("执行SQL【{0}】出错,详细信息为:{1}", sql, exception.Message));
- }
- finally
- {
- connection.Close();
- }
- }
- }
- return result;
- }
- }
- }
|