ADO.net连接Oracle数据库_sql

要在引入处自己加入System.Data.OracleClient

using System

using System.Data

using System.Data.OracleClient

using System.Web.UI.WebControlsnamespace SiFenManager.Util

{

/// <summary>

/// 数据库通用 *** 作类

/// </summary>

public class Database

{

protected OracleConnection con//连接对象

public Database()

{

con=new OracleConnection(DafangFramework.AppConfig.DataBaseConnectionString)

}

public Database(string constr)

{

con=new OracleConnection(constr)

}

#region 打开数据库连接

/// <summary>

/// 打开数据库连接

/// </summary>

private void Open()

{

//打开数据库连接

if(con.State==ConnectionState.Closed)

{

try

{

//打开数据库连接

con.Open()

}

catch(Exception e)

{

throw e

}

#endregion

#region 关闭数据库连接

/// <summary>

/// 关闭数据库连接

/// </summary>

private void Close()

{

//判断连接的状态是否已经打开

if(con.State==ConnectionState.Open)

{

con.Close()

}

#endregion

#region 执行查询语句，返回OracleDataReader ( 注意：调用该方法后，一定要对OracleDataReader进行Close )

/// <summary>

/// 执行查询语句，返回OracleDataReader ( 注意：调用该方法后，一定要对OracleDataReader进行Close )

/// </summary>

/// <param name="sql">查询语句</param>

/// <returns>OracleDataReader</returns>

public OracleDataReader ExecuteReader(string sql)

{

OracleDataReader myReader

Open()

OracleCommand cmd = new OracleCommand(sql, con)

myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection)

return myReader

}

#endregion

用的时候不关闭连接，最后退出系统时再关，一般不这么用。

建议使用tomcat连接池的方法处理，效果会好，程序也不用较多的特殊处理。

1:连接池所要解决的问题：

应用程序每一次与数据库的连接都会由于网络传输和执行数据库查询而严重降低了程序的执行效率，因此我们需要用到连接池将将我们经常要用到的数据保存在连接池中，这样就减少了网络传输和因查询而给程序执行效率带来的影响。

2：连接池的本质：用一个集合保存查询出来的数据。

3：连接池的实现原理：

我们要使用Connect pool,首先要做的是访问datasource（所有的要访问的数据都放在这里面）。datasource数据源是通过LDAP(light directory access protocal)软件进行管理的（其本质就是将数据源以树状结构进行存储，这样的话，方便查询（树状结构的查询效率是最快的），java通过JNDI（java naming directory interface）访问LDAP里面的数据。

4:在tomcat种配置连接池：

1）打开tomcat目录下的conf/context.cfg:在里面加入如下配置

Xml代码

其中：maxActive:代表的是要配置的最大连接数。

type:资源类型

2)通过应用程序执行上述连接：

Java代码

<%@page contentType="text/html" %>

<%@page import="java.sql.*"%>

<%@page import="javax.sql.*"%>

<%@page import="javax.naming.*"%>

<html>

<body>

<% Context ctx=new InitialContext()

DataSource ds=(DataSource)ctx.lookup("java:comp/env/ds")//必须要

Connection con=ds.getConnection()

out.println("<h1>connection succeeful</h1>")

con.close()

</body>

</html>

<%@page contentType="text/html" %>

<%@page import="java.sql.*"%>

<%@page import="javax.sql.*"%>

<%@page import="javax.naming.*"%>

<html>

<body>

<% Context ctx=new InitialContext()

DataSource ds=(DataSource)ctx.lookup("java:comp/env/ds")//必须要

Connection con=ds.getConnection()

out.println("<h1>connection succeeful</h1>")

con.close()

</body>

</html>

conn.close()：连接池是被覆盖了的，本质上的含义，把连接池借过来的连接还回去。

java web 开发书上的例子

web.xml

<?xml version="1.0" encoding="UTF-8"?>

<web-app version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee

http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">

<welcome-file-list>

<welcome-file>index.jsp</welcome-file>

</welcome-file-list>

<resource-ref>

<description>SQL Server 2005 DataSource</description>

<res-ref-name>jdbc/dbpooling</res-ref-name>

<res-type>javax.sql.DataSource</res-type>

<res-auth>Container</res-auth>

</resource-ref>

</web-app>

showUsers.jsp

<%@ page language="java" import="java.sql.*,javax.sql.*,javax.naming.*"

pageEncoding="GB2312"%>

<html>

<head>

<title>全部注册用户信息</title>

</head>

<body>

try {

DataSource ds = null

InitialContext ctx = new InitialContext()//建立上下文对象

ds = (DataSource) ctx.lookup("java:comp/env/jdbc/dbpooling")//通过JNDI查找数据连接池

Connection conn = ds.getConnection()//获得数据库连接对象

PreparedStatement pstate = conn

.prepareStatement("select * from [User]")

ResultSet rs = pstate.executeQuery()

out.println("<table border=1>")

out.println("<tr><td>用户名</td><td>密码</td></tr>")

while (rs.next()) {

out.println("<tr><td>")

out.println(rs.getString(2))

out.println("</td><td>")

out.println(rs.getString(3))

out.println("</td></tr>")

}

out.println("</table>")

} catch (SQLException e) {

out.println(e)

}

</body>

</html>

aspx.cs

PersonDao dao = new PersonDao()

Person person = dao.getPerson("姓名")//取记录

person.Age = 20 //更新该员工的年龄

dao.updatePerson(person)// 将新的数据保存到数据库

//实体数据模型

public class Person

{

private string name

private int age

private string sex

public string Name

{

get { return name}

set { name = value}

}

public int Age

{

get { return age}

set { age = value}

}

public string Sex

{

get { return sex}

set { sex = value}

}

//对数据库的 *** 作

public class PersonDao

{

private static string ConnStr = "数据库连接字符串"

public Person getPerson(string name)//可以用按其它条件查询, 确保唯一

{

string sql = "select name, age ,sex from table where name ='" + name + "'"

Person person = new Person()

SqlConnection sqlConn = new SqlConnection(ConnStr)

SqlCommand cmd = null

try

{

sqlConn.Open()

cmd = sqlConn.CreateCommand()

cmd.CommandText = sql

SqlDataReader dr = cmd.ExecuteReader()

if (dr.Read())

{

person.Name = dr["name"].ToString()

person.Age = Convert.ToInt32(dr["age"])

person.Sex = dr["age"].ToString()

}

catch (SqlException e)

{

person = null

//记录错误信息

}

finally

{

if (sqlConn.State != ConnectionState.Closed)

{

sqlConn.Dispose()

sqlConn.Close()

}

cmd.Dispose()

}

return person

}

public int updatePerson(Person person)//可以用按其它条件查询, 确保唯一

{

string sql = "update person set age = "+person.Age+", sex='"+person.Sex+"' where name = '"+person.Name+"'"

int i = 0

SqlConnection sqlConn = new SqlConnection(ConnStr)

SqlCommand cmd = null

try

{

sqlConn.Open()

cmd = sqlConn.CreateCommand()

cmd.CommandText = sql

i = cmd.ExecuteNonQuery()

}

catch (SqlException e)

{

i = 0

//记录错误信息

}

finally

{

if (sqlConn.State != ConnectionState.Closed)

{

sqlConn.Dispose()

sqlConn.Close()

}

cmd.Dispose()

}

return i

}

安装oracle的最新ODP.NET，用ODP.NET的Oracle.DataAccess.dll替换。详情见http://blog.csdn.net/yenange/article/details/12198829

欢迎分享，转载请注明来源：内存溢出

原文地址: http://outofmemory.cn/sjk/9922669.html

ADO.net连接Oracle数据库

发表评论

评论列表（0条）