第一部分代码(实体类)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
package com.wf.entity;
public class Hehe{
private int hehe_id;
private String hehe_name;
private String hehe_gender;
public int getHehe_id(){
return hehe_id;
}
public void setHehe_id(int heheId){
hehe_id=heheId;
}
public String getHehe_name() {
return hehe_name;
}
public void setHehe_name( String heheName) {
hehe_name = heheName;
}
public String getHehe_gender() {
return hehe_gender;
}
public void setHehe_gender( String heheGender) {
hehe_gender = heheGender;
}
}
|
第二部分 BaseDao(增删改查和查唯一)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
package com.wf.dao;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class BaseDao{
protected static final String DRIVER= "com.mysql.jdbc.Driver" ;
protected static final String URL= "mysql://localhost:3306/mysql" ;
protected static final String USER= "root" ;
protected static final String PASSWORD= "******" ;
protected Connection connection= null ;
protected PreparedStatement preparedStatement= null ;
protected ResultSet resultSet = null ;
protected void getconnection() throws ClassNotFoundException, SQLException{
Class.forName(DRIVER);
this .connection =DriverManager.getconnection (URL,USER,PASSWORD);
}
/**
* 通用的增删改方法
* @param sql SQL语句
* @param params 参数数组
* @return 受影响的行数
*/
protected int executeUpdate(String sql ,String[]params){
int result=- 1 ;
try {
this .getconnection();
this .preparedStatement= this .connection.prepareStatement(sql);
if ( null !=params){
for ( int i = 0 ; i < params.length; i++) {
this .preparedStatement.setString(i+ 1 , params[i]);
}
}
result= this .preparedStatement.executeUpdate();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
this .close();
}
return result;
}
/**
* 查询结果集的方法
* @param sql
* @param params
*/
protected void executeQuery(String sql,String[]params){
try {
this .getconnection();
this .preparedStatement= this .connection.prepareStatement(sql);
if ( null !=params){
for ( int i = 0 ; i < params.length; i++) {
this .preparedStatement.setString(i+ 1 , params[i]);
}
}
this .resultSet= this .preparedStatement.executeQuery();
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
/**
* 查询唯一的结果
* @return Object
*/
protected Object executeQueryUnique(String sql,String[]params){
Object object= null ;
try {
this .getconnection();
this .preparedStatement= this .connection.prepareStatement(sql);
if ( null !=params){
for ( int i = 0 ; i < params.length; i++) {
this .preparedStatement.setString(i+ 1 , params[i]);
}
}
this .resultSet= this .preparedStatement.executeQuery();
if ( this .resultSet.next())
object= this .resultSet.getObject( 1 );
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
return object;
}
protected void close(){
try {
if ( null != this .resultSet)
this .resultSet.close();
if ( null != this .preparedStatement)
this .preparedStatement.close();
if ( null != this .connection)
this .connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
|
第三部分 HeheDao
1
2
3
4
5
6
7
8
9
10
11
|
package com.wf.dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import com.wf.entity.Hehe;
public class HeheDao extends BaseDao{
public boolean insert(Hehe hehe){
String sql= "insert into hehe(hehe_name,hehe_gender) values(?,?)" ;
String []params= new String[]{hehe.getHehe_name(),hehe.getHehe_gender()};
return this .executeUpdate(sql, params)> 0 ? true : false ;
}
|
第四部分 测试Test_BaseDao_Insert
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
|
package com.wf.test;
import com.wf.dao.HeheDao;
import com.wf.entity.Hehe;
public class Test_BaseDao_Insert {
public static void main(String[] args) {
Hehe hehe= new Hehe();
hehe.setHehe_name( "个" );
hehe.setHehe_gender( "b" );
HeheDao _hd= new HeheDao();
if (_hd.insert(hehe))
System.out.println( "成功!" );
else
System.out.println( "失败!" );
}
}
|
原文链接:http://www.cnblogs.com/wffj150926/archive/2016/12/25/6219908.html