java连接mysql数据库增删改查操作记录
2014-08-18 21:16
543 查看
1. 连接数据库,得到数据库连接变量
[java] view plaincopyprint?
01.//注意,这是连接mysql的方法
注意连接数据库的时候
(1)打开DB Browser 新建一个Database Driver,注意添加Driver JARs的时候添加的包,我的是mysql-connector-java-5.0.3-bin.jar
(2)要将数据库jar包拷贝到工程下的WEB-INF\lib下
[java] view plaincopyprint?
01.import java.sql.Connection;//java包
02.public class DBConnection
03. {
04. private String dbDriver="com.mysql.jdbc.Driver";
05. private String dbUrl="jdbc:mysql://[ip地址]:[端口号]/[数据库名]";//根据实际情况变化
06. private String dbUser="root";
07. private String dbPass="root";
08. public Connection getConn()
09. {
10. Connection conn=null;
11. try
12. {
13. Class.forName(dbDriver);
14. }
15. catch (ClassNotFoundException e)
16. {
17. e.printStackTrace();
18. }
19. try
20. {
21. conn = DriverManager.getConnection(dbUrl,dbUser,dbPass);//注意是三个参数
22. }
23. catch (SQLException e)
24. {
25. e.printStackTrace();
26. }
27. return conn;
28. }
29. }
2. 插入操作
[java] view plaincopyprint?
01.public int insert()
02.{
03. int i=0;
04. String sql="insert into (表名)(列名1,列明2) values(?,?)";
05. Connection cnn=getConn();
06.
07. try{
08. PreparedStatement preStmt =cnn.prepareStement(sql);
09. preStmt.setString(1,值);
10. preStmt.setString(2,值);//或者:preStmt.setInt(1,值);
11. i=preStmt.executeUpdate();
12. }
13. catch (SQLException e)
14. {
15. e.printStackTrace();
16. }
17. return i;//返回影响的行数,1为执行成功
18.}
3. 更新操作
[java] view plaincopyprint?
01.public int update
02.{
03. int i=0;
04. String sql="update (表名) set (列名1)=?,列明2=? where (列名)=?";//注意要有where条件
05. Connection cnn=getConn();
06.
07.
08. try{
09. PreparedStatement preStmt =cnn.prepareStatement(sql);
10. preStmt.setString(1,(值));
11. preStmt.setString(2,(值));//或者:preStmt.setInt(1,值);
12. preStmt.setInt(3,(值));
13. i=preStmt.executeUpdate();
14. }
15. catch (SQLException e)
16. {
17. e.printStackTrace();
18. }
19. return i;//返回影响的行数,1为执行成功
20.}
4. 查找操作
[java] view plaincopyprint?
01.public String select
02. {
03. String sql = "select * from (表名) where (列名)=(值)";
04. Connection cnn = getConn();//此处为通过自己写的方法getConn()获得连接
05. try
06. {
07. Statement stmt = conn.createStatement();
08. ResultSet rs = stmt.executeQuery(sql);
09.
10. if(rs.next())
11. {
12. int m1 = rs.getInt(1);//或者为rs.getString(1),根据数据库中列的值类型确定,参数为第一列
13. String m2 = rs.getString(2);
14. }
15. //可以将查找到的值写入类,然后返回相应的对象
16. }
17. catch (SQLException e)
18. {
19. e.printStackTrace();
20. }
21. return (相应的值的变量);
22. }
5. 删除操作
[java] view plaincopyprint?
01.public int delete()
02.{
03. String sql = "delete from (表名) where (列名)=(值)";
04. int i=0;
05. Connection conn = getConn();//此处为通过自己写的方法getConn()获得连接
06. try
07. {
08. Statement stmt = conn.createStatement();
09. i = stmt.executeUpdate(sql);
10. }
11. catch (SQLException e)
12. {
13. e.printStackTrace();
14. }
15. return i;//如果返回的是1,则执行成功;
16.}
[java] view plaincopyprint?
01.//注意,这是连接mysql的方法
注意连接数据库的时候
(1)打开DB Browser 新建一个Database Driver,注意添加Driver JARs的时候添加的包,我的是mysql-connector-java-5.0.3-bin.jar
(2)要将数据库jar包拷贝到工程下的WEB-INF\lib下
[java] view plaincopyprint?
01.import java.sql.Connection;//java包
02.public class DBConnection
03. {
04. private String dbDriver="com.mysql.jdbc.Driver";
05. private String dbUrl="jdbc:mysql://[ip地址]:[端口号]/[数据库名]";//根据实际情况变化
06. private String dbUser="root";
07. private String dbPass="root";
08. public Connection getConn()
09. {
10. Connection conn=null;
11. try
12. {
13. Class.forName(dbDriver);
14. }
15. catch (ClassNotFoundException e)
16. {
17. e.printStackTrace();
18. }
19. try
20. {
21. conn = DriverManager.getConnection(dbUrl,dbUser,dbPass);//注意是三个参数
22. }
23. catch (SQLException e)
24. {
25. e.printStackTrace();
26. }
27. return conn;
28. }
29. }
2. 插入操作
[java] view plaincopyprint?
01.public int insert()
02.{
03. int i=0;
04. String sql="insert into (表名)(列名1,列明2) values(?,?)";
05. Connection cnn=getConn();
06.
07. try{
08. PreparedStatement preStmt =cnn.prepareStement(sql);
09. preStmt.setString(1,值);
10. preStmt.setString(2,值);//或者:preStmt.setInt(1,值);
11. i=preStmt.executeUpdate();
12. }
13. catch (SQLException e)
14. {
15. e.printStackTrace();
16. }
17. return i;//返回影响的行数,1为执行成功
18.}
3. 更新操作
[java] view plaincopyprint?
01.public int update
02.{
03. int i=0;
04. String sql="update (表名) set (列名1)=?,列明2=? where (列名)=?";//注意要有where条件
05. Connection cnn=getConn();
06.
07.
08. try{
09. PreparedStatement preStmt =cnn.prepareStatement(sql);
10. preStmt.setString(1,(值));
11. preStmt.setString(2,(值));//或者:preStmt.setInt(1,值);
12. preStmt.setInt(3,(值));
13. i=preStmt.executeUpdate();
14. }
15. catch (SQLException e)
16. {
17. e.printStackTrace();
18. }
19. return i;//返回影响的行数,1为执行成功
20.}
4. 查找操作
[java] view plaincopyprint?
01.public String select
02. {
03. String sql = "select * from (表名) where (列名)=(值)";
04. Connection cnn = getConn();//此处为通过自己写的方法getConn()获得连接
05. try
06. {
07. Statement stmt = conn.createStatement();
08. ResultSet rs = stmt.executeQuery(sql);
09.
10. if(rs.next())
11. {
12. int m1 = rs.getInt(1);//或者为rs.getString(1),根据数据库中列的值类型确定,参数为第一列
13. String m2 = rs.getString(2);
14. }
15. //可以将查找到的值写入类,然后返回相应的对象
16. }
17. catch (SQLException e)
18. {
19. e.printStackTrace();
20. }
21. return (相应的值的变量);
22. }
5. 删除操作
[java] view plaincopyprint?
01.public int delete()
02.{
03. String sql = "delete from (表名) where (列名)=(值)";
04. int i=0;
05. Connection conn = getConn();//此处为通过自己写的方法getConn()获得连接
06. try
07. {
08. Statement stmt = conn.createStatement();
09. i = stmt.executeUpdate(sql);
10. }
11. catch (SQLException e)
12. {
13. e.printStackTrace();
14. }
15. return i;//如果返回的是1,则执行成功;
16.}
相关文章推荐
- java连接mysql数据库增删改查操作记录
- java连接mysql数据库增删改查操作记录
- java连接mysql数据库增删改查操作记录
- java连接mysql数据库增删改查操作记录
- java连接mysql数据库增删改查操作记录
- java连接mysql数据库增删改查操作记录
- Java连接本地MySQL数据库进行增删改查操作
- Java连接Mysql数据库增删改查操作
- java连接mysql数据库 三 实现增删改查操作
- Java连接MySQL数据库实现增删改查操作!
- Java连接本地MySQL数据库进行增删改查操作
- JAVA连接到MySQL数据库的基本操作
- MySQL入门接触记录--从安装到Java通过JDBC连接MySQL数据库
- mysql数据库的连接以及增删改查Java代码实现(Statement版)
- Java连接MySQL数据库及操作
- java连接mysql与简单操作mysql的增删改查简单例子
- Java连接Mysql数据库的基本操作
- JAVA通过JDBC连接并操作MySQL数据库
- vs2010连接mysql数据库进行增删改查操作
- java连接mysql数据库的正确操作流程