第一部分代码(实体类)
แพ็คเกจ com.wf.entity; คลาสสาธารณะ hehe {ส่วนตัว int hehe_id; สตริงส่วนตัว hehe_name; สตริงส่วนตัว hehe_gender, public int gethehe_id () {return hehe_id;} public void sethehe_id (int heheid) โมฆะ sethehe_name (สตริง hehename) {hehe_name = hehename;} สตริงสาธารณะ gethehe_gender () {return hehe_gender;} โมฆะสาธารณะ sethehe_gender (hehegender) {hehe_gender = hehegender;第二部分第二部分 (增删改查和查唯一 (增删改查和查唯一)
แพ็คเกจ com.wf.dao; นำเข้า java.sql.connection; นำเข้า java.sql.drivermanager; นำเข้า java.sql.preparedStatement; นำเข้า java.sql.resultset; นำเข้า java.sql.sqlexception; string url = "mysql: // localhost: 3306/mysql"; ผู้ใช้สตริงสุดท้ายที่ได้รับการป้องกัน = "รูท"; รหัสผ่านสตริงสุดท้ายที่ได้รับการป้องกัน = "******"; การเชื่อมต่อการเชื่อมต่อป้องกัน = null; class.forname (ไดรเวอร์); this.connection = driverManager.getConnection (URL, ผู้ใช้, รหัสผ่าน);}/*** 通用的增删改方法* @param sql sql 语句* @param params 参数数组* @return 受影响的行数*/การป้องกัน int executeUpdate (String sql, String [] พารามิเตอร์) {this.getConnection (); this.preparedStatement = this.connection.preparestatement (sql); ถ้า (null! = params) {สำหรับ (int i = 0; i <params.length; i ++) {this.preparedStatement.setString this.preparedStatement.executeUpdate ();} catch (classnotFoundException e) {e.printstacktrace ();} catch (sqlexception e) {e.printstacktrace ();} {this.close (); sql, string [] params) {ลอง {this.getConnection (); this.preparedStatement = this.connection.preparestatement (sql); ถ้า (null! = params) {สำหรับ (int i = 0; i <params.length; i ++) } this.resultset = this.preparedStatement.executeQuery ();} catch (classnotFoundException e) {e.printstacktrace ();} catch (sqlexception e) {e.printstacktrace ();}}}} /*** 查询唯一的结果*@return Object*/วัตถุที่ได้รับการป้องกัน ExecuteQueryUnique (String sql, string [] params) {object object = null; ลอง {this.getConnection (); this.preparedStatement = this.connection.preparestatement (sql); {this.preparedStatement.setString (i+1, params [i]);}} this.resultset = this.preparedStatement.executeQuery (); ถ้า (this.resultset.next ()) {catching) {catching) e) {e.printstacktrace ();} return object;} void protected close () {ลอง {ถ้า (null! = this.resultset) this.resultset.close (); ถ้า (null! (sqlexception e) {e.printstacktrace ();}}第三部分 hehedao
แพ็คเกจ com.wf.dao; นำเข้า java.sql.connection; นำเข้า java.sql.preparedStatement; นำเข้า java.sql.sqlexception; นำเข้า com.wf.entity.hehe; ชั้นเรียนสาธารณะ hehedao ขยายพื้นฐาน hehe (hehe_name, hehe_gender) ค่า (?,?) "; string [] params = สตริงใหม่ [] {hehe.gethehe_name (), hehe.gethe_gender ()}; return.executeupdate (sql, params)> 0? จริง: เท็จ;}第四部分 test_basedao_insert
แพ็คเกจ com.wf.test; นำเข้า com.wf.dao.hedao; นำเข้า com.wf.entity.hehe; คลาสสาธารณะ test_basedao_insert {โมฆะคงที่สาธารณะ (สตริง [] args) {hehe hehe = ใหม่ hehe (); hehe.sethehe_name ("个"); hehe.sethehe_gender ("b"); hehedao _hd = new hehedao (); ถ้า (_hd.insert (hehe)) ระบบ.