一、需求
使用JDBC补充增加、修改新闻标题以及删除信息的功能
示例代码:
package cn.kgc.dao;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.Date;
// 使用PreparedStatement
public class NewsDao {
Connection connection = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
// 获取数据库连接的方法
public void getConnection(){
try {
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://127.0.0.1:3306/kgcnews";
connection = DriverManager.getConnection(url, "root", "41312019");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
// 关闭资源的方法
public void close(){
try {
connection.close();
pstmt.close();
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
// 增加新闻信息
public void addNews(int id,int categoryId,String title,String summary,String content,String author,Date createDate){
String sql = "INSERT INTO news_detail(id, categoryId, title, " +
"summary,content,author, createDate) VALUES(?,?,?,?,?,?,?);";
try {
this.getConnection();
pstmt = connection.prepareStatement(sql);
pstmt.setInt(1, id);
pstmt.setInt(2, categoryId);
pstmt.setString(3, title);
pstmt.setString(4, summary);
pstmt.setString(5, content);
pstmt.setString(6, author);
pstmt.setTimestamp(7,new Timestamp(createDate.getTime()));
int i = pstmt.executeUpdate();
if (i > 0){
System.out.println("插入新闻信息成功");
}
}catch (SQLException e) {
e.printStackTrace();
} finally {
this.close();
}
}
// 删除特定新闻
public void deleteNews(int id){
String sql = "DELETE FROM news_detail WHERE id=?";
try {
this.getConnection();
System.out.println(sql);
pstmt = connection.prepareStatement(sql);
pstmt.setInt(1, id);
int i = pstmt.executeUpdate();
if (i > 0){
System.out.println("删除新闻信息成功");
}
}catch (SQLException e) {
e.printStackTrace();
} finally {
this.close();
}
}
// 修改特定新闻的标题
public void updateNews(int id, String title){
String sql = "UPDATE news_detail SET title=? WHERE id=?";
try {
this.getConnection();
pstmt = connection.prepareStatement(sql);
pstmt.setString(1, title);
pstmt.setInt(2, id);
int i = pstmt.executeUpdate();
if (i > 0){
System.out.println("修改新闻信息成功");
}
}catch (SQLException e) {
e.printStackTrace();
} finally {
this.close();
}
}
// 查询全部新闻信息
public void getAllNews(){
this.getConnection();
String sql = "SELECT id, title, author,createDate FROM news_detail";
try {
pstmt = connection.prepareStatement(sql);
rs = pstmt.executeQuery();
while(rs.next()){
int id = rs.getInt("id");
String newsTitle = rs.getString("title");
String author = rs.getString("author");
Timestamp createdate = rs.getTimestamp("createDate");
System.out.println(id + " " + newsTitle + " " + author + " " + createdate);
}
} catch (SQLException e) {
e.printStackTrace();
} finally {
this.close();
}
}
// 查询特定的新闻id、标题
public void getNewsByTitle(String title){
try {
this.getConnection();
String sql = "SELECT id, title FROM news_detail where title=?";
pstmt = connection.prepareStatement(sql);
pstmt.setString(1, title);
rs = pstmt.executeQuery();
while(rs.next()){
int id = rs.getInt("id");
String newsTitle = rs.getString("title");
System.out.println(id + " " + newsTitle);
}
}catch (SQLException e) {
e.printStackTrace();
} finally {
this.close();
}
}
public static void main(String[] args) {
NewsDao dao = new NewsDao();
dao.getNewsByTitle("Java Web开课啦");
// dao.addNews(3, 2, "美国爆炸了", "塔利班对此负责", "我有一句mmp", "tom", new Date());
dao.updateNews(3, "newTitle");
dao.deleteNews(3);
dao.getAllNews();
}
}
注:
1、在增加新闻信息的时候,valuse后面的括号中的?都是不要单引号的。
2、设置时间用的是时间戳。
3、增删改的时候都是executeUpdate方法(返回值是受影响的行数),查询的时候用的是executeQuery方法。
4、关闭资源的方法不推荐单独拿出来做一个方法,因为不同的操作用到的资源不一样,所以有差别,如果不管什么都关的话可能会报错。可以把连接和PreparedStatement单独拿出来,增删改没有结果集就不要把这个拿出来。
二、中文乱码问题
在java程序中插入数据的时候,如果插入的是中文,则在数据库中无法显示,解决方法如下:
首先通过jdbc连接数据库后插入数据时,你应该保证以下三处的编码方式相同(推荐utf-8编码方式):
1:eclipse文件保存的编码方式
2:数据库的编码方式
3:jdbc连接的编码方式
前两点是一般都能想到的,但是第三点忽略则很容易导致数据中文乱码情况,第三条的解决方案就是将获取数据库连接改为:
String url="jdbc:mysql://localhost:3306/数据库名?characterEncoding=utf-8
我们再运行程序,发现中文就显示正常了
修改连接的方法如下:
// 获取数据库连接的方法
public void getConnection(){
try {
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://127.0.0.1:3306/kgcnews?characterEncoding=utf-8";
connection = DriverManager.getConnection(url, "root", "41312019");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
}
}
这样再查询正文标题以及插入中文数据的时候就正常了。