📄 datatidy_insert.jsp
字号:
程序功能：实现jsp数据插入功能。
<%@ page contentType="text/html;charset=gb2312"%>
<%@ page import="java.sql.*"%>
<%@ page import="java.lang.*"%>
<%@page import="java.sql.ResultSet"%>
<jsp:useBean id="DB_Conn" scope="page" class="JavaBean.DB_Conn"/>
<jsp:useBean id="DB_User" scope="page" class="JavaBean.DB_User"/>
<body style="background-attachment: fixed">
<br>
<br>
<br>
<br>
<br>
<center>
<FONT style="FONT-SIZE:10pt">
<%out.print("您已经将数据插入到数据库!");%>
</font>
</center>
<%String hint_dest_table[] =request.getParameterValues("DEST_TABLE");%>
<%String hint_sour_table[] =request.getParameterValues("SOUR_TABLE");%>
<%String hint_dest_column[] =request.getParameterValues("DEST_COLUMN");%>
<%String hint_sour_column[] =request.getParameterValues("SOUR_COLUMN");%>
<%String hint_dest_type[] =request.getParameterValues("DEST_TYPE");%>
<%String hint_sour_type[] =request.getParameterValues("SOUR_TYPE");%>
<%String hint_operator[] =new String[hint_dest_table.length];%>
<%for(int m=0;m<hint_dest_table.length;m++){%>
<%hint_operator[m]="lisi";%>
<%System.out.println(hint_operator[m]);%>
<%System.out.println(hint_dest_table[m]);%>
<%System.out.println(hint_sour_table[m]);%>
<%System.out.println(hint_dest_column[m]);%>
<%System.out.println(hint_sour_column[m]);%>
<%System.out.println(hint_dest_type[m]);%>
<%System.out.println(hint_sour_type[m]);%>
<br>
<%}%>
<%
DB_Conn.ConnectDestDB();
ResultSet compare_rs1 = null;
String sql1 = "select * from COMPARE_RESULT ";
compare_rs1 = DB_Conn.sm.executeQuery(sql1);
ResultSetMetaData mtdt1=compare_rs1.getMetaData();
int table_length1=mtdt1.getColumnCount();
%>
<%int leng=0;%>
<%int m=0;%>
<%while(compare_rs1.next()){%>
<%m++;%>
<%leng=m;%>
<%}%>
<%System.out.print(leng);%>
<%String test_dest_table[] =new String[leng];%>
<%String test_sour_table[] =new String[leng];%>
<%String test_dest_column[] =new String[leng];%>
<%String test_sour_column[] =new String[leng];%>
<%
Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();
String url="jdbc:oracle:thin:@211.64.219.91:1521:QDKD";
String user="tran";
String password="tran";
String sql = "select * from COMPARE_RESULT";
Connection conn= DriverManager.getConnection(url,user,password);
Statement stmt=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
ResultSet rs =stmt.executeQuery(sql);
%>
<%int p=0;%>
<%while (rs.next()){%>
<%test_dest_table[p]=rs.getString(1);%>
<%test_sour_table[p]=rs.getString(2);%>
<%test_dest_column[p]=rs.getString(3);%>
<%test_sour_column[p]=rs.getString(4);%>
<%p++;%>
<%}%>
<%for(int q=0;q<leng;q++){%>
<%System.out.print(test_dest_table[q]);%>
<%System.out.print(test_sour_table[q]);%>
<%System.out.print(test_dest_column[q]);%>
<%System.out.print( test_sour_column[q]);%>
<br>
<%}%>
<%for(int n=0;n<hint_dest_table.length;n++){%>
<%String A=hint_dest_table[n];%>
<%String B=hint_sour_table[n];%>
<%String C=hint_dest_column[n];%>
<%String D=hint_sour_column[n];%>
<%for(int k=0;k<leng;k++){%>
<%if(A==test_dest_table[k] && B==test_sour_table[k] && C==test_dest_column[k] && D==test_sour_column[k]){%>
<%}%>
<%}%>
<%Class.forName("oracle.jdbc.driver.OracleDriver").newInstance();%>
<%String deleteurl="jdbc:oracle:thin:@211.64.219.91:1521:QDKD"; %>
<%String deleteuser="tran"; %>
<%String deletepassword="tran"; %>
<%Connection deleteconn= DriverManager.getConnection(deleteurl,deleteuser,deletepassword); %>
<%Statement deletestmt=deleteconn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE); %>
<%String deletesql="delete from COMPARE_RESULT where DEST_TABLE="+"'"+A+"'"+"and SOUR_TABLE="+"'"+B+"'"+"and DEST_COLUMN="+"'"+C+"'"+"and SOUR_COLUMN="+"'"+D+"'"; %>
<%deletestmt.executeUpdate(deletesql); %>
<%}%>
<%Connection insertconn=null;
PreparedStatement insertpst=null;
CallableStatement insertcs=null;
try{
Class.forName("oracle.jdbc.driver.OralceDriver");
}
catch(ClassNotFoundException ce){
System.out.println(ce.getMessage());
}
try{
String inserturl="jdbc:oracle:thin:@211.64.219.91:1521:QDKD";
insertconn=DriverManager.getConnection(inserturl,"tran","tran");
insertpst=insertconn.prepareStatement("INSERT INTO COMPARE_RESULT(DEST_TABLE,SOUR_TABLE,DEST_COLUMN,SOUR_COLUMN,DEST_TYPE,SOUR_TYPE,OPERATOR) VALUES(?,?,?,?,?,?,?)");
for(int i=0;i<hint_dest_table.length;i++){
insertpst.setString(1,hint_dest_table[i]) ;
insertpst.setString(2,hint_sour_table[i]);
insertpst.setString(3,hint_dest_column[i]);
insertpst.setString(4,hint_sour_column[i]) ;
insertpst.setString(5,hint_dest_type[i]);
insertpst.setString(6,hint_sour_type[i]);
insertpst.setString(7,hint_operator[i]);
insertpst.executeUpdate();
}
}catch (SQLException e){
System.out.print(e);
}
%>
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -