1. 程式人生 > >Java鏈接Mysql傳輸數據

Java鏈接Mysql傳輸數據

else try creates incr 鏈接 成功 刪除數據庫 數據庫操作 auto

MySQL部分

1.先建立mysql數據庫數據表

技術分享圖片

① 運行-mysql –u root –p 輸入密碼(安裝mysql時設置)打開mysql

② 創建數據庫 create database 數據庫名稱;

技術分享圖片

show databases ; 查看數據庫

drop database 數據庫名稱 ; 刪除數據庫

③ 選擇數據庫 use 數據庫名稱;

技術分享圖片

④ 創建數據表

create table 表名稱

(

字段名稱1 數據類型 約束條件,

字段名稱2 數據類型 約束條件,

... ...

字段名稱n 數據類型 約束條件

);

Mysql數據類型

  字符:char(字符數據大小個數) 不可變字符 / varchar(數據大小) 可變字符 /text

  數字:float/double(7,2) int

  日期:date / time / datetime / timestamp

Mysql 約束條件

  主鍵約束:primary key -- 標識所有記錄唯一性的標誌,所對應數據 不能為空,且不能重復

  非空約束:not null -- 該字段信息必須填寫,不能使用null進行填充

  唯一約束:unique -- 該字段信息不能有重新信息

  外鍵約束:foreign key -- 在從表中引用主表中數據信息

  檢查約束:check -- 檢查當前輸入輸入有效性

  默認值: default -- 用戶沒有填加數據時,采用默認值進行填充

Eg:

create table userInfo

(

      id int primary key auto_increment,  #編號,整形,主鍵,自動增長

      username varchar(20) unique ,        #唯一性          

      password varchar(20) not null ,       #非空

      sex char(1) default
, #默認值 age int , birth date null #允許為空 );

技術分享圖片

⑤ 查看當前數據庫存在表 show tables;

⑥ 查看表結構信息 desc 表名稱;

技術分享圖片

⑦ 刪除數據表 drop table 表名稱;

⑧ 添加數據

inset into 表名稱(字段名稱1,字段名稱2,…..) values(數值1,數值2,…..);

insert into userinfo(username,password,sex,age,birth) values(‘張三‘,‘111‘,‘男‘,22,‘2000-1-1‘) ;

技術分享圖片

⑨ 查看數據

select 字段名稱1,字段名稱2,…..from 表名稱;

select id,username,password,sex,age,birth from userinfo ;

技術分享圖片

⑩ 刪除數據

delete from 表名 where 條件 數據;

delete from userinfo where id=1;

JAVA 部分

2.編寫java文件

主要步驟:

// 1添加驅動

// 2鏈接數據庫

// 3操作數據

// 4關閉鏈接

① 添加驅動:導入 mysql-connector-java-bin.jar 文件,右鍵 build path 引用外部jar包

try {

            // class.forname 獲得class類對象

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

        } catch (ClassNotFoundException e) {

               // TODO Auto-generated catch block

                     e.printStackTrace();

                     System.out.println("數據庫驅動加載失敗...");

        }

② 連接數據庫:

try {

                     //DirverManager.getConnection();連接數據庫

                     conn = DriverManager.getConnection(url,user,pwd);

              } catch (SQLException e) {

                     // TODO Auto-generated catch block

                     e.printStackTrace();

                     System.out.println("數據庫連接失敗");

              }

③ 操作數據庫

//添加操作

              //String sql = "insert into userinfo(username,password,sex,age,birth) values(‘zere‘,‘666‘,‘女‘,24,‘1994-4-17‘)";

              //刪除操作

              String sql = "delete from userinfo where id=1";

try {

                     //statement 方法創建用於執行SQL語句並返回它所生成結果的對象,用connection的方法createstatement創建

                     sta = conn.createStatement();

                     //statement 接口中有executeUpdate(String sql);方法發送sql語句並返回執行成功的記錄的條數

                     int num = sta.executeUpdate(sql);

                     if(num >0){

                            System.out.println("數據庫操作成功");

                     }else{

                            System.out.println("數據庫操作失敗1");

                     }

              } catch (SQLException e) {

                     // TODO Auto-generated catch block

                     e.printStackTrace();

                     System.out.println("數據庫操作失敗2");

              }      

④ 關閉數據庫操作對象

try {

                     sta.close();

                     conn.close();

              } catch (SQLException e) {

                     // TODO Auto-generated catch block

                     e.printStackTrace();

              }

⑤ 運行數據庫連接方法

public static void main(String[] args){

             

              MysqlLink link = new MysqlLink();

              link.init();

       }

整合代碼:

package com.cz.link;

 

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;

 

public class MysqlLink {     

       /*鏈接步驟

         1.添加驅動

         2.連接數據庫

         3.操作數據

         4.關閉鏈接

       */

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

       String user = "root";

       String pwd = "123456";

       //聲明鏈接對象

       Connection conn = null;

       String sql = null;

       public Statement sta = null;

      

       public void init(){

              //1.加載驅動

             

              try {

                     // class.forname 獲得class類對象

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

              } catch (ClassNotFoundException e) {

                     // TODO Auto-generated catch block

                     e.printStackTrace();

                     System.out.println("數據庫驅動加載失敗...");

              }

                    

              //2.連接數據庫

             

              try {

                     //DirverManager.getConnection();連接數據庫

                     conn = DriverManager.getConnection(url,user,pwd);

              } catch (SQLException e) {

                     // TODO Auto-generated catch block

                     e.printStackTrace();

                     System.out.println("數據庫連接失敗");

              }

             

              //3.數據操作

              //添加操作

              //String sql = "insert into userinfo(username,password,sex,age,birth) values(‘zere‘,‘666‘,‘女‘,24,‘1994-4-17‘)";

              //刪除操作

              String sql = "delete from userinfo where id=1";

try {

                     //statement 方法創建用於執行SQL語句並返回它所生成結果的對象,用connection的方法createstatement創建

                     sta = conn.createStatement();

                     //statement 接口中有executeUpdate(String sql);方法發送sql並返回執行成功的記錄的條數

                     int num = sta.executeUpdate(sql);

                     if(num >0){

                            System.out.println("數據庫操作成功");

                     }else{

                            System.out.println("數據庫操作失敗1");

                     }

              } catch (SQLException e) {

                     // TODO Auto-generated catch block

                     e.printStackTrace();

                     System.out.println("數據庫操作失敗2");

              }

             

              //4.關閉數據庫操作對象

              try {

                     sta.close();

                     conn.close();

              } catch (SQLException e) {

                     // TODO Auto-generated catch block

                     e.printStackTrace();

              }

       }

      

       public static void main(String[] args){

             

              MysqlLink link = new MysqlLink();

              link.init();

       }

}

Java鏈接Mysql傳輸數據