标签:c# cmd 改查 NpgsqlConnection pg sql new using conn
1.webconfig增加
<connectionStrings>
<add name="postgres" connectionString="PORT=5433;DATABASE=gis;HOST=127.0.0.1;PASSWORD=123456;USER ID=postgres" />
</connectionStrings>
<system.webServer>
<directoryBrowse enabled="true" />
</system.webServer>
</configuration>
2.操作
using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Linq;
using System.Web;
using Npgsql;
namespace PipeLineEditor
{
public class PgsqlHelper
{
public static string connStr = ConfigurationManager.ConnectionStrings["postgres"].ToString();
/// <summary>
/// 增 删 改(无参数)
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public static int ExecuteSQL(string sql)
{
int n = -1;
using (NpgsqlConnection conn = new NpgsqlConnection(connStr))
{
using (NpgsqlCommand cmd = new NpgsqlCommand(sql, conn))
{
try
{
conn.Open();
n = cmd.ExecuteNonQuery();
}
catch (NpgsqlException exception)
{
throw new Exception(exception.Message);
}
finally
{
conn.Close();
}
}
}
return n;
}
/// <summary>
/// 增 删 改(有参数)
/// </summary>
/// <param name="sql"></param>
/// <param name="parameters"></param>
/// <returns></returns>
public static int ExecuteNonQuery(string sql, params NpgsqlParameter[] parameters)
{
int n = -1;
using (NpgsqlConnection conn = new NpgsqlConnection(connStr))
{
conn.Open();
using (NpgsqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sql;
cmd.Parameters.AddRange(parameters);
n = cmd.ExecuteNonQuery();
}
}
return n;
}
/// <summary>
/// 查询并返回结果集DataTable(带参数)
/// </summary>
/// <param name="sql"></param>
/// <param name="parameters"></param>
/// <returns></returns>
public static DataTable ExecuteDataTable(string sql, params NpgsqlParameter[] parameters)
{
using (NpgsqlConnection conn = new NpgsqlConnection(connStr))
{
conn.Open();
using (NpgsqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sql;
if (parameters != null)
{
cmd.Parameters.AddRange(parameters);
}
NpgsqlDataAdapter adapter = new NpgsqlDataAdapter(cmd);
DataSet dataset = new DataSet();
adapter.Fill(dataset);
return dataset.Tables[0];
}
}
}
/// <summary>
/// 查询并返回结果集DataTable(无参数)
/// </summary>
/// <param name="sql"></param>
/// <returns></returns>
public static DataTable ExecuteQuery(string sql)
{
NpgsqlConnection sqlConn = new NpgsqlConnection(connStr);
DataTable ds = new DataTable();
try
{
using (NpgsqlDataAdapter sqldap = new NpgsqlDataAdapter(sql, sqlConn))
{
sqldap.Fill(ds);
}
return ds;
}
catch (System.Exception ex)
{
throw ex;
}
}
}
}
标签:c#,cmd,改查,NpgsqlConnection,pg,sql,new,using,conn 来源: https://blog.csdn.net/xlp789/article/details/119247583
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。