- 先创建一个jdbc请求
- 请求在结果树正确后,添加一个循环控制器,循环次数定义数据库表查询的数量
variables names设置为col,那么如下变量会被设置为:
col_#=2 (总行数)
col_1=第1列, 第1行
col_2=第1列, 第2行 - 添加一个计数器用来坐变量拼接
- 添加请求引用N,使用函数助手
- 查看结果
- jdbc运行结果
- 查看循环读取的结果
- jdbc运行结果
package com.dqm.io;
import java.io.*;
import java.sql.*;
public class TestFile{
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
new b1().start();
}
}
class b1 extends Thread {
public void run(){
try {
String url = "jdbc:oracle:thin:@127.0.0.1:1521:tvds";
String user = "tvdb";
String password = "tvdb";
Class.forName("oracle.jdbc.driver.OracleDriver");
try {
Connection conn = DriverManager.getConnection(url, user, password);
PreparedStatement ps = conn.prepareStatement("select * from student");
ResultSet rs = ps.executeQuery();
File file = new File("D:\\student.sql");
String strContent ="";
FileWriter fw = new FileWriter(file);
PrintWriter myFile = new PrintWriter(fw);
while(rs.next()){
System.out.println(rs.getObject(1));
strContent = strContent+"insert into student values ("+rs.getString("sno")+", '"+
rs.getString("sname")+"', "+rs.getString("age")+", to_date('"+rs.getDate("ENROLLMENTDATE")+"', 'YYYY-MM-DD'));";
strContent = strContent+"\r\n";
}
myFile.println(strContent);
myFile.flush();
myFile.close();
if(!file.exists())
try {
file.createNewFile();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
rs.close();
ps.close();
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} catch (ClassNotFoundException e2) {
// TODO Auto-generated catch block
e2.printStackTrace();
}finally{
}
}
}
分享到:
2013-03-12 00:22
浏览 884
评论
package com.dqm.io; import java.io.*; import java.sql.*; public class TestFile{ /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub new b1().start(); } } class b1 extends Thread { public void run(){ try { String url = "jdbc:oracle:thin:@127.0.0.1:1521:tvds"; String user = "tvdb"; String password = "tvdb"; Class.forName("oracle.jdbc.driver.OracleDriver"); try { Connection conn = DriverManager.getConnection(url, user, password); PreparedStatement ps = conn.prepareStatement("select * from student"); ResultSet rs = ps.executeQuery(); File file = new File("D:\\student.sql"); String strContent =""; FileWriter fw = new FileWriter(file); PrintWriter myFile = new PrintWriter(fw); while(rs.next()){ System.out.println(rs.getObject(1)); strContent = strContent+"insert into student values ("+rs.getString("sno")+", '"+ rs.getString("sname")+"', "+rs.getString("age")+", to_date('"+rs.getDate("ENROLLMENTDATE")+"', 'YYYY-MM-DD'));"; strContent = strContent+"\r\n"; } myFile.println(strContent); myFile.flush(); myFile.close(); if(!file.exists()) try { file.createNewFile(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } rs.close(); ps.close(); conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } catch (ClassNotFoundException e2) { // TODO Auto-generated catch block e2.printStackTrace(); }finally{ } } }
- 先创建一个jdbc请求
- 请求在结果树正确后,添加一个循环控制器,循环次数定义数据库表查询的数量
variables names设置为col,那么如下变量会被设置为:
col_#=2 (总行数)
col_1=第1列, 第1行
col_2=第1列, 第2行
- 添加一个计数器用来坐变量拼接
- 添加请求引用N,使用函数助手
- 查看结果
- jdbc运行结果
- 查看循环读取的结果
转载于:https://www.cnblogs.com/only-love-you-519920/p/9135006.html
private void Approve(string a) { SqlConnection sqlcon = DataOp.getConn(); sqlcom = new SqlCommand(); sqlcom.Connection = sqlcon; sqlcom.CommandType = CommandType.Text; try { string sql = "SELECT * FROM 表1 WHERE 某字段='+a+'"; sqlcom.CommandText = sql; SqlDataReader sqldr = sqlcom.ExecuteReader(); while (sqldr.Read())//这是一行一行的读取查询出来的数据集 { if (sqldr.GetString(0) == 某某) { //在这里添加你的操作; break; } } sqldr.Close(); }