PreparedStatement语句插入数据

标签： jdbcselect对象数据

2016-10-13 22:22 3864人阅读评论(0) 收藏举报

分类：

JDBC 学习笔记（8）

代码：

1.直接调用插入：

DButil.java

[java] view plaincopy

import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.Properties;
import com.mysql.jdbc.Connection;
public class DButil {
/*
* 打开数据库
*/
private static String driver;//连接数据库的驱动
private static String url;
private static String username;
private static String password;
static {
driver="com.mysql.jdbc.Driver";//需要的数据库驱动
url="jdbc:mysql://localhost:3306/test";//数据库名路径
username="root";
password="root";
}
public static Connection open()
{
try {
Class.forName(driver);
return (Connection) DriverManager.getConnection(url,username, password);
} catch (Exception e) {
System.out.println("数据库连接失败！");
// TODO Auto-generated catch block
e.printStackTrace();
}//加载驱动
return null;
}
/*
* 关闭数据库
*/
public static void close(Connection conn)
{
if(conn!=null)
{
try {
conn.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}

jdbcconnection.java

[java] view plaincopy

import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.PreparedStatement;
public class jdbcconnection {
public static void main(String[] args) {
// TODO Auto-generated method stub
insert("yangxu","yangxu@qq.com");
}
static void insert(String name,String email)
{
String sql="insert into Haige(name,email) value(?,?)";
Connection conn=DButil.open();
try {
PreparedStatement pstmt=(PreparedStatement) conn.prepareStatement(sql);
pstmt.setString(1,name);
pstmt.setString(2,email);
pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally {
DButil.close(conn);
}
}
}

2.面向对象的方式

Customer.java

[java] view plaincopy

public class Customer {
int id;
String name;
String email;
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
}

jdbcconnection.java(插入数据)

[java] view plaincopy

import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.PreparedStatement;
public class jdbcconnection {
public static void main(String[] args) {
// TODO Auto-generated method stub
//insert("yangxu","yangxu@qq.com");
Customer c=new Customer();
c.setName("zhangbing");
c.setEmail("zhangbing@qq.com");
insert(c);
}
static void insert(Customer c)
{
String sql="insert into Haige(name,email) value(?,?)";
Connection conn=DButil.open();
try {
PreparedStatement pstmt=(PreparedStatement) conn.prepareStatement(sql);
pstmt.setString(1,c.getName());
pstmt.setString(2,c.getEmail());
pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally {
DButil.close(conn);
}
}
}

jdbcconnection.java(修改数据)

[java] view plaincopy

import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.PreparedStatement;
public class jdbcconnection {
public static void main(String[] args) {
// TODO Auto-generated method stub
//insert("yangxu","yangxu@qq.com");
Customer c=new Customer();
// c.setName("zhangbing");
// c.setEmail("zhangbing@qq.com");
//insert(c);
c.setId(1001);
c.setName("kaixin");
Update(c);
}
static void Update(Customer c)
{
String sql="update haige set name=? where id=?";
Connection conn=DButil.open();
try {
PreparedStatement pstmt=(PreparedStatement) conn.prepareStatement(sql);
pstmt.setString(1,c.getName());
pstmt.setInt(2,c.getId());;
pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally {
DButil.close(conn);
}
}
}

jdbcconnection.java(删除数据)

[java] view plaincopy

import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.PreparedStatement;
public class jdbcconnection {
public static void main(String[] args) {
// TODO Auto-generated method stub
//insert("yangxu","yangxu@qq.com");
// Customer c=new Customer();
c.setName("zhangbing");
c.setEmail("zhangbing@qq.com");
// //insert(c);
// c.setId(1001);
// c.setName("kaixin");
// Update(c);
delete(1006);
}
static void delete(int id)
{
String sql="delete from haige where id=?";
Connection conn=DButil.open();
try {
PreparedStatement pstmt=(PreparedStatement) conn.prepareStatement(sql);
pstmt.setInt(1,id);;
pstmt.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally {
DButil.close(conn);
}
}
}

jdbcconnection.java(查询数据)

[java] view plaincopy

import java.sql.ResultSet;
import java.sql.SQLException;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.PreparedStatement;
public class jdbcconnection {
public static void main(String[] args) {
// TODO Auto-generated method stub
//insert("yangxu","yangxu@qq.com");
// Customer c=new Customer();
c.setName("zhangbing");
c.setEmail("zhangbing@qq.com");
// //insert(c);
// c.setId(1001);
// c.setName("kaixin");
// Update(c);
//delete(1006);
Customer c=query(1005);
System.out.println(c.getId()+","+c.getName()+","+c.getEmail());
}
static Customer query(int id)
{
String sql="select * from haige where id=?";
Connection conn=DButil.open();
try {
PreparedStatement pstmt=(PreparedStatement) conn.prepareStatement(sql);
pstmt.setInt(1,id);
ResultSet rs=pstmt.executeQuery();
if(rs.next())
{
String name=rs.getString(2);
String email=rs.getString(3);
Customer c=new Customer();
c.setId(id);
c.setName(name);
c.setEmail(email);
return c;
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally {
DButil.close(conn);
}
return null;
}
}

java 向DB2插入数据相关推荐

java向mysql插入数据乱码问题解决
java向mysql插入数据乱码问题解决参考文章: (1)java向mysql插入数据乱码问题解决 (2)https://www.cnblogs.com/jack204/archive/2012/0 ...
java向数据库插入数据时的错误： Duplicate entry ‘‘ for key ‘PRIMARY‘ 问题解决
java向数据库插入数据时的错误: Duplicate entry '' for key 'PRIMARY' 问题解决参考文章: (1)java向数据库插入数据时的错误: Duplicate ent ...
Java JDBC批处理插入数据操作
在此笔记里,我们将看到我们如何可以使用像Statement和PreparedStatement JDBC API来批量在任何数据库中插入数据.此外,我们将努力探索一些场景,如在内存不足时正常运行,以及 ...
Db2插入数据溢出报错测试
本文是测试Db2数据库插入数据报错.具体来讲,是通过命令行.JDBC.Mybatis等各种方式,尝试把一个长度为11的字符串插入到 VARCHAR(8) 的字段,查看报错信息,方便以后遇到类似的错误时 ...
java处理word插入数据转PDF及下载PDF
欢迎使用Markdown编辑器提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档文章目录前言一.引入jar包二.使用步骤 1.前端上传电子签名图片 2.java下载电子签名图片 ...
java实现批量插入数据
//业务背景:在实现一次性插入上万条数据会报错误,所有要批量插入数据 public void addCouponCode(List<CouponCodeEntity> lists){if ...
解决Java向mysql插入数据时的乱码和时区问题
解决乱码和时区问题需要在jdbc的链接url上添加参数 jdbc:mysql://mysql-server:3306/dbname?useSSL=false&useUnicode=true&a ...
java mongodb 插入数据_mongoDB 插入数据用java实现
import java.net.UnknownHostException; import com.mongodb.BasicDBObject; import com.mongodb.DB; impor ...
java mongodb 模糊查询_Java操作MongoDB插入数据进行模糊查询与in查询功能的方法
Java操作MongoDB插入数据进行模糊查询与in查询功能由于需要用MongoDB缓存数据,所以自己写了一套公共的存放和读取方法具体如下: 存放mongodb: /** * 公共方法:设置Obj ...
java mysql 插入乱码_java向mysql插入数据乱码问题的解决方法
遇到java向mysql插入数据乱码问题,如何解决? MySQL默认编码是latin1 mysql> show variables like 'character%'; +----------- ...

java 向DB2插入数据

PreparedStatement语句插入数据

java 向DB2插入数据相关推荐

最新文章

热门文章