第3关：博客系统之创建博客 - IT评测·应用市场-qidao123.com技术社区

package com.menu;
import com.dao.BlogDao;
import com.dao.BlogTypeDao;
import com.dao.UserDao;
import com.pojo.Blog;
import com.pojo.BlogType;
import com.pojo.User;
import java.util.Scanner;
public class Menu {
public static void main(String[] args) {
UserDao userDao = new UserDao();
boolean flag = true;
User user;
Blog blog;
BlogDao blogDao = new BlogDao();
BlogTypeDao blogTypeDao = new BlogTypeDao();
Scanner sc = new Scanner(System.in);
do {
System.out.println("**********欢迎进入博客系统**********");
System.out.println("**********1. 登录**********");
System.out.println("**********2. 注册**********");
System.out.println("**********3. 退出系统**********");
System.out.println("请输入你要进行的操作：");
int x = sc.nextInt();
String userName;
String passWord;
String phone;
switch (x) {
case 1:
// 获取键盘输入的用户信息
System.out.println("请输入你的用户名");
userName = sc.next();
System.out.println("请输入你的密码");
passWord = sc.next();
user = userDao.login(userName,passWord);
if (user != null) {
boolean flag1 = true;
do{
System.out.println("1. 创建博客");
System.out.println("2. 查看博客");
System.out.println("3. 删除博客");
System.out.println("4. 修改博客");
System.out.println("5. 返回上一级菜单");
System.out.println("请输入你要进行的操作：");
int y = sc.nextInt();
String blogTitle;
String blogContent;
String typeName;
switch (y){
// 请在下面的Begin-End之间按照注释中给出的提示编写正确的代码
/********** Begin **********/
case 1:
// 获取键盘输入的用户信息
System.out.println("请输入你要创建的博客标题");
blogTitle = sc.next();
System.out.println("请输入你要创建的博客内容");
blogContent = sc.next();
System.out.println("请输入你的博客类型");
typeName = sc.next();
// 查询博客类型是否存在
BlogType blogType = blogTypeDao.findBlogType(typeName);
if (blogType != null){
// 将博客信息放入博客对象中
blog = new Blog();
blog.setBlogTitle(blogTitle);
blog.setBlogContent(blogContent);
blog.setUser(user);
blog.setBlogType(blogType);
// 验证博客是否创建成功
boolean b = blogDao.addBlog(blog);
if (b){
System.out.println("博客创建成功！");
}else{
System.out.println("博客创建失败！");
}
}else {
System.out.println("博客类型不存在！");
}
break;
/********** End **********/
case 5:
flag1 = false;
break;
default:
System.out.println("你的输入有误，请重新输入！");
break;
}
}while (flag1);
}else{
System.out.println("用户名或密码不正确！");
}
break;
case 2:
user = new User();
// 获取键盘输入的用户信息
System.out.println("请输入你要注册的用户名");
userName = sc.next();
System.out.println("请输入你要注册的密码");
passWord = sc.next();
System.out.println("请输入你要注册的手机号");
phone = sc.next();
// 将用户信息存入用户对象中
user.setUserName(userName);
user.setPassWord(passWord);
user.setPhone(phone);
// 调用 register 方法，将用户信息传入其中，判断注册是否成功
boolean result = userDao.register(user);
if (result) {
System.out.println("注册成功！");
}else{
System.out.println("注册失败！");
}
break;
case 3:
// 设置状态为 false，退出系统
flag = false;
System.out.println("退出系统！");
break;
default:
System.out.println("你的输入有误，请重新输入！");
break;
}
} while (flag);
}
}

复制代码

package com.dao;
import com.pojo.BlogType;
import com.util.DBConnection;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class BlogTypeDao {
static Connection conn = null; // 连接对象
static PreparedStatement ps = null; // 预编译
static ResultSet rs = null; // 结果集
/**
* 功能查找博客类型是否存在
* 参数 blogType
* 返回值博客类型对象
*/
public BlogType findBlogType(String typeName) {
// 请在下面的Begin-End之间按照注释中给出的提示编写正确的代码
/********** Begin **********/
BlogType blogType = new BlogType();
// 判断博客类型是否存在
try {
conn = DBConnection.getConnection();
String sql = "select * from blog_type where typeName = ?";
ps = conn.prepareStatement(sql);
ps.setString(1, typeName);
rs = ps.executeQuery();
// 如果存在，返回该博客类型对象信息
if (rs.next()){
blogType.setTypeId(rs.getInt("typeId"));
blogType.setTypeName(rs.getString("typeName"));
return blogType;
}
} catch (SQLException e) {
e.printStackTrace();
}
// 不存在则返回 null
return null;
/********** End **********/
}
}

复制代码

package com.dao;
import com.pojo.Blog;
import com.pojo.BlogType;
import com.util.DBConnection;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class BlogDao {
static Connection conn = null; // 连接对象
static PreparedStatement ps = null; // 预编译
static ResultSet rs = null; // 结果集
public boolean addBlog(Blog blog) {
// 请在下面的Begin-End之间按照注释中给出的提示编写正确的代码
/********** Begin **********/
boolean result = false;
// 插入博客数据到博客表中
try {
conn = DBConnection.getConnection();
String sql = "insert into t_blog (blogTitle,blogContent,userId,typeId) values (?,?,?,?)";
ps = conn.prepareStatement(sql);
ps.setString(1, blog.getBlogTitle());
ps.setString(2, blog.getBlogContent());
ps.setInt(3, blog.getUser().getUserId());
ps.setInt(4, blog.getBlogType().getTypeId());
int i = ps.executeUpdate();
// 判断是否添加成功
if (i == 1) {
result = true;
}
} catch (SQLException e) {
e.printStackTrace();
}
return result;
}
/********** End **********/
}

复制代码