try{Connection con;
创新互联公司长期为上1000+客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为龙湖企业提供专业的网站设计、做网站，龙湖网站改版等技术服务。拥有十余年丰富建站经验和众多成功案例,为您定制开发。
Statement stmt;
ResultSet rs;
int temp;
Class.forName("com.mysql.jdbc.Driver");
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/java","root","");//以上是数据库连接，不同的数据管理器有 //不同的驱动和链接方式，以上是mysql的连接
stmt=con.createStatement();
rs=stmt.executeQuery("select * from student");//执行查询语句，结果赋值给结果集rs
//结果集是结果于字段编号的映射，每一个字
//段都有一个编号，最小为1，也就是第一个字段
while(rs.next()){
String names=rs.getString("name");//查询结果转换成字符串。
System.out.println(names);
}rs.close();
}catch(Exception e){
e.printStackTrace();
}
代码如下：
import java.util.ArrayList;
import java.util.List;
class Org {
private String id;
private String name;
private String pid;
public Org(String id, String name, String pid) {
this.id = id;
this.name = name;
this.pid = pid;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPid() {
return pid;
}
public void setPid(String pid) {
this.pid = pid;
}
@Override
public String toString() {
return "Org [id=" + id + ", name=" + name + ", pid=" + pid + "]";
}
}
public class App {
static void find(ListOrg list, String pid) {
list.stream().filter(p - p.getPid().equals(pid))
.forEach(org - {
System.out.println(org);
find(list, org.getId());
});
}
public static void main(String[] args) {
ListOrg list = new ArrayList();
list.add(new Org("111", "公司", "0"));
list.add(new Org("222", "部门", "111"));
list.add(new Org("333", "小组", "222"));
list.add(new Org("444", "员工1", "333"));
list.add(new Org("555", "员工2", "333"));
find(list, "0");
System.out.println("------------------------------------");
find(list, "111");
}
}
运行结果：
try{Connection con;
Statement stmt;
ResultSet rs;
int temp;
Class.forName("com.mysql.jdbc.Driver");
con=DriverManager.getConnection("jdbc:mysql://localhost:3306/java","root","");//以上是数据库连接，不同的数据管理器有 //不同的驱动和链接方式，以上是mysql的连接
stmt=con.createStatement();
rs=stmt.executeQuery("select * from student");//执行查询语句，结果赋值给结果集rs
//结果集是结果于字段编号的映射，每一个字
//段都有一个编号，最小为1，也就是第一个字段
while(rs.next()){
String names=rs.getString("name");//查询结果转换成字符串。
System.out.println(names);
}rs.close();
}catch(Exception e){
e.printStackTrace();
}
import java.sql.Connection。
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;
public class DBCon {
//数据库驱动对象
public static final String DRIVER="oracle.jdbc.driver.OracleDriver";
//数据库连接地址(数据库名)
public static final String URL="jdbc:oracle:thin:@localhost:1521:orcl";
//登陆名
public static final String USER="FM";
//登陆密码
public static final String PWD="FM";
//创建数据库连接对象
private Connection con=null;
//创建数据库预编译对象
private PreparedStatement ps=null;
//创建结果集
private ResultSet rs=null;
//创建数据源对象
public static DataSource source=null;
// //静态代码块
// static{
//
// //初始化配置文件context
// try {
// Context context=new InitialContext();
// source=(DataSource)context.lookup("java:comp/env/jdbc/webmessage");
// } catch (Exception e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
//
// }
/**
* 获取数据库连接
*/
public Connection getCon(){
try {
Class.forName(DRIVER);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
try {
con=DriverManager.getConnection(URL,USER,PWD);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return con;
}
// /**
// * 获取数据库连接
// */
// public Connection getCon(){
//
// try {
// con=source.getConnection();
// } catch (SQLException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
// return con;
// }
/**
* 关闭所有资源
*/
public void closeAll(){
if(rs!=null)
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if(ps!=null)
try {
ps.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
if(con!=null)
try {
con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
/**
* @param sql数据库更新(增、删、改) 语句
* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）
* @return 返回受影响都行数
*/
public int update(String sql,String... pras){
int resu=0;
con=getCon();
try {
ps=con.prepareStatement(sql);
for(int i=0;ipras.length;i++){
ps.setString(i+1,pras[i]);
}
resu=ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
closeAll();
}
return resu;
}
/**
* @param sql数据库查询语句
* @param pras参数列表（可传，可不传，不传为NULL，以数组形式存在）
* @return 返回结果集
*/
public ResultSet query(String sql,String... pras){
con=getCon();
try {
ps=con.prepareStatement(sql);
if(pras!=null)
for(int i=0;ipras.length;i++){
ps.setString(i+1, pras[i]);
}
rs=ps.executeQuery();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rs;
}
}
打开Eclipse或MyEclipse，选中你的项目，选择上面菜单栏的Search（也可以使用IDE的快捷键ctrl+H打开），输入你要查找的关键字，就能整个项目，甚至整个工作空间的查找，控制台旁边的Search标签页会显示查找结果。
事件： 报表接口数据库突然无法连接 ，导致无法正常取数操作。
异常信息： Io 异常： Got minus one from a read call
分析： 数据库地址及其配置信息都为发生变化 ， 经询问后得知数据库调整为集群工作方式 。
结果：1. 修改普通 JDBC 连接字符串为集群工作方式。
2. 接口中的 JDBC JAR文件不适合集群工作方式。
思维宽度：
1. JDBC JAR文件的选择， Classes12 到底是个啥玩意？ 第一次听很晕 ， 其实就是 oracle 数据库自带的 JDBC ，全名叫 classes12.jar 。 高手都这么忽悠人的!
常用JDBC JAR 信息
序号 常用JDBC驱动包 JDK 1.4 JDK 1.5 JDK 1.6 单例数据库 集群数据库 Class.forName
1 OracleJdbcDriver9i.jar 支持 支持 支持 支持 不支持 oracle.jdbc.OracleDriver
2 classes12.jar(oracle 92i) 支持 支持 支持 支持 不支持 oracle.jdbc.OracleDriver
3 ojdbc14.jar(oracle 92i) 支持 支持 支持 支持 不支持 oracle.jdbc.OracleDriver
4 classes12.jar(oracle 10G) 支持 支持 支持 支持 支持 oracle.jdbc.OracleDriver
5 ojdbc14.jar(oracle 10G) 支持 支持 支持 支持 支持 oracle.jdbc.OracleDriver
6 ojdbc5.jar 不支持 支持 支持 支持 支持 无需 Class.forName 加载
7 ojdbc6.jar 不支持 不支持 支持 支持 支持 无需 Class.forName 加载
序号1 ： OracleJdbcDriver9i.jar 这就是我常用的 JDBC 驱动，本次肇事者 !出身不明 ， 户口本 (MANIFEST.MF) 内容为空 ，初步分析为 oracle92i 时代产物。序号2， 3 ： 系出同门 ，都为 oracle92i 自带 ，家庭住址： oracle/jdbc/libclasses12.jar 户口本信息：Specification-Title： “Oracle JDBC driver classes for use with JDK1.2 and JDK1.3”Specification-Version： “Oracle JDBC Driver version - 9.0.2.0.0”ojdbc14.jar 户口本信息：Specification-Title： “Oracle JDBC driver classes for use with JDK1.4”Specification-Version： “Oracle JDBC Driver version - 9.0.2.0.0”序号4，5 ： oracle 10G 的产物 与 oracle 92i 最大的区别在于支持 集群查询。序号 6，7： ojdbc5.jar 支持 JDK 1.5 ，支持 JDBC 3.0 ojdbc6.jar 支持 JDK 1.6 ，支持 JDBC 4.0两者无需执行 Class.forName(“oracle.jdbc.OracleDriver”); 直接 DriverManager.getConnection( URL， USER， PWD) ; 就OK了。如果项目仅支持 JDK1.4 就不要妄动 ， 选择序号 4 ，5 不二的选择 。如果项目支持 JDK1.5 以上 推荐 序号 6 ，7 研究一下新特性。
2. 集群工作方式 连接字符串…慎重选择连接之外的属性。 偷懒粘贴下代码 !
StringBuffer url = new StringBuffer();url.append(“jdbc:oracle:thin：@(description= (address_list =”);url.append(“(address=(protocol=tcp)(host=192.168.31.9)(port=1521))”);//根据自己情况继续追加集群信息，格式如下//bf.append(“(address=(protocol=tcp)(host=10.37.27.112)(port=1521))”);url.append(“(load_balance=yes)”); //load_balance=yes;表示是否负载均衡url.append(“)”); //address_list 结束url.append(“(connect_data =”);url.append(“(server = dedicated)”); //server = dedicated;表示专用服务器模式，可以去掉url.append(“(service_name=wangjj)”); //数据库服务名称url.append(“(failover_mode =”);url.append(“(type=session)”); //TYPE = SESSION表示当一个连接好的会话的实例发生故障，系统会自动将会话切换到其他可用的实例，前台应用无须再度发起连接，但会话正在执行的SQL 需要重新执行url.append(“(method=basic)”); //METHOD = BASIC表示初始连接就连接一个接点，彵还有个选项是preconnect，表示初始连接所有的接点url.append(“(retries=5)”); //RETRIES 重试次数url.append(“(delay=15)”); //DELAY 重试延迟 单位为秒url.append(“)”); //failover_mode 结束url.append(“)”); //connect_data 结束url.append(“)”); //description 结束
重庆分公司
重庆分公司
