在Java中如何对数据库中的数据进行 *** 作?

在Java中如何对数据库中的数据进行 *** 作?,第1张

//此类为连接数据库并进行数据库的 *** 作\x0d\x0aimportjava.sql.Connection\x0d\x0aimportjava.sql.DriverManager\x0d\x0aimportjava.sql.ResultSet\x0d\x0aimportjava.sql.SQLException\x0d\x0aimportjava.sql.Statement\x0d\x0apublicclassConn{\x0d\x0aprivatestaticConnectionconn=null\x0d\x0aprivatestaticStatementst=null\x0d\x0aprivatestaticResultSetrs=null\x0d\x0a//建立数据库的连接\x0d\x0apublicConn(){\x0d\x0aStringurl="jdbc:sqlserver://localhost:1433databaseName=ZYGX"\x0d\x0aStringuser="sa"\x0d\x0aStringpassword="123"\x0d\x0atry{\x0d\x0aClass.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver")\x0d\x0aconn=DriverManager.getConnection(url,user,password)\x0d\x0ast=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY)\x0d\x0a}catch(ClassNotFoundExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0a}\x0d\x0a\x0d\x0a//通过不同的sql语句,得到相应Resultset结果集\x0d\x0apublicResultSetgetRs(Stringsql){\x0d\x0atry{\x0d\x0ars=st.executeQuery(sql)\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0areturnrs\x0d\x0a}\x0d\x0a//根据不同的sql语句,执行数据库的更新 *** 作\x0d\x0apublicintupdata(Stringsql){\x0d\x0aintnum=0\x0d\x0atry{\x0d\x0anum=st.executeUpdate(sql)\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0areturnnum\x0d\x0a}\x0d\x0a//关闭数据库连接相应的资源\x0d\x0apublicvoidclose(){\x0d\x0atry{\x0d\x0aif(rs!=null){\x0d\x0ars.close()\x0d\x0ars=null\x0d\x0a}\x0d\x0aif(st!=null){\x0d\x0ast.close()\x0d\x0ast=null\x0d\x0a}\x0d\x0aif(conn!=null){\x0d\x0aconn.close()\x0d\x0aconn=null\x0d\x0a}\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0a}\x0d\x0a}\x0d\x0a----------------------------------------------------------------------\x0d\x0a//可以对button里添加动作按钮:\x0d\x0afinalJButtonbutton=newJButton()\x0d\x0abutton.addActionListener(newActionListener(){\x0d\x0apublicvoidactionPerformed(finalActionEvente){\x0d\x0aConnconn=newConn()\x0d\x0aStringsql1="select*fromaawherename='"+name+"'"//按name值查找\x0d\x0aResultSetrs=conn.getRs(sql1)\x0d\x0atry{\x0d\x0awhile(rs.next()){\x0d\x0aintn=rs.getString("type")\x0d\x0a}\x0d\x0a}catch(SQLExceptione){\x0d\x0ae.printStackTrace()\x0d\x0a}\x0d\x0aStringname=textField.getText()\x0d\x0aStringsql="updateaasettittle='"+name+"'"//从aa表将title字段的值改成textField里的name值\x0d\x0aStringsql2="deletefromaawherename='"+name+"'"//从aa表将按取得name的值删除该行数据\x0d\x0aStringsql3="insertintoaa(name,uname)values('"+name+"','"')"//将name,uname值新增到aa表\x0d\x0aif(conn.update(sql)==1){\x0d\x0aSystem.out.print("修改成功")\x0d\x0a}\x0d\x0aif(conn.update(sql2)==1){\x0d\x0aSystem.out.print("删除成功")\x0d\x0a}\x0d\x0aif(conn.update(sql3)==1){\x0d\x0aSystem.out.print("新增成功")\x0d\x0a}\x0d\x0a}\x0d\x0a})

每个使用关系型数据库的程序都可能遇到数据死锁或不可用的情况,而这些情况需要在代码中编程来解决本文主要介绍与数据库事务死锁等情况相关的重试逻辑概念,此外,还会探讨如何避免死锁等问题,文章以DB2(版本9)与为例进行讲解。

什么是数据库锁定与死锁锁定(Locking)发生在当一个事务获得对某一资源的“锁”时,这时,其他的事务就不能更改这个资源了,这种机制的存在是为了保证数据一致性在设计与数据库交互的程序时,必须处理锁与资源不可用的情况。

锁定是个比较复杂的概念,仔细说起来可能又需要一大篇,所以在本文中,只把锁定看作是一个临时事件,这意味着如果一个资源被锁定,它总会在以后某个时间被释放。

而死锁发生在当多个进程访问同一数据库时,其中每个进程拥有的锁都是其他进程所需的,由此造成每个进程都无法继续下去。

如何避免锁我们可利用事务型数据库中的隔离级别机制来避免锁的创建,正确地使用隔离级别可使程序处理更多的并发事件(如允许多个用户访问数据),还能预防像丢失修改(LostUpdate)、读“脏”数据(DirtyRead)、不可重复读(NonrepeatableRead)及“虚”(Phantom)等问题。

隔离级别问题现象丢失修改读“脏”数据不可重复读“虚”可重复读取NoNoNoNo读取稳定性NoNoNoYes光标稳定性NoNoYesYes未提交的读NoYesYesYes表1:DB2的隔离级别与其对应的问题现象在只读模式中,就可以防止锁定发生,而不用那些未提交只读隔离级别的含糊语句。

浙江电脑培训http://www.kmbdqn.cn/发现一条SQL语句当使用了下列命令之一时,就应该考虑只读模式了

JDBC是java数据库连接技术的简称,它提供了连接各种数据库的能力,这便使程序的可维护性和可扩展性大大的提高了.JDBC连接数据库常见的驱动方式有两种,一种是jdbc-odbc即桥连另外一种是纯java驱动.一般在做java开发的时候用第二种.so前一种我就不说了,纯java驱动方式连接步骤如下:

1.先把一个jdbc的jar包导入到项目(用MyEclipse开发)的lib中.

2.代码如下:

[c-sharp] view plain copy

import java.sql.*

/**

* 连接数据库帮助类

* @author Administrator

*

*/

public class BaseDao {

private static final String DRIVER="com.microsoft.sqlserver.jdbc.SQLServerDriver"

private static final String URL = "jdbc:sqlserver://localhost:1433DatabaseName=LibraryManageSystem"

private static final String USERNAME="sa"

private static final String PASSWORD="sa"

/**

* 连接数据库

* @return 数据库连接对象

* @throws ClassNotFoundException

* @throws SQLException

*/

public Connection getConn()throws ClassNotFoundException,SQLException{

Class.forName(DRIVER)

Connection conn = DriverManager.getConnection(URL,USERNAME,PASSWORD)

return conn

}

/**

* 释放资源

* @param conn

* @param pstmt

* @param rs

* @throws SQLException

*/

public void closeAll(Connection conn,PreparedStatement pstmt,ResultSet rs)throws SQLException{

if(rs!=null){

rs.close()

}

if(pstmt!=null){

pstmt.close()

}

if(conn!=null){

conn.close()

}

}

/**

* 执行SQL语句,可以进行增、删、改的 *** 作

* @param sql

* @return 影响条数

* @throws ClassNotFoundException

* @throws SQLException

*/

public int executeSQL(String sql)throws ClassNotFoundException,SQLException{

Connection conn = this.getConn()

PreparedStatement pstmt = conn.prepareStatement(sql)

int number = pstmt.executeUpdate()

this.closeAll(conn, pstmt, null)

return number

}

}

从代码知道首先吧jdbc驱动类装载java虚拟机中,即Class.forName(DRIVER)其次加载驱动并建立于数据库的连接Connection conn = DriverManager.getConnection(URL,USERNAME,PASSWORD)然后发送SQL语句并的到结果集.之后处理结果,最后要关闭数据库的连接,释放资源.当然我说的这样连接数据库的方式使用的软件是sql和MyEclipse.

使用配置文件来连接数据库,当然这样的连接需要进行一些配置.其实这样的连接用专业术语来说就是连接池,连接池是负责分配管理和释放数据库连接.它允许用用程序重复使用一个现有的数据库连接不再重复建立连接.释放空闲时间超过最大空闲时间的数据库连接以避免因为没有释放数据库而引起的数据库遗漏.

连接池的创建分为以下几个步骤:1.配置context.xml文件  这个文件是服务器(指tomcat)的一个conf文件夹中,拷贝出来放入项目的lib文件夹中,具体配置如下:

[c-sharp] view plain copy

<Resource name="jdbc/book" auth="Container" type="javax.sql.DataSource"

maxActive="100" maxIdle="20" maxWait="100" username="sa" password="sa"

driverClassName="com.microsoft.sqlserver.jdbc.SQLServerDriver"

url="jdbc:sqlserver://localhost:1433dataBaseName=book"

/>在config.xml文件中加入Resource标签,然后对数据库信息进行配置,当然这个数据库指的也是sqlserver有疑问可以qq757966892联系

之后把数据库的驱动包,这里指的是sql2005的包放入服务器的lib中,这样以后如果在你自己的机子上都不用在重新导入这个包了.

然后就是从MyEclipse中取得这样的连接从而对数据库进行一些 *** 作具体代码如下:

[c-sharp] view plain copy

package web.login.dao

import java.sql.Connection

import java.sql.PreparedStatement

import java.sql.ResultSet

import javax.naming.Context

import javax.naming.InitialContext

import javax.sql.DataSource

public class BaseDao {

protected Connection conn

protected PreparedStatement ps

protected ResultSet rs

protected String sql

public Connection getConn(){

try {

Context context=new InitialContext()

DataSource ds=(DataSource)context.lookup("java:comp/env/jdbc/user")

return ds.getConnection()

} catch (Exception e) {

e.printStackTrace()

return null

}

}

public void closeAll(Connection conn,PreparedStatement ps,ResultSet rs){

try {

if(rs!=null){

rs.close()

rs=null

}

if(ps!=null){

ps.close()

ps=null

}

if(conn!=null){

conn.close()

conn=null

}

} catch (Exception e) {

e.printStackTrace()

}

}

}

之后便可以建立业务类从而对数据库进行 *** 作.


欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/sjk/9870466.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-02
下一篇 2023-05-02

发表评论

登录后才能评论

评论列表(0条)

保存