Java语言数据库操作的基本流程

王朝java/jsp·作者佚名  2008-05-31
窄屏简体版  字體: |||超大  

1.Java数据库操作基本流程

a .数据库连接1.Drivermanager 链接数据库

String className,url,uid,pwd;

className="Oracle.jdbc.driver.OracleDriver";

uid="scott";

pwd="tiger";

url="jdbc:oracle:thin:@localhost:1521:ora92";

Class.forName(classname);

Connection conn=DriverManager.getConnection(url,uid,pwd);

2.JNDI链接数据库

String jndi ="jdbc/db"; // e20-040 9L0-609 数据源的名称

//context是一组名称到对象的绑定组成

Hashtable env=new Hashtable ();

Context ctx=(Context)new InitialContext.lookup("env");// 获得数据源所在的上下文点的对象

DataSource ds=(DataSource)ctx.lookup(jndi);//找到数据源

Connection conn=ds.getConnection();//

b.执行 sql语句

String sql;

StateMent stat=conn.createStatement();

ResultSet rs=stat.executeQuery(sql);//执行数据的查询语句(select);

stat.executeUpdate(sql);//执行数据的更新语句(inset into ,delete ,update ,drop)

stat.close();

c.用preparedStatement 来执行sql语句

String sql="inset into table(id,name) values(?,?)";

PreparedStatement ps=conn.prepareStatement(sql);

ps.setInt(1,001);

ps.setString(2,"zhangmanli");

ps.executeQuery();

int count=ps.executeUpdate();

d.处理执行结果

查询语句,返回记录集ResultSet对象

更新语句,返回数字,表示该更新影响的记录数

javax.sql.*

javax.naming.*;

数据处理:

1关闭connection 的自动提交

conn.setAutoCommit(false);

2执行一系列sql 语句,

Statement sm;

sm=conn.createStatement(sql);

sm.executeUpdate();

sm.close();

3.提交:

conn.commit();

4.回滚机制;

conn.rollback();

e:线程处理:

D:jndi和dataSource 来获得数据库的链接:

import java.sql.ResultSet ;

import java.sql.*;

import javax.sql.DataSource;

import javax.naming.Context;

import javax.naming.InitialContext;

import java.util.Hashtable;

import java.util.Properties;

import java.io.*;

public class BasicExample{

public static void main(String args[]){

Connection conn=null;

try{

Properties prop =new Properties();

prop.load(new FileInputStream("simple.properties"));

Hashtable env =new Hashtable();

env.put(Context.INITIAL_CONTEXT_FACTORY,prop.getProperty("INITIAL_CONTEXT_FACTORY"));

env.put(Context.PROVIDER_URL,prop.getProperty("PROVIDER_URL"));

InitialContext ctx=new InitialContext(env);

DataSource ds=(DataSource)ctx.lookup("Book");

Conn=ds.getConnection();

Statement stat=conn.createStatement();;

ResultSet rs=stmt.executeQuery(sql);

while(rs.next()){

int id=Integer.parseInt(rs.getString("userId"));

String userName=rs.getString ("username");

}

}catch(SQLException e){

e.printStackTrace();

}finally{

try{

if(conn!=null){

conn.close();

}

}catch(SQLException e){

e.printStackTrace();

}

}

}

};

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航