package PreparedStatement;

import java.io.ByteArrayInputStream;
import java.io.InputStream;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.UUID;

import org.opengauss.Driver;

/**
 * @作者 ： pwx5328113 @时间 ： 2023/9/27
 * @测试点 : blob字段类型setBinaryStream\setBlob\getBlob方法覆盖
 **/
public class JDBC_PreparedStatement_Case0002 {
	public static void main(String[] args) throws Exception {
		if (args.length < 4) {
			System.out.print("need para: host:ip,db_b,user,password");
			return;
		}
		System.out.println(Driver.getGSVersion());
		String t_name = "t_jdbc_preparedstatament_0027";
		String url1 = "jdbc:opengauss://" + args[0] + "/" + args[1] + "?LoggerLevel=off&blobMode=on";
		Connection connection1 = DriverManager.getConnection(url1, args[2], args[3]);
		Statement statement = connection1.createStatement();
		String create_sql = "drop table if exists " + t_name + "; " + "create table " + t_name
				+ " (id varchar(64), col_blob blob);";
		statement.executeUpdate(create_sql);

		String insert_sql = "insert into " + t_name + " (id, col_blob) values (?, ?)";
		String select_sql = "select id,col_blob from " + t_name;
		String content = "通过setBinaryStream方法插入blob数据";
		InputStream inputStream1 = new ByteArrayInputStream(content.getBytes());
		PreparedStatement preparedStatement = connection1.prepareStatement(insert_sql);
		preparedStatement.setString(1, UUID.randomUUID().toString());
		preparedStatement.setBinaryStream(2, inputStream1);
		preparedStatement.execute();
		System.out.println("testcase1：通过setBinaryStream方法插入blob数据成功");
		content = "通过setBlob方法插入blob数据";
		inputStream1 = new ByteArrayInputStream(content.getBytes());
		preparedStatement.setString(1, UUID.randomUUID().toString());
		preparedStatement.setBlob(2, inputStream1);
		preparedStatement.execute();
		System.out.println("testcase2：通过setBlob方法插入blob数据成功");
		try {
			preparedStatement.setString(1, UUID.randomUUID().toString());
			preparedStatement.setBytes(2, content.getBytes());
			preparedStatement.execute();
		} catch (Exception e) {
			System.out.println("testcase3：通过setBytes方法插入blob数据报错 \n" + e.getMessage());
		}
		try (ResultSet resultSet = statement.executeQuery(select_sql)) {
			while (resultSet.next()) {
				String col1 = resultSet.getObject(1).toString();
				Object col2 = resultSet.getObject(2);
				Blob col3 = resultSet.getBlob(2);
				System.out.println("col1 = " + col1);
				System.out.println("testcase4：getObject获取blob字段 = " + new String((byte[]) col2)); // getObject获取结果以字符串方式显示
				System.out.println("testcase5：getBlob获取blob字段 = " + new String(col3.getBytes(1, (int) col3.length()))); // getBlob获取结果以字符串方式显示
			}
		}
		statement.executeUpdate("drop table " + t_name);
		preparedStatement.close();
		statement.close();
		statement.close();
	}
}