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();
｝