using System;
using SystemData;
using SystemDataSqlClient;
using SystemConfiguration;
using SystemCollections;
using SystemWeb;
namespace SQLFunctionDBHelper
{
public abstract class SqlHelper
{
public static readonly string CONN_STRING = ConfigurationManagerConnectionStrings["SqlConnString"]ConnectionString;
public static int ExecuteNonQuery(CommandType cmdType, string cmdText, params SqlParameter[] cmdParams)
{
SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(CONN_STRING))
{
PrepareCommand(cmd, conn, cmdType, cmdText, cmdParams);
int val = cmdExecuteNonQuery();
cmdParametersClear();
return val;
}
}
public static int ExecuteNonQuery(SqlConnection conn, CommandType cmdType, string cmdText, params SqlParameter[] cmdParams)
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, conn, cmdType, cmdText, cmdParams);
int val = cmdExecuteNonQuery();
cmdParametersClear();
return val;
}
public static SqlDataReader ExecuteReader(CommandType cmdType, string cmdText, params SqlParameter[] cmdParams)
{
SqlCommand cmd = new SqlCommand();
SqlConnection conn = new SqlConnection(CONN_STRING);
try
{
PrepareCommand(cmd, conn, cmdType, cmdText, cmdParams);
SqlDataReader rdr = cmdExecuteReader(CommandBehaviorCloseConnection);
cmdParametersClear();
return rdr;
}
catch
{
connClose();
throw;
}
}
public static object ExecuteScalar(CommandType cmdType, string cmdText, params SqlParameter[] cmdParams)
{
SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(CONN_STRING))
{
PrepareCommand(cmd, conn, cmdType, cmdText, cmdParams);
object val = cmdExecuteScalar();
cmdParametersClear();
return val;
}
}
public static object ExecuteScalar(SqlConnection conn, CommandType cmdType, string cmdText, params SqlParameter[] cmdParams)
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, conn, cmdType, cmdText, cmdParams);
object val = cmdExecuteScalar();
cmdParametersClear();
return val;
}
public static DataSet Fill(CommandType cmdType, string cmdText, params SqlParameter[] cmdParams)
{
SqlCommand cmd = new SqlCommand();
using (SqlConnection conn = new SqlConnection(CONN_STRING))
{
PrepareCommand(cmd, conn, cmdType, cmdText, cmdParams);
SqlDataAdapter adapter = new SqlDataAdapter(cmd);
DataSet ds = new DataSet();
adapterFill(ds);
return ds;
}
}
private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, CommandType cmdType, string cmdText, SqlParameter[] cmdParams)
{
if (connState != ConnectionStateOpen)
connOpen();
cmdConnection = conn;
cmdCommandType = cmdType;
cmdCommandText = cmdText;
if (cmdParams != null)
{
foreach (SqlParameter param in cmdParams)
cmdParametersAdd(param);
}
}
}
}
ASPNET20的 读取配置文件中的数据库连接字符串"SqlConnString"
可能没看懂这个封装可以直接引用 ExecuteNonQuery执行UPdate,DELETE 等SQL语句返回影响多少记录,ExecuteReader执行一个查询语句返回SqlDataReader ,ExecuteScalar 执行执行SQL返回一个结果为object类型,Fill返回一个DATASET记录集,传递参数
(CommandType[TEXT/StoredProcedure],[SQL语句/存储过程名],[SqlParameter/没有则null])所以这个函数既可以执行存储过程也可用足普通SQL
import javasql;
public class DataBasePractice {
public static void main(String[] args) {
//声明Connection对象
Connection con;
//驱动程序名
String driver = "commysqljdbcDriver";
//URL指向要访问的数据库名mydata
String url = "jdbc:mysql://localhost:3306/mydata";
//MySQL配置时的用户名
String user = "root";
//MySQL配置时的密码
String password = "root";
//遍历查询结果集
try {
//加载驱动程序
ClassforName(driver);
//1getConnection()方法,连接MySQL数据库!!
con = DriverManagergetConnection(url,user,password);
if(!conisClosed())
Systemoutprintln("Succeeded connecting to the Database!");
//2创建statement类对象,用来执行SQL语句!!
Statement statement = concreateStatement();
//要执行的SQL语句
String sql = "select from student";
//3ResultSet类,用来存放获取的结果集!!
ResultSet rs = statementexecuteQuery(sql);
Systemoutprintln("-----------------");
Systemoutprintln("执行结果如下所示:");
Systemoutprintln("-----------------");
Systemoutprintln(" 学号" + "\t" + " 姓名");
Systemoutprintln("-----------------");
String name = null;
String id = null;
while(rsnext()){
//获取stuname这列数据
name = rsgetString("stuname");
//获取stuid这列数据
id = rsgetString("stuid");
//首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。
//然后使用GB2312字符集解码指定的字节数组。
name = new String(namegetBytes("ISO-8859-1"),"gb2312");
//输出结果
Systemoutprintln(id + "\t" + name);
}
rsclose();
conclose();
} catch(ClassNotFoundException e) {
//数据库驱动类异常处理
Systemoutprintln("Sorry,can`t find the Driver!");
eprintStackTrace();
} catch(SQLException e) {
//数据库连接失败异常处理
eprintStackTrace();
}catch (Exception e) {
// TODO: handle exception
eprintStackTrace();
}finally{
Systemoutprintln("数据库数据成功获取!!");
}
}
}
在上面while代码段后面添加以下代码段:
String name = null;
String id = null;
while(rsnext()){
//获取stuname这列数据
name = rsgetString("stuname");
//获取stuid这列数据
id = rsgetString("stuid");
//首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。
//然后使用GB2312字符集解码指定的字节数组。
name = new String(namegetBytes("ISO-8859-1"),"gb2312");
//输出结果
Systemoutprintln(id + "\t" + name);
}
PreparedStatement psql;
ResultSet res;
//预处理添加数据,其中有两个参数--“?”
psql = conprepareStatement("insert into student values(,)");
psqlsetInt(1, 8); //设置参数1,创建id为5的数据
psqlsetString(2, "xiaogang"); //设置参数2,name 为小明
psqlexecuteUpdate(); //执行更新
//预处理更新(修改)数据
psql = conprepareStatement("update student set stuname = where stuid = ");
psqlsetString(1,"xiaowang"); //设置参数1,将name改为王五
psqlsetInt(2,10); //设置参数2,将id为2的数据做修改
psqlexecuteUpdate();
//预处理删除数据
psql = conprepareStatement("delete from student where stuid = ");
psqlsetInt(1, 5);
psqlexecuteUpdate();
//查询修改数据后student表中的数据
psql = conprepareStatement("selectfrom student");
res = psqlexecuteQuery(); //执行预处理sql语句
Systemoutprintln("执行增加、修改、删除后的数据");
while(resnext()){
name = resgetString("stuname");
id = resgetString("stuid");
name = new String(namegetBytes("ISO-8859-1"),"gb2312");
Systemoutprintln(id + "\t" + name);
}
resclose();
psqlclose();
这是jsp中sql2005的连接代码,放到页面或者javabean中都可以使用
import javasqlConnection;
import javasqlDriverManager;
import javasql;
public class Dbconn {
public Connection getConnection()
{
String driverName = "commicrosoftsqlserverjdbcSQLServerDriver";
String dbURL = "jdbc:sqlserver://localhost:1433;DataBaseName=xmsz";
String userName = "admin";
String userPwd ="123";
Connection dbConn = null;
try {
ClassforName(driverName);
dbConn = DriverManagergetConnection(dbURL, userName, userPwd);
Systemoutprintln("Connection Successful!");
}
catch (Exception e) {
// eprintStackTrace();
Systemoutprintln(egetMessage());
}
return dbConn;
}
}
以上就是关于asp.net 数据库连接代码(c#)完整代码全部的内容,包括:asp.net 数据库连接代码(c#)完整代码、java连接数据库mysql代码及简单访问数据库、如何做数据库,最好有完整代码的等相关内容解答,如果想了解更多相关内容,可以关注我们,你们的支持是我们更新的动力!
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)