JDBC连接数据库的步骤
2013-05-13 14:14
197 查看
1.配置数据库的驱动程序
下载mysql-connector-java
下载地址：http://www.mysql.com/downloads/mirror.php
提取包中的文件 “mysql-connector-java-5.1.17-bin.jar”
现在将下载好的驱动程序放在C盘目录中，所以此时直接修改 CLASSPATH 即可，在windows中的环境变量中直接修改即可，如果没有classpath则自己增加一个新的。
变量名：CLASSPATH
变量值：.;C:\mysql-connector-java-5.1.17-bin.jar
此时数据库驱动程序就安装成功。
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
2.加载驱动程序
[html]
view plaincopy
public class ConnectionDemo01
{
//定义MySQL数据库驱动程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver";
public static void main(String[] args)
{
try{
Class.forName(DBDRIVER);//加载驱动程序
}catch(ClassNotFoundException e){
e.printStackTrace();
}
}
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
3.连接及关闭数据库
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.SQLException ;
public class ConnectionDemo02
{
//定义MySQL数据库驱动程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
//定义MySQ数据库的连接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
//MySQ数据库的连接用户名
public static final String DBUSER = "root" ;
//MySQ数据库的连接密码
public static final String DBPASS = "hslhe" ;
public static void main(String[] args)
{
Connection conn = null ; //数据库连接
try{
Class.forName(DBDRIVER);//加载驱动程序
}catch(ClassNotFoundException e){
e.printStackTrace();
}
try{
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
}catch(SQLException e){
e.printStackTrace();
}
System.out.println(conn) ;//如果此时可以打印表示连接正常
try{
conn.close() ; //数据库关闭
}catch(SQLException e){
e.printStackTrace();
}
}
}
4.执行数据库插入操作
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.Statement ;
public class InsertDemo01
{
//定义MySQL数据库驱动
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
//定义MySQL数据库的连接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
//MySQL数据库的用户名
public static final String DBUSER = "root" ;
//MySQL数据库的密码
public static final String DBPASS = "hslhe" ;
public static void main(String[] args) throws Exception //所有的异常抛出
{
Connection conn = null ; //数据库连接
Statement stmt = null ; //数据库操作
Class.forName(DBDRIVER) ;//加载驱动程序
String name = "李四" ;
String password = "aaaa" ;
int age = 30 ;
String sex = "女" ;
String barthday = "1980-01-22" ;
String sql = "INSERT INTO user(name,password,age,sex,birthday)" +
"VALUES('"+name+"','"+password+"',"+age+",'"+sex+"','"+barthday+"')";
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
stmt = conn.createStatement(); //实例化Statement对象
stmt.executeUpdate(sql); //执行数据更新操作
stmt.close(); //关闭操作
conn.close() ; //数据库关闭
}
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
5.执行数据库更新(修改)操作
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.Statement ;
public class UpdateDemo{
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;//定义MySQL数据库驱动
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;//定义MySQL数据库的连接地址
public static final String DBUSER = "root" ;//MySQL数据库的用户名
public static final String DBPASS = "hslhe" ;//MySQL数据库的密码
public static void main(String[] args) throws Exception{ //所有的异常抛出
Connection conn = null ; //数据库连接
Statement stmt = null ; //数据库操作
Class.forName(DBDRIVER) ;//加载驱动程序
int id = 5 ;
String name = "王五" ;
String password = "bbbb" ;
int age = 33 ;
String sex = "男" ;
String birthday = "1985-11-12" ;
String sql = "UPDATE user SET name ='"+name+"',password = '"
+ password+"' , age =" + age + " , sex = '"+sex+"' , birthday = '"
+ birthday+"' where id =" + id ;
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
stmt = conn.createStatement(); //实例化Statement对象
stmt.executeUpdate(sql); //执行数据更新操作
stmt.close(); //关闭操作
conn.close() ; //数据库关闭
}
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
6.执行数据库删除记录(修改)操作
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.Statement ;
public class DeleteDemo{
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;//定义MySQL数据库驱动
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;//定义MySQL数据库的连接地址
public static final String DBUSER = "root" ;//MySQL数据库的用户名
public static final String DBPASS = "hslhe" ;//MySQL数据库的密码
public static void main(String[] args) throws Exception{//所有的异常抛出
Connection conn = null ;//数据库连接
Statement stmt = null ;//数据库操作
Class.forName(DBDRIVER) ;//加载驱动程序
int id = 3 ;
String sql = "DELETE FROM user where id =" + id ;
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
stmt = conn.createStatement();//实例化Statement对象
stmt.executeUpdate(sql);//执行数据更新操作
stmt.close();//关闭操作
conn.close() ;//数据库关闭
}
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
7.使用 ResultSet 接口 接收并显示内容
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.Statement ;
import java.sql.ResultSet ;
public class ResultSetDemo01{
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;//定义MySQL数据库驱动
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;//定义MySQL数据库的连接地址
public static final String DBUSER = "root" ;//MySQL数据库的用户名
public static final String DBPASS = "hslhe" ;//MySQL数据库的密码
public static void main(String[] args) throws Exception{//所有的异常抛出
Connection conn = null ;//数据库连接
Statement stmt = null ;//数据库的操作对象
ResultSet rs = null ;//保存查询结果
String sql ="SELECT id,name,password,age,sex,birthday FROM user" ;
Class.forName(DBDRIVER) ;//加载驱动程序
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
stmt = conn.createStatement() ;
rs = stmt.executeQuery(sql) ;
while(rs.next()){
int id = rs.getInt(1) ;//取出id列的内容
String name = rs.getString(2); //取出name列的内容
String password = rs.getString(3); //取出password列的内容
int age = rs.getInt(4); //取出age列的内容
String sex = rs.getString(5); //取出sex列的内容
java.util.Date d = rs.getDate(6); //取出birthday列的内容
System.out.print("编号：" + id + "; ") ;
System.out.print("姓名：" + name + "; ") ;
System.out.print("密码：" + password + "; ") ;
System.out.print("年龄：" + age + "; ") ;
System.out.print("性别：" + sex + "; ") ;
System.out.println("生日：" + d + "; ") ;
System.out.println("------------------------------------------------------------") ;
}
conn.close() ;//数据库关闭
}
}
下载mysql-connector-java
下载地址：http://www.mysql.com/downloads/mirror.php
提取包中的文件 “mysql-connector-java-5.1.17-bin.jar”
现在将下载好的驱动程序放在C盘目录中，所以此时直接修改 CLASSPATH 即可，在windows中的环境变量中直接修改即可，如果没有classpath则自己增加一个新的。
变量名：CLASSPATH
变量值：.;C:\mysql-connector-java-5.1.17-bin.jar
此时数据库驱动程序就安装成功。
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
2.加载驱动程序
[html]
view plaincopy
public class ConnectionDemo01
{
//定义MySQL数据库驱动程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver";
public static void main(String[] args)
{
try{
Class.forName(DBDRIVER);//加载驱动程序
}catch(ClassNotFoundException e){
e.printStackTrace();
}
}
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
3.连接及关闭数据库
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.SQLException ;
public class ConnectionDemo02
{
//定义MySQL数据库驱动程序
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
//定义MySQ数据库的连接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
//MySQ数据库的连接用户名
public static final String DBUSER = "root" ;
//MySQ数据库的连接密码
public static final String DBPASS = "hslhe" ;
public static void main(String[] args)
{
Connection conn = null ; //数据库连接
try{
Class.forName(DBDRIVER);//加载驱动程序
}catch(ClassNotFoundException e){
e.printStackTrace();
}
try{
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
}catch(SQLException e){
e.printStackTrace();
}
System.out.println(conn) ;//如果此时可以打印表示连接正常
try{
conn.close() ; //数据库关闭
}catch(SQLException e){
e.printStackTrace();
}
}
}
4.执行数据库插入操作
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.Statement ;
public class InsertDemo01
{
//定义MySQL数据库驱动
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;
//定义MySQL数据库的连接地址
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;
//MySQL数据库的用户名
public static final String DBUSER = "root" ;
//MySQL数据库的密码
public static final String DBPASS = "hslhe" ;
public static void main(String[] args) throws Exception //所有的异常抛出
{
Connection conn = null ; //数据库连接
Statement stmt = null ; //数据库操作
Class.forName(DBDRIVER) ;//加载驱动程序
String name = "李四" ;
String password = "aaaa" ;
int age = 30 ;
String sex = "女" ;
String barthday = "1980-01-22" ;
String sql = "INSERT INTO user(name,password,age,sex,birthday)" +
"VALUES('"+name+"','"+password+"',"+age+",'"+sex+"','"+barthday+"')";
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
stmt = conn.createStatement(); //实例化Statement对象
stmt.executeUpdate(sql); //执行数据更新操作
stmt.close(); //关闭操作
conn.close() ; //数据库关闭
}
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
5.执行数据库更新(修改)操作
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.Statement ;
public class UpdateDemo{
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;//定义MySQL数据库驱动
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;//定义MySQL数据库的连接地址
public static final String DBUSER = "root" ;//MySQL数据库的用户名
public static final String DBPASS = "hslhe" ;//MySQL数据库的密码
public static void main(String[] args) throws Exception{ //所有的异常抛出
Connection conn = null ; //数据库连接
Statement stmt = null ; //数据库操作
Class.forName(DBDRIVER) ;//加载驱动程序
int id = 5 ;
String name = "王五" ;
String password = "bbbb" ;
int age = 33 ;
String sex = "男" ;
String birthday = "1985-11-12" ;
String sql = "UPDATE user SET name ='"+name+"',password = '"
+ password+"' , age =" + age + " , sex = '"+sex+"' , birthday = '"
+ birthday+"' where id =" + id ;
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
stmt = conn.createStatement(); //实例化Statement对象
stmt.executeUpdate(sql); //执行数据更新操作
stmt.close(); //关闭操作
conn.close() ; //数据库关闭
}
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
6.执行数据库删除记录(修改)操作
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.Statement ;
public class DeleteDemo{
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;//定义MySQL数据库驱动
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;//定义MySQL数据库的连接地址
public static final String DBUSER = "root" ;//MySQL数据库的用户名
public static final String DBPASS = "hslhe" ;//MySQL数据库的密码
public static void main(String[] args) throws Exception{//所有的异常抛出
Connection conn = null ;//数据库连接
Statement stmt = null ;//数据库操作
Class.forName(DBDRIVER) ;//加载驱动程序
int id = 3 ;
String sql = "DELETE FROM user where id =" + id ;
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
stmt = conn.createStatement();//实例化Statement对象
stmt.executeUpdate(sql);//执行数据更新操作
stmt.close();//关闭操作
conn.close() ;//数据库关闭
}
}
－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－－
7.使用 ResultSet 接口 接收并显示内容
[java]
view plaincopy
import java.sql.Connection ;
import java.sql.DriverManager ;
import java.sql.Statement ;
import java.sql.ResultSet ;
public class ResultSetDemo01{
public static final String DBDRIVER = "org.gjt.mm.mysql.Driver" ;//定义MySQL数据库驱动
public static final String DBURL = "jdbc:mysql://localhost:3306/mldn" ;//定义MySQL数据库的连接地址
public static final String DBUSER = "root" ;//MySQL数据库的用户名
public static final String DBPASS = "hslhe" ;//MySQL数据库的密码
public static void main(String[] args) throws Exception{//所有的异常抛出
Connection conn = null ;//数据库连接
Statement stmt = null ;//数据库的操作对象
ResultSet rs = null ;//保存查询结果
String sql ="SELECT id,name,password,age,sex,birthday FROM user" ;
Class.forName(DBDRIVER) ;//加载驱动程序
conn = DriverManager.getConnection(DBURL,DBUSER,DBPASS) ;
stmt = conn.createStatement() ;
rs = stmt.executeQuery(sql) ;
while(rs.next()){
int id = rs.getInt(1) ;//取出id列的内容
String name = rs.getString(2); //取出name列的内容
String password = rs.getString(3); //取出password列的内容
int age = rs.getInt(4); //取出age列的内容
String sex = rs.getString(5); //取出sex列的内容
java.util.Date d = rs.getDate(6); //取出birthday列的内容
System.out.print("编号：" + id + "; ") ;
System.out.print("姓名：" + name + "; ") ;
System.out.print("密码：" + password + "; ") ;
System.out.print("年龄：" + age + "; ") ;
System.out.print("性别：" + sex + "; ") ;
System.out.println("生日：" + d + "; ") ;
System.out.println("------------------------------------------------------------") ;
}
conn.close() ;//数据库关闭
}
}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- 完整java开发中JDBC连接数据库代码和步骤
- java开发中JDBC连接数据库代码和步骤
- 完整java开发中JDBC连接数据库代码和步骤
- 完整java开发中JDBC连接数据库代码和步骤
- Java 直接用jdbc连接数据库 sql2000 的步骤和验证代码
- 完整java开发中JDBC连接数据库代码和步骤
- java开发中JDBC连接数据库代码和步骤
- 完整java开发中JDBC连接数据库代码和步骤
- java开发中JDBC连接数据库代码和步骤
- JDBC连接数据库的原理和步骤
- jdbc连接数据库的7大步骤（以通过jdbc连接实现数据的插入、更新为例）
- JDBC 连接数据库开发步骤
- JAVA JDBC连接数据库的步骤
- JDBC连接数据库步骤
- 完整java开发中JDBC连接数据库代码和步骤
- JDBC连接数据库代码和步骤
- 【转】Java开发中JDBC连接数据库代码和步骤总结
- 完整java开发中JDBC连接数据库代码和步骤[转]
- 完整java开发中JDBC连接数据库代码和步骤
- java开发中JDBC连接数据库代码和步骤 转