FilesExpand file tree

 master

/

Insert.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

131 lines (104 loc) · 2.83 KB

 master

/

Insert.java

Copy path

Top

File metadata and controls

• Code
• Blame

131 lines (104 loc) · 2.83 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

package simpledb;

/**

* Inserts tuples read from the child operator into the tableid specified in the

* constructor

*/

public class Insert extends Operator {

TransactionId tid;

DbIterator child;

int tableid;

TupleDesc FNresult;

boolean hasNotBeenUsed;

private static final long serialVersionUID = 1L;

/**

* Constructor.

*

* @param t

* The transaction running the insert.

* @param child

* The child operator from which to read tuples to be inserted.

* @param tableid

* The table in which to insert tuples.

* @throws DbException

* if TupleDesc of child differs from table into which we are to

* insert.

*/

public Insert(TransactionId t,DbIterator child, int tableid)

throws DbException {

// some code goes here

this.tid = t;

this.child = child;

this.tableid = tableid;

this.hasNotBeenUsed = true;

Type[] typeAr = new Type[]{Type.INT_TYPE};

String[] fieldAr = new String[]{"Num_inserted_tuples"};

FNresult = new TupleDesc(typeAr, fieldAr);

}

public TupleDesc getTupleDesc() {

// some code goes here

//return Database.getCatalog().getTupleDesc(tableid);

return FNresult;

}

public void open() throws DbException, TransactionAbortedException {

// some code goes here

child.open();

super.open();

}

public void close() {

// some code goes here

child.close();

super.close();

}

public void rewind() throws DbException, TransactionAbortedException {

// some code goes here

child.rewind();

//super.rewind(); //method doesn't exist

}

/**

* Inserts tuples read from child into the tableid specified by the

* constructor. It returns a one field tuple containing the number of

* inserted records. Inserts should be passed through BufferPool. An

* instances of BufferPool is available via Database.getBufferPool(). Note

* that insert DOES NOT need check to see if a particular tuple is a

* duplicate before inserting it.

*

* @return A 1-field tuple containing the number of inserted records, or

* null if called more than once.

* @see Database#getBufferPool

* @see BufferPool#insertTuple

*/

protected Tuple fetchNext() throws TransactionAbortedException, DbException {

// some code goes here

int count = 0;

if(!this.hasNotBeenUsed)

{

return null;

}

try

{

while(child.hasNext())

{

Database.getBufferPool().insertTuple(tid, tableid, child.next());

count +=1;

}

}

catch(Exception e)

{

e.printStackTrace();

}

//reporting purposes

Tuple t = new Tuple(FNresult);

t.setField(0, new IntField(count));

this.hasNotBeenUsed = false;

return t;

}

@Override

public DbIterator[] getChildren() {

// some code goes here

return null;

}

@Override

public void setChildren(DbIterator[] children) {

// some code goes here

}

}