package dbcontroller;

import java.sql.SQLException;

import java.io.Serializable;

import java.util.Iterator;

import java.util.HashMap;

import javax.sql.RowSet;

import org.apache.beehive.controls.api.bean.ControlExtension;

import dbControl.DatabaseControl;

import dbControl.DatabaseControl.ConnectionDataSource;

import dbControl.DatabaseControl.SQL;

import forms.Employee;

@ControlExtension

@ConnectionDataSource(jndiName="jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=Test;user=sa;password=sa")
 //配置数据库连接属性

public interface MyFirstDBControl extends DatabaseControl

{

    @SQL(statement="CREATE TABLE Employee (id INT PRIMARY KEY NOT NULL, " +

                   "name VARCHAR(50), age INT)")

    public void createTable() throws SQLException;

     @SQL(statement="DROP TABLE Employee")

    public void dropTable() throws SQLException;

    @SQL(statement="INSERT INTO Employee " + "(id, name, age) " +

                   "VALUES ({u.id}, {u.name}, {u.age})")

public void insertEmployee(Employee u) throws SQLException;

    @SQL(statement="UPDATE Employee SET age = {age} WHERE id = {id}")

    public void changeTitle(int id, String title) throws SQLException;

    @SQL(statement="DELETE FROM Employee WHERE id = {id}")

    public void deleteEmployee(int id) throws SQLException;

    @SQL(statement="SELECT name FROM Employee")

    public String[] selectAllName() throws SQLException;

    @SQL(statement="SELECT * FROM Employee WHERE id={id}")

    public Employee selectEmployee(int id) throws SQLException;

    @SQL(statement="SELECT * FROM Employee ORDER BY id")

    public Employee[] selectEmployees() throws SQLException;

    @SQL(statement="SELECT * FROM Employee ORDER BY id", iteratorElementType=Employee.class)

    public Iterator selectEmployeesWithIterator() throws SQLException;

    @SQL(statement="SELECT * FROM Employee ORDER BY id")

    public HashMap selectEmployeeWithHashMap() throws SQLException;

    @SQL(statement="SELECT * FROM Employee ORDER BY id", maxRows=1)

public Employee[] selectOneEmployee() throws SQLException;

    @SQL(statement="select count(*) from Employee")

public Integer getCount() throws SQLException;      //返回int型的一定要定义返回类型为Integer

}

package forms;

public class Employee {

    public Integer id;

    public String name;

    public int age;

    public Employee(Integer id, String name, int age) {

        this.id = id;

        this.name = name;

        this.age = age;

    }

    public Employee(Integer id) {

        this.id = id;

    }

    public Integer getId() {

        return this.id;

    }

    public void setId(Integer id) {

        this.id = id;

    }

    public String getName() {

        return this.name;

    }

    public void setName(String name) {

        this.name = name;

    }

    public int getAge() {

        return this.age;

    }

    public void setAge(int age) {

        this.age = age;

    }

}

import javax.servlet.http.HttpSession;

import org.apache.beehive.netui.pageflow.Forward;

import org.apache.beehive.netui.pageflow.PageFlowController;

import org.apache.beehive.netui.pageflow.annotations.Jpf;

import forms.Employee;                            //应用中所需的持久类

import dbcontroller.MyFirstDBControl;               //应用中所需的数据库操作的定义文件

import org.apache.beehive.controls.api.bean.Control;   //用来解释@Control，将MyFirstDBControl接口实现成bean，并完成实例化工作。

@Control

public MyFirstDBControl myControl;

public Employee u;                                 

@Jpf.Action(

        forwards={

           @Jpf.Forward(name="success", path="index.jsp")

        }

)

protected Forward begin()

{

        return new Forward("success");

}

@Jpf.Action(

        forwards={

           @Jpf.Forward(name="success", path="displaydata.jsp")

        }

)

protected Forward show() throws java.sql.SQLException{

u = myControl.selectEmployee(1);

getRequest().setAttribute("data",u);

return new Forward(“success”);

}

…………..

@Control

public MyFirstDBControl myControl;

public Vector u;           

…………..

protected Forward show() throws java.sql.SQLException{

u = new Vector();

Employee[] es = myControl.selectEmployees();     

    for(int i=0;i<es.length;i++) {

        u.add(es[i]);       

    }

return new Forward(“success”);

}

<netui-data:repeater dataSource="pageFlow.u">

        <netui-data:repeaterHeader>

                <table border="1">

                    <tr>

                        <td><b>id</b></td>

                        <td><b>name</b></td>   

                        <td><b>age</b></td>

                    </tr>

            </netui-data:repeaterHeader>

            <netui-data:repeaterItem>

                <tr>

                    <td>

                        <netui:label value="${container.item.id}" />

                    </td>

                    <td>

                        <netui:label value="${container.item.name}" />

                    </td>

                     <td>

                        <netui:label value="${container.item.age}" />

                    </td>

                </tr>

            </netui-data:repeaterItem>

            <netui-data:repeaterFooter>

                </table>

            </netui-data:repeaterFooter> 

  </netui-data:repeater>