您的位置:

java操作mysql示例代码(mysql触发java程序)

本文目录一览:

java mysql连接代码

import java.sql.*;

public class CF{

private static final String DRIVER="com.mysql.jdbc.Driver";

private static final String URL="jdbc:mysql:///etoak";

private static final String USER="root";

private static final String PWD="etoak";

static{

try{

Class.forName(DRIVER);

}catch(Exception e){

e.printStackTrace();

}

}

//封装获得连接的方法

public static Connection getConnection()throws Exception{

return DriverManager.getConnection(URL,USER,PWD);

}

//封装关闭的方法

public static void close(ResultSet rs,Statement sta,

Connection con){

try{

if(rs!=null)rs.close();

}catch(Exception e){

e.printStackTrace();

}

try{

if(sta!=null)sta.close();

}catch(Exception e){

e.printStackTrace();

}

try{

if(con!=null)con.close();

}catch(Exception e){

e.printStackTrace();

}

}

}

Java如何连接MySQL数据库进行操作

下面是一个从 mysql 数据库获取用户信息的例子,可以参考一下:

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.ArrayList;

import java.util.List;

// 用户类,存储单个用户信息

class User {

private int id;

private String name;

public User(int id, String name) {

this.id = id;

this.name = name;

}

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;

}

@Override

public String toString() {

return "User [id=" + id + ", name=" + name + "]";

}

}

public class Demo1 {

public static void main(String[] args) throws ClassNotFoundException, SQLException {

// 本例使用 mysql 数据库,演示将数据库 test 的 tb_users 表中的用户信息

// 放到 List 中

// 加载数据驱动

Class.forName("com.mysql.jdbc.Driver");

// 数据库连接字符串, 此例数据库为 test

String url = "jdbc:mysql://localhost:3306/test";

String user = "root"; // 数据库用户名

String password = ""; // 数据库密码

// 打开一个数据连接

Connection conn = DriverManager.getConnection(url, user, password);

Statement stmt = conn.createStatement();

// 获取表 tb_users 所有用户信息到结果集中

ResultSet rs = stmt.executeQuery("SELECT id, name FROM tb_users");

// 定义一个存放用户信息的 List

ListUser users = new ArrayList();

// 提取用户信息,并将用户信息放入 List

while (rs.next()) {

// 获取用户ID

int id = rs.getInt(1);

// 获取用户名

String name = rs.getString(2);

users.add(new User(id, name));

}

rs.close();

stmt.close();

conn.close();

// 显示用户信息

for (User u : users) {

System.out.println(u);

}

}

}

如何在Java程序中访问mysql数据库中的数据并进行简单的操作

一、使用工具:java语言、Myeclipse。

二、操作步骤:

1、第一步:加载MySQL的JDBC的驱动

2、第二步:创建与MySQL数据库的连接类的实例

3、第三步:获取连接类实例con,用con创建Statement对象类实例 sql_statement

4、第四步:执行查询,用ResultSet类的对象,返回查询的结果

5、得出数据

三、注意事项:有几处是需要根据自身情况修改的

1、如下图中的url和账号,密码需要与你自己的相一致。

2、这些需要访问的数据必须要与数据库中的类型相互匹配,才能打印出正确的结果。

java连接mysql数据库

步骤如下,

1. 在开发环境中加载指定数据库的驱动程序。

接下来的实验中,使用数据库MySQL,所以需要下载MySQL支持JDBC的驱动程序(mysql-connector-java-5.1.18-bin.jar)。

2. 开发环境是MyEclipse,将下载得到的驱动程序加载进开发环境中。

3. 在Java程序中加载驱动程序。

在Java程序中,通过 “Class.forName(“指定数据库的驱动程序”)”

方式来加载添加到开发环境中的驱动程序,例如Class.forName(“com.mysql.jdbc.Driver”)。

4. 创建数据连接对象:通过DriverManager类创建数据库连接对象Connection。

DriverManager类作用于Java程序和JDBC驱动程序之间,用于检查所加载的驱动程序是否可以建立连接,然后通过它的getConnection方法,根据数据库的URL、用户名和密码,创建一个JDBC

Connection 对象。代码如:Connection connection = DriverManager.getConnection(“连接数据库的URL", "用户名",

"密码”)。

其中,URL=协议名+IP地址(域名)+端口+数据库名称;用户名和密码是指登录数据库时所使用的用户名和密码。具体示例创建MySQL的数据库连接代码如下:

Connection connectMySQL =

DriverManager.geiConnection(“jdbc:mysql://localhost:3306/myuser","root"

,"root" );

5. 创建Statement对象:Statement 类的主要是用于执行静态 SQL

语句并返回它所生成结果的对象。

通过Connection 对象的 createStatement()方法可以创建一个Statement对象。例如:Statement statament =

connection.createStatement(); 具体示例创建Statement对象代码如下:Statement statamentMySQL =connectMySQL.createStatement();

6. 调用Statement对象的相关方法执行相对应的 SQL

语句:通过execuUpdate()方法用来数据的更新,包括插入和删除等操作,例如向staff表中插入一条数据的代码:

statement.excuteUpdate( "INSERT INTO

staff(name, age, sex,address, depart, worklen,wage)" + " VALUES ('Tom1', 321,

'M', 'china','Personnel','3','3000' ) ") ;

7. 通过调用Statement对象的executeQuery()方法进行数据的查询,而查询结果会得到

ResulSet对象,ResulSet表示执行查询数据库后返回的数据的集合,ResulSet对象具有可以指向当前数据行的指针。通过该对象的next()方法,使得指针指向下一行,然后将数据以列号或者字段名取出。如果当next()方法返回null,则表示下一行中没有数据存在。使用示例代码如下:

ResultSet resultSel =

statement.executeQuery( "select * from staff" );

8. 关闭数据库连接:使用完数据库或者不需要访问数据库时,通过Connection的close() 方法及时关闭数据连接。

如何使用Java与Mysql进行数据交互

使用jdbc驱动  六个步骤

创建链接

加载驱动

获取示例

执行sql语句

获取结果集

关闭连接

代码示例

import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;public class DbDemo {

    public static void main(String[] args) {        // TODO Auto-generated method stub

        ResultSet result = null;

        Connection con = null;

        Statement statement = null;        try {            // 第0步:将mysql 的jdbcjar包加入到引用库中来

            // 第一步:将想要连接的数据库驱动类加载到JVM中来,加载过程中并向DriverManager注册Driver

            // 成功加载后,会将Mysql的驱动Driver类的实例注册到DriverManager类中。

            //使得下面我们获取Connection只需要通过DriverManager就可以了。我不需要通过每个数据库具体的Driver。

            Class.forName("com.mysql.jdbc.Driver").newInstance();            // 第二步,通过DriverManager获取一个和mysql的连接实例con

            String JDBCUrl = "jdbc:mysql://localhost:3306/test?useUnicode=truecharacterEncoding=utf-8";//

            String userName = "root";

            String password = "1557862201";            // 接受一个jdbcurl,username,password;

            con = DriverManager.getConnection(JDBCUrl, userName, password);            // 第三步:通过con连接获取到Statement实例,执行sql语句

            statement = con.createStatement();// statement实例是用于一些不带参数的sql执行,查询,更新,插入,删除操作都可以但是需要构建一个没有占位符的sql字符串

            // 第四步,statement执行sql语句,查询到的结果集到ResultSet实例,简单查询,没有where语句的查询

            result = statement.executeQuery("select * from student");            // 第五步:从结果集中获取数据

            while (result.next()) {                // 根据test库中student表格列名读取数据

                int id = result.getInt("id");

                String name = result.getString("_stuName");

                String number = result.getString("_stuNumber");

                String Grade = result.getString(result.findColumn("_stuGrade"));

                String Address = result.getString(result.findColumn("_stuAddress"));

                System.out

                        .println("name= " + name + " number= " + number + " Grade= " + Grade + " Address= " + Address);

            }            // 插入语句

            // statement.executeUpdate("");

            insert(statement);            // 执行带参数的查询,有where语句的查询

            int id = 2;

            executeQuery(con, id);            // 执行更新操作

            updateDate(con, 2);

            delete(con, "XX");// 删除数据行

        } catch (ClassNotFoundException e) {            // TODO Auto-generated catch block

            System.out.println("找不到驱动程序类 ,加载驱动失败!");

            e.printStackTrace();

        } catch (InstantiationException e) {            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (IllegalAccessException e) {            // TODO Auto-generated catch block

            e.printStackTrace();

        } catch (SQLException ex) {            // TODO Auto-generated catch block

            System.out.println("SQLException: " + ex.getMessage());

            System.out.println("SQLState: " + ex.getSQLState());

            System.out.println("VendorError: " + ex.getErrorCode());

            ex.printStackTrace();

        } finally {            // 第六步:释放资源

            /**

             * 关闭JDBC对象 操作完成以后要把所有使用的JDBC对象全都关闭,以释放JDBC资源,关闭顺序和声 明顺序相反: 1、关闭记录集

             * 2、关闭声明 3、关闭连接对象

             */

            if (result != null) {// 关闭结果集

                try {

                    result.close();

                } catch (SQLException e) {                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                result = null;

            }            if (statement != null) {// 关闭执行sql语句代码块

                try {

                    statement.close();

                } catch (SQLException e) {                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                statement = null;

            }            if (con != null) {// 关闭连接

                try {

                    con.close();

                } catch (SQLException e) {                    // TODO Auto-generated catch block

                    e.printStackTrace();

                }

                con = null;

            }

        }

    }

java连接数据库mysql代码及简单访问数据库

import java.sql.*;

public class DataBasePractice {

public static void main(String[] args) {

//声明Connection对象

Connection con;

//驱动程序名

String driver = "com.mysql.jdbc.Driver";

//URL指向要访问的数据库名mydata

String url = "jdbc:mysql://localhost:3306/mydata";

//MySQL配置时的用户名

String user = "root";

//MySQL配置时的密码

String password = "root";

//遍历查询结果集

try {

//加载驱动程序

Class.forName(driver);

//1.getConnection()方法,连接MySQL数据库!!

con = DriverManager.getConnection(url,user,password);

if(!con.isClosed())

System.out.println("Succeeded connecting to the Database!");

//2.创建statement类对象,用来执行SQL语句!!

Statement statement = con.createStatement();

//要执行的SQL语句

String sql = "select * from student";

//3.ResultSet类,用来存放获取的结果集!!

ResultSet rs = statement.executeQuery(sql);

System.out.println("-----------------");

System.out.println("执行结果如下所示:");

System.out.println("-----------------");

System.out.println(" 学号" + "\t" + " 姓名");

System.out.println("-----------------");

String name = null;

String id = null;

while(rs.next()){

//获取stuname这列数据

name = rs.getString("stuname");

//获取stuid这列数据

id = rs.getString("stuid");

//首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。

//然后使用GB2312字符集解码指定的字节数组。

name = new String(name.getBytes("ISO-8859-1"),"gb2312");

//输出结果

System.out.println(id + "\t" + name);

}

rs.close();

con.close();

} catch(ClassNotFoundException e) {

//数据库驱动类异常处理

System.out.println("Sorry,can`t find the Driver!");

e.printStackTrace();

} catch(SQLException e) {

//数据库连接失败异常处理

e.printStackTrace();

}catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}finally{

System.out.println("数据库数据成功获取!!");

}

}

}

在上面while代码段后面添加以下代码段:

String name = null;

String id = null;

while(rs.next()){

//获取stuname这列数据

name = rs.getString("stuname");

//获取stuid这列数据

id = rs.getString("stuid");

//首先使用ISO-8859-1字符集将name解码为字节序列并将结果存储新的字节数组中。

//然后使用GB2312字符集解码指定的字节数组。

name = new String(name.getBytes("ISO-8859-1"),"gb2312");

//输出结果

System.out.println(id + "\t" + name);

}

PreparedStatement psql;

ResultSet res;

//预处理添加数据,其中有两个参数--“?”

psql = con.prepareStatement("insert into student values(?,?)");

psql.setInt(1, 8); //设置参数1,创建id为5的数据

psql.setString(2, "xiaogang"); //设置参数2,name 为小明

psql.executeUpdate(); //执行更新

//预处理更新(修改)数据

psql = con.prepareStatement("update student set stuname = ? where stuid = ?");

psql.setString(1,"xiaowang"); //设置参数1,将name改为王五

psql.setInt(2,10); //设置参数2,将id为2的数据做修改

psql.executeUpdate();

//预处理删除数据

psql = con.prepareStatement("delete from student where stuid = ?");

psql.setInt(1, 5);

psql.executeUpdate();

//查询修改数据后student表中的数据

psql = con.prepareStatement("select*from student");

res = psql.executeQuery(); //执行预处理sql语句

System.out.println("执行增加、修改、删除后的数据");

while(res.next()){

name = res.getString("stuname");

id = res.getString("stuid");

name = new String(name.getBytes("ISO-8859-1"),"gb2312");

System.out.println(id + "\t" + name);

}

res.close();

psql.close();