Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import java.sql.Connection;
- import java.sql.Statement;
- import java.sql.PreparedStatement;
- import java.sql.ResultSet;
- import java.sql.DriverManager;
- public class CRUD {
- public static void main(String[] args) {
- System.out.println("Connect to SQL Server and demo Create, Read, Update and Delete operations.");
- String connectionUrl = "jdbc:sqlserver://localhost:1433;databaseName=master;user=sa;password=your_password";
- try {
- // Load SQL Server JDBC driver and establish connection.
- System.out.print("Connecting to SQL Server ... ");
- try (Connection connection = DriverManager.getConnection(connectionUrl)) {
- System.out.println("done.");
- // Create a sample database
- System.out.print("Dropping and creating database 'SampleDB' ... ");
- // //SS: Blank comment. Remove it
- String sql = "DROP DATABASE IF EXISTS [SampleDB]; CREATE DATABASE [SampleDB]";
- try (Statement statement = connection.createStatement()) {
- statement.executeUpdate(sql);
- System.out.println("done.");
- }
- // Create a Table and insert some sample data
- System.out.print("Creating sample table with data, press ENTER to continue...");
- System.in.read();
- sql = new StringBuilder()
- .append("USE SampleDB; ")
- .append("CREATE TABLE Employees ( ")
- .append(" Id INT IDENTITY(1,1) NOT NULL PRIMARY KEY, ")
- .append(" Name NVARCHAR(50), ")
- .append(" Location NVARCHAR(50) ")
- .append("); ")
- .append("INSERT INTO Employees (Name, Location) VALUES ")
- .append("(N'Jared', N'Australia'), ")
- .append("(N'Nikita', N'India'), ")
- .append("(N'Tom', N'Germany'); ")
- .toString();
- try (Statement statement = connection.createStatement()) {
- statement.executeUpdate(sql);
- System.out.println("done.");
- }
- // INSERT demo
- System.out.print("Inserting a new row into table, press ENTER to continue...");
- System.in.read();
- sql = new StringBuilder()
- .append("INSERT Employees (Name, Location) ")
- .append("VALUES (?, ?);")
- .toString();
- try (PreparedStatement statement = connection.prepareStatement(sql)) {
- statement.setString(1, "Jake");
- statement.setString(2, "United States");
- int rowsAffected = statement.executeUpdate();
- System.out.println(rowsAffected + " row(s) inserted");
- }
- // UPDATE demo
- String userToUpdate = "Nikita";
- System.out.print("Updating 'Location' for user '" + userToUpdate + "', press ENTER to continue...");
- System.in.read();
- sql = "UPDATE Employees SET Location = N'United States' WHERE Name = ?";
- try (PreparedStatement statement = connection.prepareStatement(sql)) {
- statement.setString(1, userToUpdate);
- int rowsAffected = statement.executeUpdate();
- System.out.println( rowsAffected + " row(s) updated");
- }
- // DELETE demo
- String userToDelete = "Jared";
- System.out.print("Deleting user '" + userToDelete + "', press ENTER to continue...");
- System.in.read();
- sql = "DELETE FROM Employees WHERE Name = ?;";
- try (PreparedStatement statement = connection.prepareStatement(sql)) {
- statement.setString(1, userToDelete);
- int rowsAffected = statement.executeUpdate();
- System.out.println( rowsAffected + " row(s) deleted");
- }
- // READ demo
- System.out.print("Reading data from table, press ENTER to continue...");
- System.in.read();
- sql = "SELECT Id, Name, Location FROM Employees;";
- try (Statement statement = connection.createStatement();
- ResultSet resultSet = statement.executeQuery(sql)) {
- while (resultSet.next()) {
- System.out.println(resultSet.getInt(1) + " " + resultSet.getString(2) + " " + resultSet.getString(3));
- }
- }
- System.out.println("All done.");
- }
- } catch (Exception e) { // Do you want to restrict your exception to SqlException instead of catching all Exceptions?
- System.out.println(""); // SS: If you want to print a new line you dont have to use "" you can simply do System.out.println();
- e.printStackTrace();
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement