验证中...
语言: Java
分类: 数据库相关
最后更新于 2018-09-05 00:18
片段 1 片段 2 片段 3
jdbc工具类
原始数据 复制代码
import java.sql.Connection;
import java.sql.DriverManager;
import org.omg.CosNaming.NamingContextExtPackage.StringNameHelper;
import java.sql.Statement;
/**
* @author Amon E-mail:248779716@qq.com
* @version 创建时间:2018年3月17日 上午10:00:08
* 获取数据库连接封装
*/
public class DbUtil {
private static String dbUrl="jdbc:mysql://localhost:3306/stu?useSSL=true";
private static String userName = "root";
private static String passWord = "root";
private static String jdbcName = "com.mysql.jdbc.Driver";
/**
* 获取数据库连接
* @return
* @throws Exception
*/
public Connection getCon() throws Exception{
Class.forName(jdbcName);
System.out.println("DbUtil-----加载驱动成功");
Connection con= DriverManager.getConnection(dbUrl, userName, passWord);
System.out.println("DbUtil-----连接数据库成功!");
return con;
}
/**
* 关闭数据库
* @param con
* @throws Exception
*/
public void closeCon(Statement stmt,Connection con) throws Exception {
if (stmt!=null) {
stmt.close();
if (con!=null) {
con.close();
}
}
}
Student测试类
原始数据 复制代码
package com.Chinasoft.Util;
import java.io.File;
import java.io.FileInputStream;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import com.Chinasoft.Model.Students;
import java.sql.Clob;
/**
* @author Amon E-mail:248779716@qq.com
* @version 创建时间:2018年3月17日 下午2:39:59
* 操作数据库的类(PreparedStatement,常用这个而不用Statement)
*/
public class PreparedStatementExeStu {
static DbUtil dbUtil = new DbUtil();
/**
* 添加学生
*
* @param stu
* @return
* @throws Exception
*/
public static int addStu(Students student) throws Exception {
String sql = "insert into students values (?,?,?,?,?)";
Connection con = dbUtil.getCon();
PreparedStatement prmt = con.prepareStatement(sql);
prmt.setInt(1, student.getId()); // 给第一个坑添加值
prmt.setString(2, student.getName()); // 给第二个坑添加值
prmt.setString(3, student.getSex()); // 给第三个坑添加值
prmt.setInt(4, student.getAge()); // 给第四个坑添加值
File context=student.getContext(); //獲取文件
InputStream inputStream=new FileInputStream(context);
prmt.setAsciiStream(5, inputStream, context.length()); // 给第五个坑添加值
int result = prmt.executeUpdate();
dbUtil.closeCon(prmt, con);
return result;
}
public static void getStu(int id) throws Exception{
Connection con=dbUtil.getCon();
String sql="select * from students where id=?";
PreparedStatement pstmt=con.prepareStatement(sql);
pstmt.setInt(1, id);
ResultSet rs=pstmt.executeQuery();
if (rs.next()) {
String name=rs.getString("name");
String sex=rs.getString("sex");
int age=rs.getInt("age");
Clob c=rs.getClob("context"); //将该 ResultSet对象的当前行中指定列的值作为Java编程语言中的 Clob对象检索。
//c.length()返回的是long类型的对象,
//getSubString()在由Clob对象指定的CLOB值中检索指定子字符串的副本。 子串起始于pos ,最多可length length个字符。
String context=c.getSubString(1, (int)c.length());
System.out.println("名字:"+name+"詳細信息:"+context);
}
dbUtil.closeCon(pstmt, con);
}
/**
* 修改学生信息
*
* @return
* @throws Exception
*/
public static int updateStu() throws Exception {
String sql = "update students set name=?,sex=?,age=? where id=?";
DbUtil dbUtil = new DbUtil();
Connection con = dbUtil.getCon();
PreparedStatement prmt = con.prepareStatement(sql);
prmt.setInt(4, 1789);
prmt.setString(1, "张浩辉");
prmt.setString(2, "男");
prmt.setInt(3, 20);
int result = prmt.executeUpdate();
return result;
}
/**
* 删除学生信息
*
* @return
* @throws Exception
*/
public static int deleteStu() throws Exception {
String sql = "delete from students where id=?";
DbUtil dbUtil = new DbUtil();
Connection con = dbUtil.getCon();
PreparedStatement prmt = con.prepareStatement(sql);
prmt.setInt(1, 1789);
int result = prmt.executeUpdate();
return result;
}
/**
* 查询遍历学生信息
*
* @return
* @throws Exception
*/
public static List<Students> selectStu() throws Exception {
List<Students> stuList=new ArrayList<Students>();
String sql = "select * from students";
DbUtil dbUtil = new DbUtil();
Connection con = dbUtil.getCon();
PreparedStatement prmt = con.prepareStatement(sql);
ResultSet result = prmt.executeQuery();
while (result.next()) {
int id = result.getInt("id");
String name = result.getString("name");
String sex = result.getString("sex");
int age = result.getInt("age");
// Students students=new Students(id, name, sex, age);
// stuList.add(students);
}
return stuList;
}
}
mysql-connector-java-5.1.26-bin.jar

评论列表( 0 )

你可以在登录后,发表评论

搜索帮助

12_float_left_people 12_float_left_close