JDBC 连接数据库的 基本操作 增 ，查

package com.genomics.ib.generator;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import com.genomics.core.UUIDGenerator;
import com.genomics.ib.emaillist.db.EmailListSupport;

public class Test2 {

/**
* @Title: main
* @Description: 从测试数据库取出数据， 然后导入到正式数据库中
* @param args
* @exception:(异常说明)
*/
public static void main(String[] args) {

Connection conn = null;

String driver2 = "oracle.jdbc.driver.OracleDriver";

String url = "jdbc:oracle:thin:@172.16.103.47:1521:orclbms1";   //测试数据库地址

String urlZS = "" ;    //正式数据库地址

String userName = "xxx";// <!-- solexatest bms101 -->

String password = "xxxxx";

List<EmailListSupport> listEmail = new ArrayList<EmailListSupport>();

/**
* 从测试数据库取出数据
*/

try {
Class.forName(driver2);

} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

try {

conn = DriverManager.getConnection(url, userName, password);

} catch (SQLException e) {

System.out.println("连接数据库失败“用户,密码错误”！");

}

String sql = " select * from EMAIL_LIST_SUPPORT el where el.function_name = '上机试剂模块' ";

try {
Statement stmt = conn.createStatement();

ResultSet rs = stmt.executeQuery(sql);

while ( rs.next() ) {

System.out.println( "ID: "+ rs.getString(1)
+ " --FUNCTION_NAME "  + rs.getString( 2 )
+ " --USER_NAME "  + rs.getString( 3 )
+ " --USER_MAIL "  + rs.getString( 4 )
+ " --GROUP_TYPE "  + rs.getString( 5 )
+ " --CREATE_USER "  + rs.getString( 6 )
+ " --CREATE_DATE "  + rs.getDate( 7 )
+ " --MODIFY_USER "  + rs.getString( 8 )
+ " --MODIFY_DATE "  + rs.getDate( 9 )
+ " --SECTION "  + rs.getString( 10 )
+ " --DIVISION_AREA "  + rs.getString( 11 )

);

String id = UUIDGenerator.getNextUUID();
String FUNCTION_NAME =  rs.getString( 2 ) ;
String USER_NAME  = rs.getString( 3 )  ;
String USER_MAIL  = rs.getString( 4 )  ;
String GROUP_TYPE  = rs.getString( 5 )  ;
String CREATE_USER = rs.getString( 6 )  ;
Date CREATE_DATE = rs.getDate( 7 )  ;
String MODIFY_USER = rs.getString( 8 )  ;
Date MODIFY_DATE = rs.getDate( 9 )  ;
String SECTION     = rs.getString( 10 )  ;
String DIVISION_AREA = rs.getString( 11 )   ;

EmailListSupport em = new EmailListSupport();

em.setId( id ) ;
em.setFunctionName(  FUNCTION_NAME ) ;
em.setUserName(  USER_NAME  ) ;
em.setUserMail(  USER_MAIL );
em.setGroupType( GROUP_TYPE );
em.setCreateUser( CREATE_USER );
em.setCreateDate( CREATE_DATE );
em.setModifyUser( MODIFY_USER );
em.setModifyDate( MODIFY_DATE );
em.setSection( SECTION );
em.setDivisionArea( DIVISION_AREA );

listEmail.add( em );

}

if(conn != null){
conn.close();
}

} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

for (EmailListSupport emailListSupport : listEmail) {

System.out.println(  "FUNCTION_NAME :" + emailListSupport.getFunctionName()   );

}

//-------------------------------------------------

/**
* 导入到正式数据库中
*/
try {
Class.forName(driver2);

} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

System.out.println("-------ssss-----");

try {

conn = DriverManager.getConnection(urlZS, userName, password);

} catch (SQLException e) {

System.out.println("连接数据库失败“用户,密码错误”！");

}

String sql3 = " select * from EMAIL_LIST_SUPPORT  ";

try {
Statement stmt = conn.createStatement();

ResultSet rs = stmt.executeQuery(sql3);

while ( rs.next() ) {

System.out.println( "ID: "+ rs.getString(1)
+ " --FUNCTION_NAME "  + rs.getString( 2 )
+ " --USER_NAME "  + rs.getString( 3 )
+ " --USER_MAIL "  + rs.getString( 4 )
+ " --GROUP_TYPE "  + rs.getString( 5 )
+ " --CREATE_USER "  + rs.getString( 6 )
+ " --CREATE_DATE "  + rs.getDate( 7 )
+ " --MODIFY_USER "  + rs.getString( 8 )
+ " --MODIFY_DATE "  + rs.getDate( 9 )
+ " --SECTION "  + rs.getString( 10 )
+ " --DIVISION_AREA "  + rs.getString( 11 )
);

}

//			if(conn != null){
//				conn.close();
//			}

} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}

String sql2 = " insert into EMAIL_LIST_SUPPORT " +
" ( id, function_name, user_name,  user_mail,  group_type,  create_user,  create_date,   modify_user,  modify_date, section,  division_area ) " +
"  values( ? , ? , ? , ? ,? ,? ,? ,? ,? ,? ,? ) " ;

try {

Integer xx = 1;

for (EmailListSupport emailListSupport : listEmail) {

PreparedStatement ps =conn.prepareStatement( sql2 );
ps.setString(1 ,  emailListSupport.getId() );
ps.setString(2 ,  emailListSupport.getFunctionName() );
ps.setString(3 ,  emailListSupport.getUserName() );
ps.setString(4 ,  emailListSupport.getUserMail() );
ps.setString(5 ,  emailListSupport.getGroupType() );
ps.setString(6 ,  emailListSupport.getCreateUser() );
ps.setDate(  7 ,  new java.sql.Date(  emailListSupport.getCreateDate().getTime() ) );

ps.setString(8 ,  emailListSupport.getModifyUser() );
ps.setDate(  9 ,     new java.sql.Date( emailListSupport.getModifyDate().getTime() ) );
ps.setString(10 ,  emailListSupport.getSection() );
ps.setString(11,  emailListSupport.getDivisionArea() );

ps.executeUpdate();
ps.close();

System.out.println( "xx : " + xx );

xx++ ;

}

if(conn != null){
conn.close();
}

System.out.println( " ");

} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally{

if(conn != null){
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}

}

}