import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import com.microsoft.sqlserver.jdbc.*;


public class app {

    public static void main(String[] args) {

        String connectionString = "jdbc:sqlserver://servidororigem;" + "database=soubotafogo_backup;"
                + "user=usuario;" + "password=senha;" + "encrypt=true;"
                + "trustServerCertificate=false;" + "hostNameInCertificate=*.database.windows.net;"
                + "loginTimeout=30;";

        String connectionStringDestino = "jdbc:sqlserver://servidordestino;" + "database=soubotafogo;"
                + "user=usuario;" + "password=senha;" + "encrypt=true;"
                + "trustServerCertificate=false;" + "hostNameInCertificate=*.database.windows.net;"
                + "loginTimeout=30;";

        Connection conexao_origem = null;
        Connection conexao_destino = null;
        Statement statement = null;
        ResultSet resultSet = null;
        PreparedStatement st = null;

        String selectSql = "SELECT TOP 10 IDCOBRANCA, IDCLIENTE_FK, IDASSINATURA_FK, IDSOCIO_FK, NUMPEDIDO, IDAPIPAGAMENTO_FK, IDTIPOPAGAMENTO_FK,"
        + " MES_REFERENCIA, NUM_TENTATIVAS, QTD_PARCELAS, VR_TOTALCOBRANCA, IDULTBRASPAGTRANSACAO, DT_CADASTRO, "
        + " DT_CANCELAMENTO, DT_ESTORNO, DT_PAGAMENTO, ESTADO, EMAILAVISO, DT_VENCIMENTO, FLG_IMPORT, IDITEM_TEMP, DT_ULT_TENTATIVA"
        + " FROM COBRANCA "
        + " WHERE FLG_IMPORT IS NOT NULL";

        String insertSql = "SET IDENTITY_INSERT COBRANCA ON; INSERT INTO COBRANCA(IDCOBRANCA, IDCLIENTE_FK, IDASSINATURA_FK, IDSOCIO_FK, NUMPEDIDO, IDAPIPAGAMENTO_FK, IDTIPOPAGAMENTO_FK,"
        + " MES_REFERENCIA, NUM_TENTATIVAS, QTD_PARCELAS, VR_TOTALCOBRANCA, IDULTBRASPAGTRANSACAO, DT_CADASTRO, "
        + " DT_CANCELAMENTO, DT_ESTORNO, DT_PAGAMENTO, ESTADO, EMAILAVISO, DT_VENCIMENTO, FLG_IMPORT, IDITEM_TEMP, DT_ULT_TENTATIVA)"
        + " VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";

        try {
            conexao_origem = DriverManager.getConnection(connectionString);
            conexao_destino = DriverManager.getConnection(connectionStringDestino);

            Statement stmt = conexao_origem.createStatement();
            resultSet = stmt.executeQuery(selectSql);
            while (resultSet.next()) {
                st = conexao_destino.prepareStatement(insertSql);
                st.setInt(1, resultSet.getInt(1));
                st.setInt(2, resultSet.getInt(2));
                st.setInt(3, resultSet.getInt(3));
                st.setInt(4, resultSet.getInt(4));
                st.setString(5, resultSet.getString(5));
                st.setInt(6, resultSet.getInt(6));
                st.setInt(7, resultSet.getInt(7));
                st.setInt(8, resultSet.getInt(8));
                st.setInt(9, resultSet.getInt(9));
                st.setInt(10, resultSet.getInt(10)); // qtd_parcelas
                st.setFloat(11, resultSet.getFloat(11));
                st.setInt(12, resultSet.getInt(12));
                st.setString(13, resultSet.getString(13));
                st.setString(14, resultSet.getString(14));
                st.setString(15, resultSet.getString(15));
                st.setString(16, resultSet.getString(16));
                st.setString(17, resultSet.getString(17));
                st.setInt(18, 1);
                st.setString(19, resultSet.getString(19));
                st.setString(20, resultSet.getString(20));
                st.setInt(21, resultSet.getInt(21));
                st.setString(22, resultSet.getString(22));
            }
            st.executeUpdate();
            st.close();
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
}