package com.ibm.gcl.db2.test;

import java.sql.*;
import java.io.FileWriter;
import java.io.IOException;

/**
 * @author kevin
 * JDBCConnectTest
 */
public class JDBCConnectTest {
	
	// Log FileWritter
	private static FileWriter _logger = null;
	
	// Connection to DB2 V7.2
	private static Connection oldcon = null;

	// Connection to DB2 V8.1
	private static Connection newcon = null;
	
	public static void main(String[] args)
	{
		try {
			_logger = new FileWriter("JDBCConnectTest.log");   //测试程序会生成Log文件
			
			while(true)
			{
				java.lang.Thread.sleep(5000);
				ConnectV7_2();
				ConnectV8_1();
				java.lang.Thread.sleep(5000);
			}

		} catch (Exception ex) {
			try
			{
				_logger.write("Exception || Main Function\n");
				_logger.flush();
			}catch(Exception eex)
			{
				eex.printStackTrace();
			}
			ex.printStackTrace();
		}finally
		{
			try
			{
				if(null != _logger)
				{
					_logger.flush();
					_logger.close();
					_logger = null;
				}
			}catch(Exception eeex)
			{
				eeex.printStackTrace();
			}
		}
	}
	
	private static void ConnectV7_2()
	{
		try {
				/*********************
				 * Connect to Database V7.2 
				 *********************/
				//Class.forName("COM.ibm.db2.jdbc.app.DB2Driver");
				Class.forName("com.ibm.db2.jcc.DB2Driver");
				_logger.write(
					"Connect to DB2 V7.2 Driver: com.ibm.db2.jcc.DB2Driver\n");
				_logger.flush();

				oldcon =                           // 测试数据库连接，请读者自行替换驱动程序包名和URL模式重复实验
					DriverManager.getConnection(
						"jdbc:db2://10.1.1.14:50000/OLDDB",
						"db2admin",
						"password");
				_logger.write(
					"Connect to DB2 V7.2 Successful!    URL: jdbc:db2://10.1.1.14:50000/OLDDB Username: db2admin Password: password\n");
				_logger.flush();

				oldcon.setAutoCommit(false);
				
				Statement stmt = oldcon.createStatement();
				
				String selstr = "";
				ResultSet rs = stmt.executeQuery(selstr);   //  测试查询操作
				
				String insstr = "";
				stmt.executeUpdate(insstr);  //  测试插入操作
				
				String updstr = "";
				stmt.executeUpdate(updstr);  //  测试更新操作
				
				String delstr = "";
				stmt.executeUpdate(delstr);  //  测试删除操作
				
				String ddlstr = "";
				stmt.executeUpdate(ddlstr);  //  测试DDL操作
				
				rs.close();
				stmt.close();
				
			} catch (SQLException sqlex) {
				try
				{
				_logger.write("SQLException || Connect to Database V7.2\n");
				_logger.flush();
				sqlex.printStackTrace();
				}catch(Exception ex)
				{
				}
			} catch (Exception ex) {
				try
				{
				_logger.write("Exception || Connect to Database V7.2\n");
				_logger.flush();
				ex.printStackTrace();
				}catch(Exception eex)
				{
				}
			}
	}
	
	private static void ConnectV8_1()
	{
		try {
				/*********************
				 * Connect to Database V 8.1 
				 *********************/
				//Class.forName("COM.ibm.db2.jdbc.app.DB2Driver");
				Class.forName("com.ibm.db2.jcc.DB2Driver");
				_logger.write(
					"Connect to DB2 V8.1 Driver: com.ibm.db2.jcc.DB2Driver\n");
				_logger.flush();

				oldcon =                    // 测试数据库连接，请读者自行替换驱动程序包名和URL模式重复实验
					DriverManager.getConnection(
						"jdbc:db2://10.1.1.15:50000/NEWDB",
						"db2admin",
						"password");
				_logger.write(
					"Connect to DB2 V8.1 Successful!    URL: jdbc:db2://10.1.1.15:50000/NEWDB Username: db2admin Password: password\n");
				_logger.flush();

				oldcon.setAutoCommit(false);
				
				Statement stmt = oldcon.createStatement();
				
				String selstr = "";
				ResultSet rs = stmt.executeQuery(selstr);   //  测试查询操作
				
				String insstr = "";
				stmt.executeUpdate(insstr);  //  测试插入操作
				
				String updstr = "";
				stmt.executeUpdate(updstr);  //  测试更新操作
				
				String delstr = "";
				stmt.executeUpdate(delstr);  //  测试删除操作
				
				String ddlstr = "";
				stmt.executeUpdate(ddlstr);  //  测试DDL操作
				
				rs.close();
				stmt.close();
					
			} catch (SQLException sqlex) {
				try
				{
				_logger.write("SQLException || Connect to Database V8.1\n");
				_logger.flush();
				sqlex.printStackTrace();
				}catch(Exception ex)
				{
				}
			} catch (Exception ex) {
				try
				{
				_logger.write("Exception || Connect to Database V8.1\n");
				_logger.flush();
				ex.printStackTrace();
				}catch(Exception eex)
				{
				}
			}
	}
}