sqlserver jdbc增删改查-编程学习网

短信预约信息系统项目管理师报名、考试、查分时间动态提醒

sqlserver jdbc增删改查

随便个springboot的maven项目都可以。

pom.xml 配置



    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.2.5.RELEASE
         
    
    com.example
    demo
    0.0.1-SNAPSHOT
    demo
    Demo project for Spring Boot

    
        1.8
    

    


        
            org.springframework.boot
            spring-boot-starter
        


        
            org.springframework.boot
            spring-boot-starter-test
            test
            
                
                    org.junit.vintage
                    junit-vintage-engine
                
            
        
        
            org.springframework.boot
            spring-boot-starter-web
        

        
            com.microsoft.sqlserver
            sqljdbc4
            4.0
        
    

    
        
            
                org.springframework.boot
                spring-boot-maven-plugin

package com.example.demo.sqlserver;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/sqlserver")
public class Sqlserver {

    private final String jdbcDriver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
    private final String url = "jdbc:sqlserver://10.0.6.224:1433;DatabaseName=school";
    private final String userName = "xxx";
    private final String password  = "xxx";

    @GetMapping("/insert")
    public int insertBook(int idcount) {
        System.out.println("开始执行");

        idcount = selectBookByName("test")+1;

        int n = 0;
        String sql = "insert into student (SID,SNAME,MAJOR,BIRTH,SCORE,CID,STATUS) VALUES (?,?,?,?,?,?,?)";
        Connection conn = null;
        PreparedStatement ps = null;
        java.sql.Date pubDate = null;
        try {
            // 加载驱动
            Class.forName(jdbcDriver);
            // 获取连接
            conn = DriverManager.getConnection(url, userName, password);
            // 创建会话
            ps = conn.prepareStatement(sql);
            // 设置 ? 的值

            ps.setString(1, String.valueOf(idcount));
            ps.setString(2,"stu100" );
            ps.setString(3, "test");
            pubDate = new java.sql.Date(System.currentTimeMillis());
            ps.setDate(4, pubDate);
            ps.setString(5, "23.23");
            ps.setString(6, "1");
            ps.setString(7, "1");

            // 执行sql
            n = ps.executeUpdate();

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {     // 关闭数据库资源
            try {
                if (null != ps) {
                    ps.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                if (null != conn) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return n;
    }

    @GetMapping("/delete")
    public int deleteBook(int id) {
        System.out.println("开始执行");

        id =  selectBookByName("test");
        String sql = "delete from student where SID=?";
        int n = 0;
        Connection conn = null;
        PreparedStatement ps = null;

        try {
            // 加载驱动
            Class.forName(jdbcDriver);
            // 获取连接
            conn = DriverManager.getConnection(url, userName, password);
            // 创建会话
            ps = conn.prepareStatement(sql);
            // 设置 ? 的值
            ps.setInt(1, id);
            // 执行sql
            n =  ps.executeUpdate();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (null != ps) {
                    ps.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                if (null != conn) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        return n;
    }

    @GetMapping("/update")
    public int updateBook(int id) {
        System.out.println("开始执行");

        id = selectBookByName("test");
        String sql = "update student set SNAME=?, MAJOR=? where SID=?";
        int n = 0;
        Connection conn =  null;
        PreparedStatement ps = null;
        try {
            // 加载驱动
            Class.forName(jdbcDriver);
            // 获取连接
            conn = DriverManager.getConnection(url, userName, password);
            // 创建会话
            ps = conn.prepareStatement(sql);
            ps.setString(1, "test101");
            ps.setString(2, "aa");
            ps.setInt(3, id);
            n = ps.executeUpdate();

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (null != ps) {
                    ps.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                if (null != conn) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return n;
    }

    @GetMapping("/select")
    public int selectBookByName(String bookName) {
        System.out.println("开始执行");

//        String sql = "select MAX(SID) as IDCOUNT from student where MAJOR=?";
        String sql = "select MAX(SID) as IDCOUNT from student";

        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            // 加载驱动
            Class.forName(jdbcDriver);
            // 获取连接
            conn = DriverManager.getConnection(url, userName, password);
            // 创建会话
            ps = conn.prepareStatement(sql);
//            ps.setString(1, bookName);
            rs = ps.executeQuery();
            if (rs.next()) {
                return Integer.parseInt(rs.getString("IDCOUNT"));
//                int id = rs.getInt("id");
//                String name = rs.getString("bookName");
//                String author = rs.getString("author");
//                java.util.Date pubDate = rs.getDate("pubDate");
//                book = new Book(id, name, author, pubDate);
            }

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (null != ps) {
                    ps.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                if (null != conn) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return 0;
    }

    @GetMapping("/selectall")
    public List selectAllBook() {
        System.out.println("开始执行");

        String sql = "select * from student";
        List list = new ArrayList<>();
        Connection conn = null;
        PreparedStatement ps = null;
        ResultSet rs = null;

        try {
            // 加载驱动
            Class.forName(jdbcDriver);
            // 获取连接
            conn = DriverManager.getConnection(url, userName, password);
            // 创建会话
            ps = conn.prepareStatement(sql);
            // 获取结果集
            rs = ps.executeQuery();
            // 遍历结果集
            while (rs.next()) {
                Map map = new HashMap<>();

                map.put("SID",rs.getString("SID"));
                map.put("SNAME",rs.getString("SNAME"));
                map.put("MAJOR",rs.getString("MAJOR"));
                map.put("BIRTH",rs.getString("BIRTH"));
                map.put("SCORE",rs.getString("SCORE"));
                map.put("CID",rs.getString("CID"));
                map.put("STATUS",rs.getString("STATUS"));
//                int id = rs.getInt("id");
//                String bookName = rs.getString("bookName");
//                String author = rs.getString("author");
//                Date pubDate = rs.getDate("pubDate");

//                Book book = new Book(id, bookName, author, pubDate);
                list.add(map);
            }


        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            try {
                if (null != ps) {
                    ps.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
            try {
                if (null != conn) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

        return list;
    }

//    public static void main(String[] args) {
//        Sqlserver bookDao = new Sqlserver();
//        int idcount = bookDao.selectBookByName("test");
//
//        bookDao.insertBook(idcount+1);
//        bookDao.updateBook(idcount);
//        bookDao.deleteBook(idcount);
//
//        List maps = bookDao.selectAllBook();
//        System.out.println(maps);
//    }
}

student.sql




-- ----------------------------
-- Table structure for student
-- ----------------------------
IF EXISTS (SELECT * FROM sys.all_objects WHERE object_id = OBJECT_ID(N"[dbo].[student]") AND type IN ("U"))
	DROP TABLE [dbo].[student]
GO

CREATE TABLE [dbo].[student] (
  [SID] int  NOT NULL,
  [SNAME] varchar(20) COLLATE Chinese_PRC_CI_AS  NOT NULL,
  [MAJOR] varchar(100) COLLATE Chinese_PRC_CI_AS  NULL,
  [BIRTH] datetime  NULL,
  [SCORE] float(53)  NULL,
  [CID] int  NULL,
  [STATUS] varchar(3) COLLATE Chinese_PRC_CI_AS  NULL
)
GO

ALTER TABLE [dbo].[student] SET (LOCK_ESCALATION = TABLE)
GO


-- ----------------------------
-- Records of student
-- ----------------------------
BEGIN TRANSACTION
GO

INSERT INTO [dbo].[student]  VALUES (N"3", N"ggg", N"bbbb", N"2020-01-21 00:00:00.000", N"99.900001525878906", N"1", NULL)
GO

INSERT INTO [dbo].[student]  VALUES (N"4", N"stu4", N"cc", N"2019-04-03 16:11:26.130", N"99.900001525878906", N"1", NULL)
GO

COMMIT
GO


-- ----------------------------
-- Primary Key structure for table student
-- ----------------------------
ALTER TABLE [dbo].[student] ADD CONSTRAINT [PK__student__CA19597003317E3D] PRIMARY KEY CLUSTERED ([SID])
WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON)  
ON [PRIMARY]
GO

浏览器访问查询最大id

http://localhost:8082/sqlserver/select?bookName=2

查询所有

http://localhost:8082/sqlserver/selectall

新增

http://localhost:8082/sqlserver/insert?idcount=2

修改

http://localhost:8082/sqlserver/update?id=1

删除

http://localhost:8082/sqlserver/delete?id=1

文章详情

sqlserver jdbc增删改查

软考中级精品资料免费领

相关文章

猜你喜欢

sqlserver jdbc增删改查

SQLServer之T-SQL增、删、改、查

java中JDBC增删改查操作详解

jdbc连接的基本语句(增删查改)

JDBC实现数据库增删改查功能

JDBC 增删改的操作（2）

java中如何实现JDBC增删改查操作

sqlserver 中如何实现增删改查操作

JDBC如何访问MySQL数据库,并增删查改

JDBC怎么实现数据库增删改查功能

php怎么连接SqlServer并实现增删改查

JDBC 实现通用的增删改查基础类方法

怎么使用MySQL进行JDBC编程与增删改查

MySQL详解进行JDBC编程与增删改查方法

Java用jdbc连接实现对MySQL增删改查操作

mongodb 增删改查

golang增删改查

如何实现 Java 连接 SQL Server 进行增删改查？(java连接sqlserver怎么实现增删改查)

html增删改查

mysql增删改查