首页 > 开发 > Java > 正文

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

2024-07-13 09:55:44
字体:
来源:转载
供稿:网友
 

 

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();
   }
  }
 }
};

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表