最新文章专题视频专题问答1问答10问答100问答1000问答2000关键字专题1关键字专题50关键字专题500关键字专题1500TAG最新视频文章推荐1 推荐3 推荐5 推荐7 推荐9 推荐11 推荐13 推荐15 推荐17 推荐19 推荐21 推荐23 推荐25 推荐27 推荐29 推荐31 推荐33 推荐35 推荐37视频文章20视频文章30视频文章40视频文章50视频文章60 视频文章70视频文章80视频文章90视频文章100视频文章120视频文章140 视频2关键字专题关键字专题tag2tag3文章专题文章专题2文章索引1文章索引2文章索引3文章索引4文章索引5123456789101112131415文章专题3
当前位置: 首页 - 科技 - 知识百科 - 正文

MySQL的简单操作方法:Statement、PreparedStatement_MySQL

来源:动视网 责编:小采 时间:2020-11-09 19:48:47
文档

MySQL的简单操作方法:Statement、PreparedStatement_MySQL

MySQL的简单操作方法:Statement、PreparedStatement_MySQL:(1)连接mysql的工具类:DBUtil.java package com.xuliugen.util; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet;
推荐度:
导读MySQL的简单操作方法:Statement、PreparedStatement_MySQL:(1)连接mysql的工具类:DBUtil.java package com.xuliugen.util; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet;


(1)连接mysql的工具类:DBUtil.java

package com.xuliugen.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBUtil {
 public static Connection getConn() {
 Connection conn = null;
 try {
 Class.forName("com.mysql.jdbc.Driver");
 conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/你的数据库名称", "你的账号", "你的密码");
 } catch (ClassNotFoundException e) {
 e.printStackTrace();
 } catch (SQLException e) {
 e.printStackTrace();
 }
 return conn;
 }

 public static PreparedStatement prepareStmt(Connection conn, String sql) {
 PreparedStatement pstmt = null;
 try {
 pstmt = conn.prepareStatement(sql);
 } catch (SQLException e) {
 e.printStackTrace();
 }
 return pstmt;
 }

 public static ResultSet executeQuery(Statement stmt, String sql) {
 ResultSet rs = null;
 try {
 rs = stmt.executeQuery(sql);
 } catch (SQLException e) {
 e.printStackTrace();
 }
 return rs;
 }


 public static void close(Connection conn, Statement stmt,
 PreparedStatement preStatement, ResultSet rs) {
 if (conn != null) {
 try {
 conn.close();
 } catch (SQLException e) {
 e.printStackTrace();
 }
 conn = null;
 }
 if (stmt != null) {
 try {
 stmt.close();
 } catch (SQLException e) {
 e.printStackTrace();
 }
 stmt = null;
 }
 if (preStatement != null) {
 try {
 preStatement.close();
 } catch (SQLException e) {
 e.printStackTrace();
 }
 preStatement = null;
 }

 if (rs != null) {
 try {
 rs.close();
 } catch (SQLException e) {
 e.printStackTrace();
 }
 rs = null;
 }
 }
}

(2)使用preparedStatement插入数据的数据库:

public boolean saveComment(Comment comment) {

 Connection connection = DBUtil.getConn();
 String sql = "insert into comment values (null,?,?,?,?)";
 PreparedStatement preparedStatement = null;
 boolean flag = false;
 try {
 preparedStatement = connection.prepareStatement(sql);
 preparedStatement.setString(1, comment.getCommenttext() + "");
 preparedStatement.setString(2, comment.getCommenttime() + "");
 preparedStatement.setString(3, comment.getUserid() + "");
 preparedStatement.setString(4, comment.getArticleid() + "");
 int isOk = preparedStatement.executeUpdate();
 if (isOk > 0) {
 return !flag;
 } else {
 return flag;
 }
 } catch (SQLException e) {
 e.printStackTrace();
 }
 DBUtil.close(connection, null, preparedStatement, null);
 return flag;
 }

(3)使用preparedStatement选择数据,读取数据:

public List getCommentDetail(int userid, int articleid) {
 Connection connection = DBUtil.getConn();
 String sql = "select * from comment c where c.userid=? and c.articleid=?";// 编写sql语句,第一个字段不需要插入,是自动增加的
 PreparedStatement preparedStatement = null;
 List commentList = new ArrayList();
 try {
 preparedStatement = connection.prepareStatement(sql);
 preparedStatement.setInt(1, userid);
 preparedStatement.setInt(2, articleid);
 //这里的产讯不需要传入sql语句
 ResultSet rs = preparedStatement.executeQuery();

 // 判断是否为空
 if (rs.next()) {
 while (rs.next()) {// 将信息迭代到list中
 Comment comment = new Comment();
 comment.setCommentid(rs.getInt("commentid"));
 comment.setCommenttext(rs.getString("commenttext"));
 comment.setCommenttime(rs.getString("commenttime"));
 comment.setUserid(rs.getInt("userid"));
 comment.setArticleid(rs.getInt("articleid"));

 commentList.add(comment);
 }
 } else {
 return null;
 }

 } catch (SQLException e) {
 e.printStackTrace();
 }
 DBUtil.close(connection, null, preparedStatement, null);
 return commentList;
 }

(4)使用Statement操作数据库:

public List getArticleMessage() {
 Connection connection = DBUtil.getConn();
 String sql = "select * from article";// 编写sql语句,第一个字段不需要插入,是自动增加的
 Statement statement = null;
 List articleList = new ArrayList();
 try {
 statement = connection.createStatement();
 ResultSet rs = statement.executeQuery(sql);
 //判断是否为空
 if (rs.next()) {
 while (rs.next()) {//将信息迭代到list中
 Article article = new Article();
 article.setTitle(rs.getString("title"));
 article.setContext(rs.getString("context"));
 article.setArticleTime(rs.getString("articletime"));
 article.setUserid(rs.getInt("userid"));
 article.setArticleid(rs.getInt("articleid"));
 articleList.add(article);
 }
 } else {
 return null;
 }

 } catch (SQLException e) {
 e.printStackTrace();
 }
 DBUtil.close(connection, statement, null, null);
 return articleList;
 }

文档

MySQL的简单操作方法:Statement、PreparedStatement_MySQL

MySQL的简单操作方法:Statement、PreparedStatement_MySQL:(1)连接mysql的工具类:DBUtil.java package com.xuliugen.util; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet;
推荐度:
标签: 操作 方法 使用
  • 热门焦点

最新推荐

猜你喜欢

热门推荐

Top