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 org.opengauss.Driver;

public class JDBC_Connection_Case0001 {
	public static void main(String[] args) throws SQLException {
		System.out.println(Driver.getGSVersion());
		if (args.length < 4) {
			System.out.print("need para: host:ip,db_b,user,password");
			return;
		}
		String url1 = "jdbc:opengauss://" + args[0] + "/" + args[1]
				+ "?loggerLevel=off&allowEncodingChanges=true&characterEncoding=" + args[4];
		String url2 = "jdbc:opengauss://" + args[0] + "/" + args[1]
				+ "?LoggerLevel=off&allowEncodingChanges=true&characterEncoding=" + args[5];
		String t_name1 = "t_jdbc_connection_01_1";
		String t_name2 = "t_jdbc_connection_01_2";
		String create_sql1 = "drop table if exists " + t_name1 + "; create table " + t_name1
				+ "(id varchar(1000), name text);";
		String create_sql2 = "drop table if exists " + t_name2 + "; create table " + t_name2
				+ "(id varchar(1000), name text);";

		System.out.println("----新建连接1----");
		Connection conn1 = GetConnection(args[2], args[3], url1);
		Statement statement1 = conn1.createStatement();

		System.out.println("----连接1插入数据----");
		statement1.executeUpdate(create_sql1);
		String sql1 = "insert into " + t_name1 + "(id,name) values (?,?)";
		PreparedStatement preparedStatement = conn1.prepareStatement(sql1);
		preparedStatement.setString(1, "只有一个connection1，connection1再次插入数据");
		preparedStatement.setString(2, "%%￥￥##");
		preparedStatement.execute();

		System.out.println("----新建连接2----");
		Connection conn2 = GetConnection(args[2], args[3], url2);
		Statement statement2 = conn2.createStatement();

		System.out.println("----连接1再次插入数据----");
		preparedStatement = conn1.prepareStatement(sql1);
		preparedStatement.setString(1, "新建connection2后，connection1再次插入数据");
		preparedStatement.setString(2, "%%￥￥##");
		preparedStatement.execute();

		System.out.println("----连接1查询数据----");
		String select_sql1 = "select * from " + t_name1;
		try (ResultSet resultSet = statement1.executeQuery(select_sql1)) {
			while (resultSet.next()) {
				System.out.print("connection1： col1 = " + resultSet.getObject(1).toString());
				System.out.println("      connection1： col2 = " + resultSet.getObject(2));
			}
		}

		System.out.println("----连接2插入数据，查询数据----");
		statement2.executeUpdate(create_sql2);
		String sql2 = "insert into " + t_name2 + "(id,name) values (?,?)";
		preparedStatement = conn2.prepareStatement(sql2);
		preparedStatement.setString(1, "连接2插入数据");
		preparedStatement.setString(2, "……99*%#%");
		preparedStatement.execute();
		String select_sql2 = "select * from " + t_name2;
		try (ResultSet resultSet = statement2.executeQuery(select_sql2)) {
			while (resultSet.next()) {
				System.out.print("connection2： col1 = " + resultSet.getObject(1).toString());
				System.out.println("      connection2： col2 = " + resultSet.getObject(2));
			}
		}

		System.out.println("----删除表----");
		String drop_sql = "drop table if exists " + t_name1 + "drop table if exists " + t_name2;
		statement2.executeUpdate(drop_sql);

		statement1.close();
		statement2.close();
		conn1.close();
		conn2.close();

	}

	public static Connection GetConnection(String username, String passwd, String sourceURL) {
		Connection conn = null;
		try {
			conn = DriverManager.getConnection(sourceURL, username, passwd);
			System.out.println(sourceURL);
			System.out.println("Connection succeed");
		} catch (Exception e) {
			e.printStackTrace();
			return null;
		}
		return conn;
	}
}