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");
新闻热点
疑难解答