บทความนี้อธิบายวิธีการใช้งาน Java ของการส่งออกบันทึกข้อมูลจำนวนมากจากฐานข้อมูลและบันทึกลงในไฟล์ แบ่งปันสำหรับการอ้างอิงของคุณดังนี้:
สคริปต์ฐานข้อมูล:
- ตาราง "t_test" ตาราง ddlcreate `t_test` (` id` int (11) ไม่ใช่ null auto_increment, `title` varchar (255) ค่าเริ่มต้น null,` createTime` Bigint (20) NULL เริ่มต้น )) เครื่องยนต์ = innoDB เริ่มต้น charset = utf8;
รหัส:
com.yanek.test; java.sql.connection; (String [] args) {test (); } *** ข้อมูลส่งออก* / โมฆะคงที่สาธารณะ exp () {การเชื่อมต่อ conn = null; ://127.0.0.1:3306/testcms?characterencoding=gbk "; สตริง jdbcusername =" root "; string jdbcpassword =" root "; conn = drivermanager.getConnection "conn" +conn); ungleclaccessexception e) {// todo บล็อก catch ที่สร้างขึ้นอัตโนมัติ E.PrintStackTrace (); } catch (sqlexception e) {// toDo บล็อก catch ที่สร้างขึ้นอัตโนมัติ E.PrintStackTrace (); .driver ") .NewInstance (); สตริง jdbcurl =" jdbc: mysql: //127.0.0.1: 3306/testcms? catreatencoding = gbk "; String jdbcusername =" root "; string jdbcpassw ord =" root "; . GetConnection (JDBCURL, JDBCUSERNAME, JDBCPassword); {// todo ที่สร้างขึ้นโดยอัตโนมัติ Catch Block E.PrintStackTrace (); Catch Block E.PrintStackTrace ();} ในที่สุด {ลอง {conn.close (); จาก startId * @ param conn * @param start_id */ public static void exp (การเชื่อมต่อ Conn, int start_id) {int counter = 0; = "เลือก * จาก t_test โดยที่ id>" + startId + "คำสั่งซื้อ id asc จำกัด 50"; RS = S tmt.executeQuery (SQL); เคาน์เตอร์ ++; println ("i ="+counter+"-id-"+id+"-ชื่อ-"+ชื่อ);} rs.close (); ();}} writeContent (""+startId, "/opt/","id.txt",False); ) {int counter = 0; จาก t_test ที่ createTime> " + timestamp +" Limit 50 "; System.out.println (" SQL === " + SQL); ลอง {คำสั่ง stmt = conn.createstatement (); Resultset rs = stmt.executeQuery (s ql ); ; );} catch (sqlexception e) {e.printstacktrace (); str ing jdbcurl = "jdbc: mysql: //127.0.0.1: 3306/testcms? jdbcpassword); System.out.println ("conn"+conn); ;}} catch (sqlexception e) {e .printstacktrace (); บล็อก E.PrintStackTrace (); บล็อกจับที่สร้างขึ้นอัตโนมัติ E.PrintStackTrace ();}}} โมฆะคงที่สาธารณะเพิ่ม (Connection Conn, String Title) {PreparedStatement PSTMT = NULL; "; system.out.println (" sql = " +insert_sql); ลอง {pstmt = conn.prepareStatement (insert_sql); pstmt.setstring (1, title); pstmt.setlong (2, system.currenttimemillis () ret = pstmt.executeupdate (); Catch Bloc K E.PrintStackTrace ();}}} / ** * เขียนเนื้อหาไปยังไฟล์ * * @param หมายเลข * @param filename * @return * / Public Static Boolean Writecontent , บูลีน i sappend) {ไฟล์ f = ไฟล์ใหม่ (dirname); ; } /*** อ่านเนื้อหาจากไฟล์** @param ::::::::::::::::::::::::::::::::: กระทาน ::::::::::::::::::::::: กระทาน ::::::::::::::::::::::::::::::::::::: กระทาน. (String Filename) {String Content = "" ลอง {ไฟล์ = ไฟล์ใหม่ (ชื่อไฟล์); String = ""; fr.close ();}} catch (ioexceptแนวคิดพื้นฐาน: มันคือการเริ่มบันทึก ID และดำเนินการ SQL หลายครั้งเพื่อประมวลผล
การใช้งานหลัก: มันสามารถใช้ในสถานการณ์ที่ส่งออกข้อมูลที่เพิ่มขึ้นให้กับบุคคลที่สามในระหว่างการพัฒนาส่วนต่อประสาน
ฉันหวังว่าบทความนี้จะเป็นประโยชน์กับการเขียนโปรแกรม Java ของทุกคน